This is an automated email from the ASF dual-hosted git repository. fpaul pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 860f0a2 [FLINK-21752] Add a call to TypeSerializer#duplicate in migration tests add 2e56653 [FLINK-25573][table] Add SinkV2Provider to execute SinkV2s with the TableAPI add 5846d8d [FLINK-25573][kafka] Migrate KafkaSink to SinkV2 No new revisions were added by this update. Summary of changes: .../5b9eed8a-5fb6-4373-98ac-3be2a71941b8 | 11 --- .../7602816f-5c01-4b7a-9e3e-235dfedec245 | 1 - .../flink/connector/kafka/sink/KafkaCommitter.java | 39 ++++------ .../flink/connector/kafka/sink/KafkaSink.java | 76 ++++++++++---------- .../flink/connector/kafka/sink/KafkaWriter.java | 36 ++++++---- .../connectors/kafka/table/KafkaDynamicSink.java | 4 +- .../connectors/kafka/table/ReducingUpsertSink.java | 52 ++++++-------- .../kafka/table/ReducingUpsertWriter.java | 22 +++--- .../connector/kafka/sink/KafkaCommitterTest.java | 84 +++++++++++++++------- .../connector/kafka/sink/KafkaWriterITCase.java | 72 ++++++++++++------- .../kafka/table/KafkaDynamicTableFactoryTest.java | 14 ++-- .../kafka/table/ReducingUpsertWriterTest.java | 32 +++++---- .../table/UpsertKafkaDynamicTableFactoryTest.java | 20 +++--- .../streaming/api/datastream/DataStreamSink.java | 3 +- .../api/transformations/SinkV1Adapter.java | 5 +- .../InitContextInitializationContextAdapter.java | 6 +- .../runtime/operators/sink/SinkWriterOperator.java | 1 - .../{SinkProvider.java => SinkV2Provider.java} | 15 ++-- .../plan/nodes/exec/common/CommonExecSink.java | 14 ++++ .../nodes/exec/common/CommonExecSinkITCase.java | 33 +++++++-- 20 files changed, 306 insertions(+), 234 deletions(-) rename {flink-core/src/main/java/org/apache/flink/api/connector => flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators}/sink/InitContextInitializationContextAdapter.java (89%) copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/{SinkProvider.java => SinkV2Provider.java} (78%)