Flink CI Thu, 31 Oct 2019 05:14:13 -0700
apache
/
flink
master
Tony Wei
[FLINK-14302] [kafka] FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS