[
https://issues.apache.org/jira/browse/FLINK-20947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17270227#comment-17270227
]
Jark Wu commented on FLINK-20947:
-
Hi [~weijiaxu], we have fixed this problem in master branch. Could
[
https://issues.apache.org/jira/browse/FLINK-20947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17270226#comment-17270226
]
Jark Wu commented on FLINK-20947:
-
Fixed in
- master: 90e680c9c579b2ffa1ca93ad7dfbaa5502dd8701
>
[
https://issues.apache.org/jira/browse/FLINK-20947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17266708#comment-17266708
]
Shengkai Fang commented on FLINK-20947:
---
Sorry for the late response. I think the tests works like
[
https://issues.apache.org/jira/browse/FLINK-20947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17264104#comment-17264104
]
Jark Wu commented on FLINK-20947:
-
1. I find that we don't have watermark pushdown with idle timeout
[
https://issues.apache.org/jira/browse/FLINK-20947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17264020#comment-17264020
]
Weijia Xu commented on FLINK-20947:
---
My pleasure, [~jark]
I think fix this issue is easy, what's
[
https://issues.apache.org/jira/browse/FLINK-20947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263907#comment-17263907
]
Jark Wu commented on FLINK-20947:
-
Good catch [~weijiaxu]! I think you are right.
> Unable to trigger
[
https://issues.apache.org/jira/browse/FLINK-20947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263895#comment-17263895
]
Weijia Xu commented on FLINK-20947:
---
I think the root cause is the watermark for the "idle" partition
[
https://issues.apache.org/jira/browse/FLINK-20947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263885#comment-17263885
]
Jark Wu commented on FLINK-20947:
-
cc [~fsk119] could you help to check whether the idle timeout works
