[jira] [Commented] (FLINK-27762) Kafka WakeupException during handling splits changes

[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554556#comment-17554556 ] Leonard Xu commented on FLINK-27762: fixed in master(1.16):50c19d9f534f86e228f3e0937d92baf766a57165

[jira] [Commented] (FLINK-27762) Kafka WakeupException during handling splits changes

[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17545668#comment-17545668 ] Mason Chen commented on FLINK-27762: Hi [~renqs], I also recently encountered a similar issue

[jira] [Commented] (FLINK-27762) Kafka WakeUpException during handling splits changes

[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543766#comment-17543766 ] Qingsheng Ren commented on FLINK-27762: --- Thanks a lot for the review [~zoucan] ! What about moving

[jira] [Commented] (FLINK-27762) Kafka WakeUpException during handling splits changes

[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543756#comment-17543756 ] zoucan commented on FLINK-27762: [~renqs]  Thanks for your effort for this issue. I‘ve reviewed your

[jira] [Commented] (FLINK-27762) Kafka WakeUpException during handling splits changes

[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17541933#comment-17541933 ] Martijn Visser commented on FLINK-27762: Thank you [~renqs] I've assigned it to you! > Kafka

[jira] [Commented] (FLINK-27762) Kafka WakeUpException during handling splits changes

[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17541932#comment-17541932 ] Qingsheng Ren commented on FLINK-27762: --- Thanks for reporting the issue [~zoucan]! I think it is

[jira] [Commented] (FLINK-27762) Kafka WakeUpException during handling splits changes

[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17541907#comment-17541907 ] Martijn Visser commented on FLINK-27762: [~renqs] WDYT? > Kafka WakeUpException during handling

[jira] [Commented] (FLINK-27762) Kafka WakeUpException during handling splits changes

[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17541896#comment-17541896 ] zoucan commented on FLINK-27762: [~martijnvisser]  Thanks for your reply. I have checked the source

[jira] [Commented] (FLINK-27762) Kafka WakeUpException during handling splits changes

[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17541861#comment-17541861 ] Martijn Visser commented on FLINK-27762: Can you please try this with the latest Flink 1.14