This is an automated email from the ASF dual-hosted git repository. rmetzger pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8debdd0 [FLINK-24317][python][tests] Optimize the implementation of Top2 in test_flat_aggregate add f763706 [hotfix][connectors/kafka] Remove unused code from KafkaDynamicSink add f82b2a9 [FLINK-24281][connectors/kafka] Only allow KafkaSinkBuilder creation with KafkaSink.builder() add 4a89552 [FLINK-24281][connectors/kafka] Migrate all format tests from FlinkKafkaProducer to KafkaSink No new revisions were added by this update. Summary of changes: .../connector/kafka/sink/KafkaSinkBuilder.java | 2 + .../connectors/kafka/table/KafkaDynamicSink.java | 15 ---- .../kafka/table/KafkaChangelogTableITCase.java | 82 ++++++++-------------- .../connectors/kafka/table/KafkaTableTestBase.java | 3 + .../registry/test/TestAvroConsumerConfluent.java | 48 ++++++++----- 5 files changed, 68 insertions(+), 82 deletions(-)