|
|
@ -1102,8 +1102,9 @@ public class TransformE2eITCase extends PipelineTestEnvironment {
|
|
|
|
|
|
|
|
|
|
|
|
boolean extractDataLines(String line) {
|
|
|
|
boolean extractDataLines(String line) {
|
|
|
|
// In multiple parallelism mode, a prefix with subTaskId (like '1> ') will be appended.
|
|
|
|
// In multiple parallelism mode, a prefix with subTaskId (like '1> ') will be appended.
|
|
|
|
// Should trim it before extracting data fields.
|
|
|
|
// Should trim it before extracting data fields by calling startsWith(..., 3).
|
|
|
|
if (!line.startsWith("DataChangeEvent{", 3)) {
|
|
|
|
// Single-parallelism version does not have this prefix.
|
|
|
|
|
|
|
|
if (!line.startsWith("DataChangeEvent{")) {
|
|
|
|
return false;
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
Stream.of("before", "after")
|
|
|
|
Stream.of("before", "after")
|
|
|
|