[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-04-04 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708345#comment-17708345 ] Lyn Zhang commented on FLINK-18996: --- [~lincoln.86xy]  I can't edit this issue, seems o

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-27 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17705363#comment-17705363 ] lincoln lee commented on FLINK-18996: - fixed in master: 2e7f63948cfff7445648aa17b6f3

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-23 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704410#comment-17704410 ] Lyn Zhang commented on FLINK-18996: --- [~lincoln.86xy] , I have updated [this PR|https:

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-23 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703988#comment-17703988 ] lincoln lee commented on FLINK-18996: - [~zicat] assigned to you > Avoid disorder fo

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-23 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703987#comment-17703987 ] lincoln lee commented on FLINK-18996: - [~zicat] Of course, welcome for contributing

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-22 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703835#comment-17703835 ] Lyn Zhang commented on FLINK-18996: --- If need, I can modify [this PR|https://github.com

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-22 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703834#comment-17703834 ] Lyn Zhang commented on FLINK-18996: --- [~lincoln.86xy] good solution. In our inner branc

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-22 Thread Chalres Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703718#comment-17703718 ] Chalres Tan commented on FLINK-18996: - [~lincoln.86xy] yes, sounds good > Avoid dis

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-22 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703660#comment-17703660 ] Benchao Li commented on FLINK-18996: Sounds good to me. > Avoid disorder for time i

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-22 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703640#comment-17703640 ] lincoln lee commented on FLINK-18996: - +1 to set the `minCleanUpInterval` to 0 by de

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-21 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703494#comment-17703494 ] Benchao Li commented on FLINK-18996: {{minCleanUpInterval = 0}} is how we resolved t

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-21 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703481#comment-17703481 ] Lyn Zhang commented on FLINK-18996: --- [~charles-tan] In my jobs, set minCleanUpInterval

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-21 Thread Chalres Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703468#comment-17703468 ] Chalres Tan commented on FLINK-18996: - +1 [~zicat]. I was pointed to [this design do

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-21 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703445#comment-17703445 ] Lyn Zhang commented on FLINK-18996: --- An interval join followed by a window aggregate i

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-21 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703443#comment-17703443 ] Lyn Zhang commented on FLINK-18996: --- [~lincoln.86xy] [~charles-tan]  The watermark rep

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-21 Thread Chalres Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703262#comment-17703262 ] Chalres Tan commented on FLINK-18996: - [~lincoln.86xy], [~zicat] has already opened

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2023-03-21 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703105#comment-17703105 ] lincoln lee commented on FLINK-18996: - Besides a same issue reported in FLINK-31212,

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2021-04-22 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327687#comment-17327687 ] Flink Jira Bot commented on FLINK-18996: This major issue is unassigned and itse

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2020-08-23 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17182624#comment-17182624 ] Benchao Li commented on FLINK-18996: CC [~jark] [~fhueske]  > Avoid disorder for ti

[jira] [Commented] (FLINK-18996) Avoid disorder for time interval join

2020-08-23 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17182623#comment-17182623 ] Benchao Li commented on FLINK-18996: After some more deep-diving into the code with