Skip to content

Commit 086536b

Browse files
authored
[hotfix][e2e] Temporarily disable TransformE2eITCase in multiple parallelism
This closes apache#3718
1 parent 3025d91 commit 086536b

File tree

2 files changed

+6
-3
lines changed

2 files changed

+6
-3
lines changed

flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/TransformE2eITCase.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1102,8 +1102,9 @@ private void waitForTemporaryRecords(int expectedRecords, long timeout) throws E
11021102

11031103
boolean extractDataLines(String line) {
11041104
// In multiple parallelism mode, a prefix with subTaskId (like '1> ') will be appended.
1105-
// Should trim it before extracting data fields.
1106-
if (!line.startsWith("DataChangeEvent{", 3)) {
1105+
// Should trim it before extracting data fields by calling startsWith(..., 3).
1106+
// Single-parallelism version does not have this prefix.
1107+
if (!line.startsWith("DataChangeEvent{")) {
11071108
return false;
11081109
}
11091110
Stream.of("before", "after")

flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,9 @@ public abstract class PipelineTestEnvironment extends TestLogger {
6767

6868
@Parameterized.Parameter public String flinkVersion;
6969

70-
public Integer parallelism = 4;
70+
// TODO: E2e cases with multiple parallelism has been temporarily disabled until we close
71+
// FLINK-36690.
72+
public Integer parallelism = 1;
7173

7274
// ------------------------------------------------------------------------------------------
7375
// Flink Variables

0 commit comments

Comments
 (0)