[
https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213148#comment-16213148
]
ASF GitHub Bot commented on FLINK-6094:
---------------------------------------
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.
> Implement stream-stream proctime non-window inner join
> -------------------------------------------------------
>
> Key: FLINK-6094
> URL: https://issues.apache.org/jira/browse/FLINK-6094
> Project: Flink
> Issue Type: New Feature
> Components: Table API & SQL
> Reporter: Shaoxuan Wang
> Assignee: Hequn Cheng
>
> This includes:
> 1.Implement stream-stream proctime non-window inner join
> 2.Implement the retract process logic for join
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
