This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from a846a48 [FLINK-20975][hive][tests] Allow integral partition filter
pushdown
add 9267a52 [FLINK-22452][Connectors/Kafka] Support specifying custom
transactional.id prefix in FlinkKafkaProducer
No new revisions were added by this update.
Summary of changes:
.../connectors/kafka/FlinkKafkaProducer.java | 62 ++++++++---
.../connectors/kafka/FlinkKafkaProducerITCase.java | 124 +++++++++++++++++++++
.../connectors/kafka/FlinkKafkaProducerTest.java | 8 ++
.../util/AbstractStreamOperatorTestHarness.java | 18 +++
.../util/OneInputStreamOperatorTestHarness.java | 11 ++
5 files changed, 210 insertions(+), 13 deletions(-)
