[jira] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17130745#comment-17130745 ] Aljoscha Krettek commented on FLINK-17327: -- For posterity, here's a summary of

[jira] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129590#comment-17129590 ] Aljoscha Krettek commented on FLINK-17327: -- I was mixing up issues before, KAFK

[jira] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128272#comment-17128272 ] Aljoscha Krettek commented on FLINK-17327: -- I managed to find a fix for this:

[jira] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104242#comment-17104242 ] Aljoscha Krettek commented on FLINK-17327: -- Btw, this can be reproduced even si

[jira] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099782#comment-17099782 ] Jun Qin commented on FLINK-17327: - What do you mean by "job fails successfully"? With Fl

[jira] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099777#comment-17099777 ] Aljoscha Krettek commented on FLINK-17327: -- I think the Kafka code doesn't like

[jira] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099775#comment-17099775 ] Aljoscha Krettek commented on FLINK-17327: -- For testing I tried this against Ka

[jira] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099751#comment-17099751 ] Aljoscha Krettek commented on FLINK-17327: -- This is another fix we need: https:

[jira] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099625#comment-17099625 ] Piotr Nowojski commented on FLINK-17327: [~qinjunjerry] the bug that [~aljoscha]

[jira] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099611#comment-17099611 ] Jun Qin commented on FLINK-17327: - The above scenario was tested with kafka_2.12-2.5.0

[jira] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099608#comment-17099608 ] Aljoscha Krettek commented on FLINK-17327: -- The fix I mentioned is only availab

[jira] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099045#comment-17099045 ] Aljoscha Krettek commented on FLINK-17327: -- I believe that {{TransactionalReque

[jira] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17090576#comment-17090576 ] Piotr Nowojski commented on FLINK-17327: Thanks [~qinjunjerry] for submitting th

[jira] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17090402#comment-17090402 ] Piotr Nowojski commented on FLINK-17327: I'm analysing this [~aljoscha] and ther

[jira] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17090378#comment-17090378 ] Aljoscha Krettek commented on FLINK-17327: -- Isn't this the expected behaviour?

[jira] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17090018#comment-17090018 ] Jun Qin commented on FLINK-17327: - Added also the Standalonesession logs which covers th

[jira] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089755#comment-17089755 ] Jun Qin commented on FLINK-17327: - {{TM.log}} is for a job where Kafka Source and Kafka