[jira] [Commented] (FLINK-27318) KafkaSink: when init transaction, it take too long to get a producerId with epoch=0

[ https://issues.apache.org/jira/browse/FLINK-27318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17531056#comment-17531056 ] Zhengqi Zhang commented on FLINK-27318: --- I understand the rationale for this part of the code

[jira] [Commented] (FLINK-27318) KafkaSink: when init transaction, it take too long to get a producerId with epoch=0

[ https://issues.apache.org/jira/browse/FLINK-27318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17530623#comment-17530623 ] Arvid Heise commented on FLINK-27318: - This is exactly what I meant: You don't restart a task, you

[jira] [Commented] (FLINK-27318) KafkaSink: when init transaction, it take too long to get a producerId with epoch=0

[ https://issues.apache.org/jira/browse/FLINK-27318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17530498#comment-17530498 ] Zhengqi Zhang commented on FLINK-27318: --- This can happen if the task runs for a while and

[jira] [Commented] (FLINK-27318) KafkaSink: when init transaction, it take too long to get a producerId with epoch=0

[ https://issues.apache.org/jira/browse/FLINK-27318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527413#comment-17527413 ] Arvid Heise commented on FLINK-27318: - Btw your scenario could also happen if many successive

[jira] [Commented] (FLINK-27318) KafkaSink: when init transaction, it take too long to get a producerId with epoch=0

[ https://issues.apache.org/jira/browse/FLINK-27318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527412#comment-17527412 ] Arvid Heise commented on FLINK-27318: - Are you sure your test is realistic? In a production setup,

[jira] [Commented] (FLINK-27318) KafkaSink: when init transaction, it take too long to get a producerId with epoch=0

[ https://issues.apache.org/jira/browse/FLINK-27318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525568#comment-17525568 ] Zhengqi Zhang commented on FLINK-27318: --- [~arvid]  it take too long to abort previous