[jira] [Commented] (FLINK-18830) JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty

2020-10-06 Thread liupengcheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208780#comment-17208780 ] liupengcheng commented on FLINK-18830: -- [~aljoscha] [~jark] Thanks for clarification, yes, I think

[jira] [Commented] (FLINK-18830) JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty

2020-09-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17203617#comment-17203617 ] Jark Wu commented on FLINK-18830: - I agree with [~aljoscha]. I'm pretty sure the current window join in

[jira] [Commented] (FLINK-18830) JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty

2020-09-28 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17203111#comment-17203111 ] Aljoscha Krettek commented on FLINK-18830: -- If it's for the Table API then we should keep it as

[jira] [Commented] (FLINK-18830) JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty

2020-09-25 Thread liupengcheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202114#comment-17202114 ] liupengcheng commented on FLINK-18830: -- hi,[~aljoscha] I think you've missed some information, the

[jira] [Commented] (FLINK-18830) JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty

2020-09-15 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196182#comment-17196182 ] Aljoscha Krettek commented on FLINK-18830: -- I would be against changing the semantics of join

[jira] [Commented] (FLINK-18830) JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty

2020-09-11 Thread liupengcheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194313#comment-17194313 ] liupengcheng commented on FLINK-18830: -- Hi, [~aljoscha] It's about both of them. I'm thinking about

[jira] [Commented] (FLINK-18830) JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty

2020-08-25 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183991#comment-17183991 ] Aljoscha Krettek commented on FLINK-18830: -- The documentation describes {{DataStream.join()}}

[jira] [Commented] (FLINK-18830) JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty

2020-08-11 Thread liupengcheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175288#comment-17175288 ] liupengcheng commented on FLINK-18830: -- cc [~aljoscha] [~dwysakowicz] > JoinCoGroupFunction and

[jira] [Commented] (FLINK-18830) JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty

2020-08-10 Thread liupengcheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174370#comment-17174370 ] liupengcheng commented on FLINK-18830: -- The above plan allows evaluating user defined functions(may

[jira] [Commented] (FLINK-18830) JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty

2020-08-06 Thread liupengcheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172797#comment-17172797 ] liupengcheng commented on FLINK-18830: -- First, I think we can create a new functionalInterface,