Github user hequn8128 commented on the issue:
https://github.com/apache/flink/pull/4471
Hi @fhueske , the pr has been updated according to your comments and also
has been rebased to the latest master. The pr mainly includes the following
changes:
1. Refactor `UpdatingPlanChecker`. Change the unique key extractor logic of
join and use the lexicographic smallest attribute as the common group id.
2. Support time indicator attributes. In fact, we do not need to add
special processing logic. Time indicator will be transmitted to the downstream.
3. Add more test cases.
4. Refactor stream join function.
---
