This is an automated email from the ASF dual-hosted git repository.
leonardBang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
from 6914d7028 [FLINK-39916][mysql] Fix MySQL batch startup option
validation error (#4441)
new b8edfcfd3 [fix][mysql-source] Compare varbinary split keys by byte
value
new d20dbc104 [test][ci] Keep E2E timezone selection on hour boundaries
new dfba99c81 [test][connector/mysql] Stabilize NewlyAddedTableITCase
failover waits
new 19a9b6449 [test][connector/mysql] Stabilize MySqlConnectorITCase waits
new 3427027b4 [test][connector/postgres] Stabilize NewlyAddedTableITCase
failover waits
new df11e13c7 [test][connector/postgres] Stabilize
PostgresSourceReaderTest schema polling
new b294f92da [test][pipeline-postgres] Avoid canceling stopped savepoint
jobs
new 4c266632e [test][connector/sqlserver] Stabilize full types and
timezone waits
new 8a6bbd823 [test][connector/mongodb] Tolerate newly-added table replay
pair
new 6b7b3b174 [test][source-e2e][mongodb] Wait for MongoE2eITCase snapshot
before changes
new 78baa80af [test][connector/oceanbase] Stabilize failover and startup
waits
new 03c499a84 [test][connector/tidb] Retry TiDB JDBC startup connections
new 931dc38ba [test][pipeline-e2e] Add shared wait and checkpoint helpers
new 35f27ee55 [test][pipeline-e2e] Stabilize MySqlToHudiE2eITCase
visibility waits
new 6ef2e23be [test][pipeline-e2e] Stabilize MySqlToIcebergE2eITCase
commits
new a65fcedb4 [test][pipeline-e2e] Wait for MysqlToKafkaE2eITCase stream
handoff
new 7f90244ac [test][pipeline-e2e] Stabilize SqlServerE2eITCase split
handoff
new ed7cb46e1 [test][pipeline-e2e] Stabilize TransformE2eITCase handoff
waits
new b88ef14c8 [test][pipeline-e2e] Stabilize UdfE2eITCase event waits
new 7cf519b8c [test][pipeline-e2e] Stabilize RouteE2eITCase batch wait
new 273616943 [test][pipeline-e2e] Stabilize Hudi schema evolution waits
new 1357fe105 [test] Keep stabilization changes semantically strict
new c32c65154 [test][pipeline-e2e] Skip checkpointing non-streaming
Iceberg job
new accee6552 [test][pipeline-e2e] Share stream split readiness wait
The 24 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:
.github/workflows/utils.sh | 9 +-
.../postgres/source/PostgresPipelineITCase.java | 3 +-
.../mongodb/source/NewlyAddedTableITCase.java | 42 +-
.../connectors/mysql/source/utils/ObjectUtils.java | 4 +
.../mysql/source/NewlyAddedTableITCase.java | 84 ++-
.../mysql/source/utils/ObjectUtilsTest.java | 18 +
.../mysql/table/MySqlConnectorITCase.java | 124 ++++-
.../oceanbase/OceanBaseFailoverITCase.java | 174 +++++-
.../oceanbase/OceanBaseSourceTestBase.java | 5 +
.../connectors/oceanbase/OceanBaseTestUtils.java | 20 +-
.../oceanbase/testutils/OceanBaseContainer.java | 6 +-
.../cdc/connectors/postgres/PostgresTestBase.java | 6 +-
.../postgres/source/NewlyAddedTableITCase.java | 31 +-
.../source/reader/PostgresSourceReaderTest.java | 73 ++-
.../connectors/sqlserver/SqlServerTestBase.java | 26 +-
.../sqlserver/table/SqlServerConnectorITCase.java | 33 +-
.../sqlserver/table/SqlServerTimezoneITCase.java | 25 +-
.../flink/cdc/connectors/tidb/TiDBTestBase.java | 18 +-
.../cdc/pipeline/tests/MySqlToHudiE2eITCase.java | 604 ++++++++++++++-------
.../pipeline/tests/MySqlToIcebergE2eITCase.java | 30 +-
.../cdc/pipeline/tests/MysqlToKafkaE2eITCase.java | 10 +-
.../flink/cdc/pipeline/tests/RouteE2eITCase.java | 5 +-
.../cdc/pipeline/tests/SqlServerE2eITCase.java | 39 +-
.../cdc/pipeline/tests/TransformE2eITCase.java | 136 ++++-
.../flink/cdc/pipeline/tests/UdfE2eITCase.java | 56 +-
.../tests/utils/PipelineTestEnvironment.java | 130 ++++-
.../src/test/resources/docker/peek-hudi.sql | 1 +
.../flink/cdc/connectors/tests/MongoE2eITCase.java | 33 +-
28 files changed, 1323 insertions(+), 422 deletions(-)
