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
omit 2d09d68c0 Address comment.
omit 41172a30f Remove flink-cdc-pipeline-e2e-tests-2.x module.
omit 714021db1 Rename module to avoid using minor version.
omit c4247b266 Update java doc.
omit 1bfa51294 Add flink-cdc-flink1.20-compat module.
omit e5e8b48be Fix compile.
omit 16c483c5a Add flink-cdc-flink2.2-compat module.
omit a3adc9d3f Add flink-cdc-flink2.2-compat module.
omit b0764446c Fix CI failure.
omit 112bc35ac Fix CI failure.
omit 1d48d77d0 Address comments.
omit b03ff0ce4 Add support for Flink 2.x.
add c003b9352 [FLINK-39152][pipeline-connector][Fluss]Fix FlussConfig
Utils class is not in the correct directory and should have a private instance
(#4306)
add dc5e92341 [FLINK-38160][starrocks] Add support for BINARY and
VARBINARY types in StarRocks connector (#4303)
add 88b120324 [DOC][MINOR] Update starrocks.md (#4304)
add 0ae9abda1 [FLINK-37292] [cdc] Remove the flink-kubernetes dependencies
during the packaging of flink-cdc-dist (#4024)
add 37783004a [minor][docs][style] Update documentation link and improve
code style (#3961)
add 570faa7a0 [FLINK-38247][MySQL] Handle BIGINT UNSIGNED overflow
correctly in PreparedStatement. (#4117)
add 91ae6776e [FLINK-39055][Iceberg] Support default column values in
Iceberg sink connector (#4277)
add 363095e07 [FLINK-38244][hotfix] Fix the full snapshot phase, the field
case is adjusted based on isTableIdCaseInsensitive (#4284)
add 3580bf414 [FLINK-38844][pipeline-connector][postgres]Add metadata
column support (#4202)
add 368a8079b [FLINK-39231][test][sqlserver] Fix unstable sqlserver
connector test (#4309)
add db595e405 [hotfix] Fix spotless check failure (#4313)
new 7c28071ea Add support for Flink 2.x.
new 5b763bd0b Address comments.
new 557cd42c5 Fix CI failure.
new bbdba2707 Fix CI failure.
new 0ddbfb4fa Add flink-cdc-flink2.2-compat module.
new 60acff8c0 Add flink-cdc-flink2.2-compat module.
new 0faf78079 Fix compile.
new cbeecde33 Add flink-cdc-flink1.20-compat module.
new 10e3747d8 Update java doc.
new f102d04dc Rename module to avoid using minor version.
new 45948829e Remove flink-cdc-pipeline-e2e-tests-2.x module.
new 3240e50fa Address comment.
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (2d09d68c0)
\
N -- N -- N refs/heads/FLINK-38729-2 (3240e50fa)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 12 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:
.../connectors/pipeline-connectors/postgres.md | 76 +++++-
.../connectors/pipeline-connectors/starrocks.md | 17 +-
.../connectors/pipeline-connectors/postgres.md | 76 +++++-
.../connectors/pipeline-connectors/starrocks.md | 17 +-
flink-cdc-composer/pom.xml | 1 +
.../sink/ElasticsearchDataSinkFactory.java | 2 +-
.../fluss/factory/FlussDataSinkFactory.java | 4 +-
.../fluss/{sink => utils}/FlussConfigUtils.java | 4 +-
.../iceberg/sink/IcebergMetadataApplier.java | 56 +++-
.../iceberg/sink/utils/IcebergTypeUtils.java | 67 +++++
.../iceberg/sink/IcebergMetadataApplierTest.java | 290 +++++++++++++++++++++
.../iceberg/sink/utils/IcebergTypeUtilsTest.java | 139 ++++++++++
.../connectors/mysql/source/MySqlDataSource.java | 9 +-
.../mysql/source/MySqlEventDeserializer.java | 5 +-
.../source/reader/MySqlPipelineRecordEmitter.java | 18 +-
.../mysql/source/MySqlDataSourceFactoryTest.java | 3 +-
.../mysql/source/MySqlPipelineITCase.java | 8 +-
.../source/MySqlTableIdCaseInsensitveITCase.java | 91 +++++--
.../src/test/resources/ddl/inventory.sql | 22 +-
.../source/DatabaseNameMetadataColumn.java} | 17 +-
.../postgres}/source/OpTsMetadataColumn.java | 2 +-
.../postgres/source/PostgresDataSource.java | 18 ++
.../postgres/source/SchemaNameMetadataColumn.java} | 17 +-
.../postgres/source/TableNameMetadataColumn.java} | 16 +-
.../factory/PostgresDataSourceFactoryTest.java | 32 +++
.../postgres/source/PostgresFullTypesITCase.java | 106 ++++++++
.../starrocks/sink/StarRocksDataSinkOptions.java | 4 +-
.../connectors/starrocks/sink/StarRocksUtils.java | 26 ++
.../starrocks/sink/CdcDataTypeTransformerTest.java | 37 +++
.../sink/EventRecordSerializationSchemaTest.java | 74 ++++++
.../sink/StarRocksMetadataApplierITCase.java | 13 +-
.../starrocks/sink/StarRocksUtilsTest.java | 74 +++++-
.../mysql/source/utils/StatementUtils.java | 36 ++-
.../connectors/mysql/source/MySqlSourceITCase.java | 94 +++++++
.../mysql/source/utils/StatementUtilsTest.java | 113 ++++++++
.../sqlserver/table/SqlServerConnectorITCase.java | 26 +-
36 files changed, 1492 insertions(+), 118 deletions(-)
rename
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/{sink
=> utils}/FlussConfigUtils.java (97%)
create mode 100644
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/test/java/org/apache/flink/cdc/connectors/iceberg/sink/utils/IcebergTypeUtilsTest.java
copy
flink-cdc-connect/flink-cdc-pipeline-connectors/{flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/source/OpTsMetadataColumn.java
=>
flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/source/DatabaseNameMetadataColumn.java}
(73%)
copy
flink-cdc-connect/flink-cdc-pipeline-connectors/{flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql
=>
flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres}/source/OpTsMetadataColumn.java
(96%)
copy
flink-cdc-connect/flink-cdc-pipeline-connectors/{flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/source/OpTsMetadataColumn.java
=>
flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/source/SchemaNameMetadataColumn.java}
(73%)
copy
flink-cdc-connect/flink-cdc-pipeline-connectors/{flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/OpTsMetadataColumn.java
=>
flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/source/TableNameMetadataColumn.java}
(74%)
create mode 100644
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/utils/StatementUtilsTest.java
