[jira] [Commented] (FLINK-6204) Improve Event-Time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15944998#comment-15944998 ] hongyuhong commented on FLINK-6204: --- I think the memory of 'sortedTimestamps' is the sam

[jira] [Commented] (FLINK-6082) Support window definition for SQL Queries based on WHERE clause with time condition

[ https://issues.apache.org/jira/browse/FLINK-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15946417#comment-15946417 ] hongyuhong commented on FLINK-6082: --- Hi [~fhueske], i think what radu means about using

[jira] [Commented] (FLINK-6200) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-6200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948273#comment-15948273 ] hongyuhong commented on FLINK-6200: --- Hi [~sunjincheng121] i have implemented it based on

[jira] [Commented] (FLINK-6204) Improve Event-Time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948570#comment-15948570 ] hongyuhong commented on FLINK-6204: --- Hi [~sunjincheng121], i agree with you that we need

[jira] [Commented] (FLINK-6204) Improve Event-Time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948628#comment-15948628 ] hongyuhong commented on FLINK-6204: --- Hi [~fhueske], agree +1 > Improve Event-Time OVER

[jira] [Commented] (FLINK-6200) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-6200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948826#comment-15948826 ] hongyuhong commented on FLINK-6200: --- Hi [~sunjincheng121] thanks very much.I'd appreciat

[jira] [Commented] (FLINK-5725) Support JOIN between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950486#comment-15950486 ] hongyuhong commented on FLINK-5725: --- Hi [~fhueske], thanks for your feedback. I agree wi

[jira] [Created] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

hongyuhong created FLINK-6232: - Summary: Support proctime inner equi-join between two streams in the SQL API Key: FLINK-6232 URL: https://issues.apache.org/jira/browse/FLINK-6232 Project: Flink

[jira] [Created] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

hongyuhong created FLINK-6233: - Summary: Support rowtime inner equi-join between two streams in the SQL API Key: FLINK-6233 URL: https://issues.apache.org/jira/browse/FLINK-6233 Project: Flink I

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960223#comment-15960223 ] hongyuhong commented on FLINK-6233: --- Hi [~fhueske], i would deal with the out-of-order r

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960505#comment-15960505 ] hongyuhong commented on FLINK-6233: --- Hi [~fhueske], the reason i think we need to keep t

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15962727#comment-15962727 ] hongyuhong commented on FLINK-6232: --- Hi [~fhueske], I have made a preliminary implementa

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15973982#comment-15973982 ] hongyuhong commented on FLINK-6232: --- Hi [~fhueske] i have implement it use normal timest

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16003957#comment-16003957 ] hongyuhong commented on FLINK-6232: --- Hi [~fhueske], I have merge the flink-5884 time ind

[jira] [Commented] (FLINK-6858) Unbounded event time Over Window emits incorrect timestamps

[ https://issues.apache.org/jira/browse/FLINK-6858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039959#comment-16039959 ] hongyuhong commented on FLINK-6858: --- Hi [~fhueske], the implemention of unbounded event-

[jira] [Assigned] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hongyuhong reassigned FLINK-6233: - Assignee: Xingcan Cui (was: hongyuhong) > Support rowtime inner equi-join between two streams in

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16092438#comment-16092438 ] hongyuhong commented on FLINK-6233: --- Hi [~fhueske], [~xccui] is now working on this issu