This is an automated email from the ASF dual-hosted git repository. gaoyunhaii pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 13b203f [FLINK-26440][connector/filesystem] Make CompactorOperatorStateHandler supporting unaligned checkpoint. add 948f571 [hotfix][streaming] Enabling GlobalCommitter SinkITCases add 955e5ff [FLINK-26516][streaming] Recover GlobalCommittables with Sink V1 GlobalCommittable serializer No new revisions were added by this update. Summary of changes: .../connector/sink2/GlobalCommittableWrapper.java | 31 +- .../connector/sink2/GlobalCommitterOperator.java | 63 +++- .../connector/sink2/GlobalCommitterSerializer.java | 140 ++++++++ .../api/transformations/SinkV1Adapter.java | 24 +- .../sink/SinkV1WriterCommittableSerializer.java | 57 +++ .../runtime/operators/sink/SinkWriterOperator.java | 71 +++- .../sink/committables/CommittableCollector.java | 2 +- .../CommittableCollectorSerializer.java | 17 +- .../SinkV1CommittableDeserializer.java | 55 +++ .../translators/SinkTransformationTranslator.java | 15 +- .../sink2/GlobalCommitterSerializerTest.java | 123 +++++++ .../operators/sink/SinkWriterOperatorTest.java | 129 +++++++ .../CommittableCollectorSerializerTest.java | 35 +- .../flink/test/streaming/runtime/SinkITCase.java | 5 - .../runtime/UnifiedSinkMigrationITCase.java | 382 +++++++++++++++++++++ .../savepoint-7bd90b-3a2cda6957cb/_metadata | Bin 0 -> 1640 bytes 16 files changed, 1064 insertions(+), 85 deletions(-) copy flink-core/src/main/java/org/apache/flink/api/common/io/compression/XZInputStreamFactory.java => flink-streaming-java/src/main/java/org/apache/flink/streaming/api/connector/sink2/GlobalCommittableWrapper.java (53%) create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/connector/sink2/GlobalCommitterSerializer.java create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/SinkV1WriterCommittableSerializer.java create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/committables/SinkV1CommittableDeserializer.java create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/api/connector/sink2/GlobalCommitterSerializerTest.java create mode 100644 flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/UnifiedSinkMigrationITCase.java create mode 100644 flink-tests/src/test/resources/unified-sink-migration-test/savepoint-7bd90b-3a2cda6957cb/_metadata