Hi, jincheng Thanks for bringing up this discussion, I'am working on this blocker issue ([FLINK-12297] Clean the closure for OutputTags in PatternStream), but it has not been merged due to lack of reviewers, I think it should be solved in 1.8.1.
Thanks, Aitozi -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/