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(-)
