[jira] [Commented] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

2019-10-09 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16947388#comment-16947388 ] Jiangjie Qin commented on FLINK-14302: -- [~tonywei] Ah, you are right. I apparently misunderstood

[jira] [Commented] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

2019-10-08 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16947309#comment-16947309 ] Wei-Che Wei commented on FLINK-14302: - Hi [~becket_qin] I think the error was from

[jira] [Commented] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

2019-10-08 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16947123#comment-16947123 ] Jiangjie Qin commented on FLINK-14302: -- [~tonywei] Thanks for the explanation. I am still a little

[jira] [Commented] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

2019-10-06 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16945515#comment-16945515 ] Wei-Che Wei commented on FLINK-14302: - Hi [~becket_qin]  The root cause of NOT_COORDINATOR is not

[jira] [Commented] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

2019-10-06 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16945485#comment-16945485 ] Jiangjie Qin commented on FLINK-14302: -- [~tonywei] Really sorry for the late response. I was on a

[jira] [Commented] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

2019-10-01 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16941640#comment-16941640 ] Wei-Che Wei commented on FLINK-14302: - Sorry for that I didn't notice that the contribution flow has