This is an automated email from the ASF dual-hosted git repository.
yuxiqian pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new a16a09ed5 [hotfix] Fix pipeline e2e CI compilation failure (#4547)
a16a09ed5 is described below
commit a16a09ed52289a6153f794203cd4770dc74e7e37
Author: yuxiqian <[email protected]>
AuthorDate: Thu Sep 17 13:36:18 2026 +0800
[hotfix] Fix pipeline e2e CI compilation failure (#4547)
---
.../tests/{ => stage2}/SchemaCoordinatorRecoveryE2eITCase.java | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
diff --git
a/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/SchemaCoordinatorRecoveryE2eITCase.java
b/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/stage2/SchemaCoordinatorRecoveryE2eITCase.java
similarity index 98%
rename from
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/SchemaCoordinatorRecoveryE2eITCase.java
rename to
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/stage2/SchemaCoordinatorRecoveryE2eITCase.java
index d70f85386..f0d53255e 100644
---
a/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/SchemaCoordinatorRecoveryE2eITCase.java
+++
b/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/stage2/SchemaCoordinatorRecoveryE2eITCase.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.flink.cdc.pipeline.tests;
+package org.apache.flink.cdc.pipeline.tests.stage2;
import org.apache.flink.api.common.JobID;
import org.apache.flink.api.common.JobStatus;
@@ -24,6 +24,7 @@ import
org.apache.flink.cdc.pipeline.tests.utils.PipelineTestEnvironment;
import org.assertj.core.api.Assertions;
import org.junit.jupiter.api.io.TempDir;
+import org.junit.jupiter.params.ParameterizedClass;
import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.ValueSource;
import org.testcontainers.containers.Container.ExecResult;
@@ -45,8 +46,14 @@ import java.util.jar.JarOutputStream;
import java.util.stream.Collectors;
/** End-to-end recovery coverage for regular and distributed schema
coordinators. */
+@ParameterizedClass
+@ValueSource(ints = {1, 4})
class SchemaCoordinatorRecoveryE2eITCase extends PipelineTestEnvironment {
+ SchemaCoordinatorRecoveryE2eITCase(int parallelism) {
+ super(parallelism);
+ }
+
private static final Duration JOB_TIMEOUT = Duration.ofMinutes(2);
@TempDir Path tempDir;
