[jira] [Commented] (FLINK-31305) KafkaWriter doesn't wait for errors for in-flight records before completing flush

[ https://issues.apache.org/jira/browse/FLINK-31305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712925#comment-17712925 ] Martijn Visser commented on FLINK-31305: [~asardaes] Yes, given that this is backported to the

[jira] [Commented] (FLINK-31305) KafkaWriter doesn't wait for errors for in-flight records before completing flush

[ https://issues.apache.org/jira/browse/FLINK-31305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712648#comment-17712648 ] Alexis Sarda-Espinosa commented on FLINK-31305: --- I understand the externalized release of

[jira] [Commented] (FLINK-31305) KafkaWriter doesn't wait for errors for in-flight records before completing flush

[ https://issues.apache.org/jira/browse/FLINK-31305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17705651#comment-17705651 ] Tzu-Li (Gordon) Tai commented on FLINK-31305: - Merged for {{apache/flink:main}} with

[jira] [Commented] (FLINK-31305) KafkaWriter doesn't wait for errors for in-flight records before completing flush

[ https://issues.apache.org/jira/browse/FLINK-31305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17703866#comment-17703866 ] Tzu-Li (Gordon) Tai commented on FLINK-31305: - thanks [~mason6345] for the ping! I've

[jira] [Commented] (FLINK-31305) KafkaWriter doesn't wait for errors for in-flight records before completing flush

[ https://issues.apache.org/jira/browse/FLINK-31305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17703855#comment-17703855 ] Mason Chen commented on FLINK-31305: [~martijnvisser] [~tzulitai] Have time to review this small

[jira] [Commented] (FLINK-31305) KafkaWriter doesn't wait for errors for in-flight records before completing flush

[ https://issues.apache.org/jira/browse/FLINK-31305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699077#comment-17699077 ] Mason Chen commented on FLINK-31305: BTW, I had a mishap with git and so this is the proper Github

[jira] [Commented] (FLINK-31305) KafkaWriter doesn't wait for errors for in-flight records before completing flush

[ https://issues.apache.org/jira/browse/FLINK-31305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698815#comment-17698815 ] Mason Chen commented on FLINK-31305: [~martijnvisser] Yes it does affect 1.17. Makes sense, and my

[jira] [Commented] (FLINK-31305) KafkaWriter doesn't wait for errors for in-flight records before completing flush

[ https://issues.apache.org/jira/browse/FLINK-31305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698798#comment-17698798 ] Martijn Visser commented on FLINK-31305: [~mason6345] IIRC this would also affect Flink 1.17,

[jira] [Commented] (FLINK-31305) KafkaWriter doesn't wait for errors for in-flight records before completing flush

[ https://issues.apache.org/jira/browse/FLINK-31305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698789#comment-17698789 ] Mason Chen commented on FLINK-31305: Opened a PR! cc: [~stevenz3wu] [~martijnvisser] [~tzulitai]  >

[jira] [Commented] (FLINK-31305) KafkaWriter doesn't wait for errors for in-flight records before completing flush

[ https://issues.apache.org/jira/browse/FLINK-31305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698267#comment-17698267 ] Martijn Visser commented on FLINK-31305: [~tzulitai] FYI > KafkaWriter doesn't wait for errors

[jira] [Commented] (FLINK-31305) KafkaWriter doesn't wait for errors for in-flight records before completing flush

[ https://issues.apache.org/jira/browse/FLINK-31305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695932#comment-17695932 ] Mason Chen commented on FLINK-31305: Hi all, this is a critical regression for deployments who have