This is an automated email from the ASF dual-hosted git repository. leonardBang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
commit 7cf519b8cbf92600539612a7c301875ac545d9fc Author: Leonard Xu <[email protected]> AuthorDate: Wed Jul 1 14:57:48 2026 +0800 [test][pipeline-e2e] Stabilize RouteE2eITCase batch wait --- .../java/org/apache/flink/cdc/pipeline/tests/RouteE2eITCase.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/RouteE2eITCase.java b/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/RouteE2eITCase.java index 792cafbda..49ef42c4e 100644 --- a/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/RouteE2eITCase.java +++ b/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/RouteE2eITCase.java @@ -40,7 +40,7 @@ import java.util.stream.IntStream; class RouteE2eITCase extends PipelineTestEnvironment { private static final Logger LOG = LoggerFactory.getLogger(RouteE2eITCase.class); - protected static final int TEST_TABLE_NUMBER = 100; + protected static final int TEST_TABLE_NUMBER = 60; protected final UniqueDatabase routeTestDatabase = new UniqueDatabase(MYSQL, "route_test", MYSQL_TEST_USER, MYSQL_TEST_PASSWORD); @@ -1155,6 +1155,9 @@ class RouteE2eITCase extends PipelineTestEnvironment { parallelism); submitPipelineJob(pipelineJob); waitUntilJobRunning(Duration.ofSeconds(30)); + if (batchMode) { + waitUntilJobFinished(Duration.ofMinutes(10)); + } String prefix = parallelism > 1 ? "> " : ""; validateResult(
