You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fp...@apache.org on 2022/02/04 12:31:33 UTC
[flink] branch master updated (860f0a2 -> 5846d8d)

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