Github user hequn8128 commented on the issue: https://github.com/apache/flink/pull/5327 @twalthr Hi, thanks for your review. I have updated the pr according to your suggestions. Changes mainly include: - Remove changes about UpsertSink - Refactor test case name and add more test to cover code path - Add more method comments - Add another base class `NonWindowOuterJoinWithNonEquiPredicates` and move corresponding variables and functions into it. - Split `CRowWrappingMultiOutputCollector` into `CRowWrappingMultiOutputCollector` and `LazyOutputCollector`. Best, Hequn.
---