QuakeWang opened a new pull request, #8362:
URL: https://github.com/apache/paimon/pull/8362
### Purpose
`MySqlSyncDatabaseActionITCase#testNewlyAddedTableMultipleTables` could time
out because it used Flink `RUNNING` as the only readiness signal. `RUNNING`
does not guarantee that the MySQL CDC source has finished snapshot setup or
reached incremental consumption, so records written too early can leave the
test waiting until the JUnit timeout.
This PR makes the test use deterministic snapshot input, verifies an
existing-table incremental record before creating runtime-added tables, and
waits for the first newly added Paimon table before inserting records into it.
CDC test waits now also fail fast if the Flink job reaches a terminal state.
### Tests
- `mvn -pl paimon-flink/paimon-flink-cdc -am -DskipTests compile`
- `mvn -pl paimon-flink/paimon-flink-cdc -am -Pfast-build,flink1
-DfailIfNoTests=false
-Dtest=org.apache.paimon.flink.action.cdc.mysql.MySqlSyncDatabaseActionITCase#testNewlyAddedTableMultipleTables
test`
- `mvn -pl paimon-flink/paimon-flink-cdc -am -Pfast-build,flink1
-DfailIfNoTests=false
-Dtest=org.apache.paimon.flink.action.cdc.mysql.MySqlSyncTableActionITCase#testRuntimeExecutionModeCheckForCdcSync
test`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
