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 b0764446c Fix CI failure.
add a3adc9d3f Add flink-cdc-flink2.2-compat module.
No new revisions were added by this update.
Summary of changes:
.github/workflows/modules.py | 3 +-
flink-cdc-cli/pom.xml | 8 +
.../java/org/apache/flink/cdc/cli/CliFrontend.java | 8 +-
.../flink/cdc/cli/utils/ConfigurationUtils.java | 6 +-
.../org/apache/flink/cdc/cli/CliFrontendTest.java | 9 +-
flink-cdc-common/pom.xml | 32 +-
.../flink/cdc/common/factories/FactoryHelper.java | 2 +-
.../flink/cdc/common/sink/EventSinkProvider.java | 1 +
.../cdc/common/source/EventSourceProvider.java | 1 +
.../cdc/common/factories/FactoryHelperTests.java | 2 +-
flink-cdc-composer/pom.xml | 15 +-
.../flink/translator/DataSinkTranslator.java | 261 ++-------
.../flink/translator/DataSourceTranslator.java | 67 +--
.../testsource/source/DistributedDataSource.java | 5 +-
.../testsource/source/DistributedSource.java | 587 ---------------------
.../source/DistributedSourceFunction.java | 276 ++++++++++
.../sink/ElasticsearchDataSinkFactory.java | 2 +-
.../sink/ElasticsearchDataSinkFactoryTest.java | 2 +-
.../fluss/factory/FlussDataSinkFactoryTest.java | 2 +-
.../hudi/sink/HudiDataSinkFactoryTest.java | 2 +-
.../iceberg/sink/IcebergDataSinkFactoryTest.java | 2 +-
.../kafka/sink/KafkaDataSinkFactoryTest.java | 2 +-
.../mysql/factory/MySqlDataSourceFactory.java | 2 +-
.../mysql/source/MySqlDataSourceFactoryTest.java | 2 +-
.../oracle/factory/OracleDataSourceFactory.java | 2 +-
.../paimon/sink/PaimonDataSinkFactoryTest.java | 2 +-
.../factory/PostgresDataSourceFactory.java | 2 +-
.../factory/PostgresDataSourceFactoryTest.java | 2 +-
.../sink/StarRocksDataSinkFactoryTest.java | 2 +-
.../pom.xml | 132 -----
.../cdc/connectors/values/sink/ValuesDataSink.java | 187 -------
.../org.apache.flink.cdc.common.factories.Factory | 16 -
.../flink-cdc-pipeline-connector-values/pom.xml | 35 ++
.../cdc/connectors/values/sink/ValuesDataSink.java | 10 +-
.../values/sink/ValuesDataSinkFunction.java | 101 ++++
.../values/source/ValuesDataSourceITCase.java | 4 +-
.../flink-cdc-pipeline-connectors/pom.xml | 1 -
flink-cdc-dist/pom.xml | 5 +
.../flink-cdc-pipeline-e2e-tests-2.x/pom.xml | 4 +-
.../tests/utils/PipelineTestEnvironment.java | 2 +-
.../cdc/pipeline/tests/MaxComputeE2eITCase.java | 2 +-
.../cdc/pipeline/tests/MySqlToHudiE2eITCase.java | 2 +-
.../tests/utils/PipelineTestEnvironment.java | 2 +-
.../tests/utils/FlinkContainerTestEnvironment.java | 2 +-
.../pom.xml | 52 +-
.../org/apache/flink/api/connector/sink2/Sink.java | 72 +++
.../connector/sink2/TwoPhaseCommittingSink.java | 7 +-
.../apache/flink/core/execution/RestoreMode.java | 54 ++
.../runtime/jobgraph/SavepointConfigOptions.java | 56 ++
.../connector/sink2/WithPostCommitTopology.java | 6 +-
.../api/connector/sink2/WithPreCommitTopology.java | 22 +-
.../api/connector/sink2/WithPreWriteTopology.java | 17 +-
.../streaming/api/functions/sink/SinkFunction.java | 22 +-
.../source/RichParallelSourceFunction.java | 42 +-
.../api/functions/source/SourceFunction.java | 22 +-
.../flink/table/api}/ValidationException.java | 11 +-
flink-cdc-runtime/pom.xml | 32 +-
pom.xml | 1 +
58 files changed, 809 insertions(+), 1421 deletions(-)
delete mode 100644
flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/testsource/source/DistributedSource.java
create mode 100644
flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/testsource/source/DistributedSourceFunction.java
delete mode 100644
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values-2.x/pom.xml
delete mode 100644
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values-2.x/src/main/java/org/apache/flink/cdc/connectors/values/sink/ValuesDataSink.java
delete mode 100644
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values-2.x/src/main/resources/META-INF/services/org.apache.flink.cdc.common.factories.Factory
create mode 100644
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/sink/ValuesDataSinkFunction.java
copy {flink-cdc-pipeline-model => flink-cdc-flink2.2-compat}/pom.xml (61%)
create mode 100644
flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/api/connector/sink2/Sink.java
copy
flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/DummyDocs.java
=>
flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/api/connector/sink2/TwoPhaseCommittingSink.java
(75%)
create mode 100644
flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/core/execution/RestoreMode.java
create mode 100644
flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/runtime/jobgraph/SavepointConfigOptions.java
copy
flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/DummyDocs.java
=>
flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/connector/sink2/WithPostCommitTopology.java
(75%)
copy
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupMode.java
=>
flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/connector/sink2/WithPreCommitTopology.java
(75%)
copy
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/function/HashFunction.java
=>
flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/connector/sink2/WithPreWriteTopology.java
(71%)
copy
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupMode.java
=>
flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java
(74%)
copy
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/VitessValidator.java
=>
flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/functions/source/RichParallelSourceFunction.java
(51%)
copy
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupMode.java
=>
flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
(73%)
rename {flink-cdc-common/src/main/java/org/apache/flink/cdc/common/exceptions
=>
flink-cdc-flink2.2-compat/src/main/java/org/apache/flink/table/api}/ValidationException.java
(72%)
