This is an automated email from the ASF dual-hosted git repository.
kunni pushed a change to branch FLINK-38729-2
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
from e5e8b48be Fix compile.
add 1bfa51294 Add flink-cdc-flink1.20-compat module.
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/flink/cdc/cli/CliFrontend.java | 9 +-
.../flink/cdc/cli/utils/ConfigurationUtils.java | 14 +-
.../org/apache/flink/cdc/cli/CliFrontendTest.java | 3 +-
flink-cdc-composer/pom.xml | 14 +
flink-cdc-dist/pom.xml | 18 ++
.../pom.xml | 6 +-
.../typeutils/TypeSerializerSnapshotAdapter.java | 4 +-
.../operators/AbstractStreamOperatorAdapter.java | 7 +-
.../apache/flink/runtime/event/WatermarkEvent.java | 4 +-
.../typeutils/TypeSerializerSnapshotAdapter.java} | 20 +-
.../operators/AbstractStreamOperatorAdapter.java} | 30 +--
.../api/operators/YieldingOperatorFactory.java} | 6 +-
flink-cdc-runtime/pom.xml | 36 +++
.../schema/distributed/SchemaOperator.java | 4 +-
.../schema/regular/BatchSchemaOperator.java | 7 +-
.../operators/schema/regular/SchemaOperator.java | 7 +-
.../sink/BatchDataSinkFunctionOperator.java | 3 -
.../sink/BatchDataSinkWriterOperator.java | 172 ++++--------
.../operators/sink/DataSinkFunctionOperator.java | 3 -
.../operators/sink/DataSinkWriterOperator.java | 292 +++++----------------
.../sink/DataSinkWriterOperatorFactory.java | 51 +---
.../operators/transform/PostTransformOperator.java | 4 +-
.../operators/transform/PreTransformOperator.java | 7 +-
.../BatchRegularPrePartitionOperator.java | 8 +-
.../DistributedPrePartitionOperator.java | 8 +-
.../partitioning/RegularPrePartitionOperator.java | 7 +-
.../cdc/runtime/serializer/EnumSerializer.java | 32 +--
.../NestedSerializersSnapshotDelegate.java | 36 +--
.../serializer/NullableSerializerWrapper.java | 21 +-
.../serializer/data/ArrayDataSerializer.java | 25 +-
.../serializer/data/DecimalDataSerializer.java | 22 +-
.../data/LocalZonedTimestampDataSerializer.java | 23 +-
.../runtime/serializer/data/MapDataSerializer.java | 23 +-
.../serializer/data/TimestampDataSerializer.java | 22 +-
.../data/ZonedTimestampDataSerializer.java | 20 +-
.../cdc/runtime/utils/FlinkCompatibilityUtils.java | 153 -----------
.../schema/distributed/SchemaEvolveTest.java | 7 +-
.../operators/sink/DataSinkOperatorAdapter.java | 14 +-
.../cdc/runtime/serializer/EnumSerializerTest.java | 7 +-
.../cdc/runtime/serializer/SerializerTestBase.java | 3 +-
.../DistributedEventOperatorTestHarness.java | 101 +++----
.../operators/RegularEventOperatorTestHarness.java | 112 ++++----
pom.xml | 1 +
43 files changed, 427 insertions(+), 939 deletions(-)
copy {flink-cdc-flink2.2-compat => flink-cdc-flink1.20-compat}/pom.xml (94%)
copy
flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/connector/sink2/WithPostCommitTopology.java
=>
flink-cdc-flink1.20-compat/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshotAdapter.java
(85%)
copy
flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/api/connector/sink2/TwoPhaseCommittingSink.java
=>
flink-cdc-flink1.20-compat/src/main/java/org/apache/flink/cdc/runtime/operators/AbstractStreamOperatorAdapter.java
(81%)
copy
flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/connector/sink2/WithPostCommitTopology.java
=>
flink-cdc-flink1.20-compat/src/main/java/org/apache/flink/runtime/event/WatermarkEvent.java
(85%)
copy
flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/{table/api/ValidationException.java
=> api/common/typeutils/TypeSerializerSnapshotAdapter.java} (65%)
copy
flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/{streaming/api/functions/source/RichParallelSourceFunction.java
=> cdc/runtime/operators/AbstractStreamOperatorAdapter.java} (53%)
copy
flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/{api/connector/sink2/TwoPhaseCommittingSink.java
=> streaming/api/operators/YieldingOperatorFactory.java} (82%)
delete mode 100644
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/utils/FlinkCompatibilityUtils.java
