[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2023-10-17 Thread tanjialiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776082#comment-17776082 ] tanjialiang commented on FLINK-29692: - Hi everyone, I notice that there is no solution yet. I want

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2023-05-02 Thread Charles Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17718710#comment-17718710 ] Charles Tan commented on FLINK-29692: - [~jark] your point makes sense. However, it can be cumbersome

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2023-04-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715607#comment-17715607 ] Jark Wu commented on FLINK-29692: - I think early fire / late arrival is a great feature, but I just want

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2023-04-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715604#comment-17715604 ] Jark Wu commented on FLINK-29692: - Hi [~charles-tan], yes, they have some differences. Group Aggregate

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2023-04-21 Thread Chalres Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715100#comment-17715100 ] Chalres Tan commented on FLINK-29692: - re [~jark]: Thanks for the response. The example query you

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2023-04-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714985#comment-17714985 ] Jark Wu commented on FLINK-29692: - Hi [~charles-tan], thank you for sharing your use case. I'm just

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2023-04-20 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714815#comment-17714815 ] Aitozi commented on FLINK-29692: hi, sorry for jumping into this discussion. I want to share two

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2023-04-18 Thread Chalres Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17713726#comment-17713726 ] Chalres Tan commented on FLINK-29692: - hi [~martijnvisser], there are many use cases that I believe

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2023-04-17 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712941#comment-17712941 ] Martijn Visser commented on FLINK-29692: [~charles-tan] Could you also elaborate on your use

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2023-04-13 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711990#comment-17711990 ] Martijn Visser commented on FLINK-29692: [~charles-tan] I don’t think there’s consensus yet how

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2023-04-13 Thread Chalres Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711958#comment-17711958 ] Chalres Tan commented on FLINK-29692: - Hi all, I notice this thread has gotten a little bit stale

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2022-10-25 Thread Jakub Partyka (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623595#comment-17623595 ] Jakub Partyka commented on FLINK-29692: --- {quote}Could you describe the demand in detail 

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2022-10-24 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623481#comment-17623481 ] Benchao Li commented on FLINK-29692: {quote}'Early fire' would periodically sent intermediate result

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2022-10-24 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623154#comment-17623154 ] Jing Zhang commented on FLINK-29692: [~canopenerda] Thanks for sharing.  The demand is a

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2022-10-24 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623143#comment-17623143 ] Jing Zhang commented on FLINK-29692: [~libenchao] Thanks for sharing. 'Early fire' would

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2022-10-24 Thread Canope Nerda (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623052#comment-17623052 ] Canope Nerda commented on FLINK-29692: -- [~jingzhang] Let me elaborate my case a little bit. First

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2022-10-23 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17622950#comment-17622950 ] Benchao Li commented on FLINK-29692: Regarding "early-fire with window" versus "unbounded

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2022-10-23 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17622940#comment-17622940 ] Jing Zhang commented on FLINK-29692: Sorry for late response. I'm still wondering whether we really

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2022-10-21 Thread Jakub Partyka (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1764#comment-1764 ] Jakub Partyka commented on FLINK-29692: --- It would be really nice if Windowing TVF's supported

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2022-10-20 Thread Canope Nerda (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621435#comment-17621435 ] Canope Nerda commented on FLINK-29692: -- Thanks [~jark] for suggesting the legacy group window agg.

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2022-10-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621167#comment-17621167 ] Jark Wu commented on FLINK-29692: - I'm fine with supporting this feature. But we have supported

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2022-10-20 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17620957#comment-17620957 ] Martijn Visser commented on FLINK-29692: [~godfrey] [~jark] [~jingzhang] WDYT? > Support