This is an automated email from the ASF dual-hosted git repository.
leonard pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
from 414720d1c [FLINK-35464][cdc] Fixes operator state backwards
compatibility from CDC 3.0.x and add migration tests (#3369)
new 9a9603413 [FLINK-35415][base] Fix compatibility with Flink 1.19
new fe1ceb9ff [FLINK-35415][base] Bump Flink patch version to 1.18.1
new d8a9c8c63 [FLINK-35316][base] Run E2e test cases with Flink 1.19 and
latest patch versions
new 8eb7e5396 [FLINK-35120][doris] Add Doris integration test cases
new 1a360635c [FLINK-35092][cdc][starrocks] Add starrocks integration test
cases
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink/translator/DataSinkTranslator.java | 45 ++-
.../flink-cdc-pipeline-connector-doris/pom.xml | 43 ++
.../doris/sink/DorisMetadataApplierITCase.java | 441 +++++++++++++++++++++
.../connectors/doris/sink/DorisPipelineITCase.java | 210 ++++++++++
.../doris/sink/utils/DorisContainer.java | 146 +++++++
.../doris/sink/utils/DorisSinkTestBase.java | 319 +++++++++++++++
.../src/test/resources/log4j2-test.properties | 0
.../flink-cdc-pipeline-connector-starrocks/pom.xml | 18 +
.../org/apache/commons/compress/utils/Lists.java} | 15 +-
.../sink/StarRocksMetadataApplierITCase.java | 388 ++++++++++++++++++
.../starrocks/sink/StarRocksPipelineITCase.java | 178 +++++++++
.../starrocks/sink/utils/StarRocksContainer.java | 113 ++++++
.../sink/utils/StarRocksSinkTestBase.java | 252 ++++++++++++
.../flink-cdc-pipeline-e2e-tests/pom.xml | 7 +-
.../cdc/pipeline/tests/MySqlToDorisE2eITCase.java | 384 ++++++++++++++++++
.../flink/cdc/pipeline/tests/MysqlE2eITCase.java | 24 +-
.../cdc/pipeline/tests/TransformE2eITCase.java | 10 +-
.../tests/utils/PipelineTestEnvironment.java | 55 ++-
.../flink-cdc-source-e2e-tests/pom.xml | 38 +-
.../tests/utils/FlinkContainerTestEnvironment.java | 56 ++-
pom.xml | 2 +-
21 files changed, 2661 insertions(+), 83 deletions(-)
create mode 100644
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplierITCase.java
create mode 100644
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/DorisPipelineITCase.java
create mode 100644
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/utils/DorisContainer.java
create mode 100644
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/utils/DorisSinkTestBase.java
copy {flink-cdc-composer =>
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris}/src/test/resources/log4j2-test.properties
(100%)
copy
flink-cdc-connect/{flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/task/context/exception/SchemaOutOfSyncException.java
=>
flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/com/starrocks/shade/org/apache/commons/compress/utils/Lists.java}
(66%)
create mode 100644
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplierITCase.java
create mode 100644
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksPipelineITCase.java
create mode 100644
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/utils/StarRocksContainer.java
create mode 100644
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/utils/StarRocksSinkTestBase.java
create mode 100644
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MySqlToDorisE2eITCase.java
