Remove irrelevant code

aiwenmo · aiwenmo · commit 8c73d29c9542 · 2025-02-10T22:48:00.000+08:00
diff --git a/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineTransformITCase.java b/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineTransformITCase.java
@@ -951,7 +951,7 @@ void testTransformWithTemporalFunction() throws Exception {
         execution.execute();
 
         // Check the order and content of all received events
-        String[] outputEvents = outCaptor.toString().replace("\r\n", "\n").trim().split("\n");
+        String[] outputEvents = outCaptor.toString().trim().split("\n");
 
         Arrays.stream(outputEvents).forEach(this::extractDataLines);
     }

Original file line number	Diff line number	Diff line change
`@@ -951,7 +951,7 @@ void testTransformWithTemporalFunction() throws Exception {`
`951`	`951`	`execution.execute();`
`952`	`952`
`953`	`953`	`// Check the order and content of all received events`
`954`		`- String[] outputEvents = outCaptor.toString().replace("\r\n", "\n").trim().split("\n");`
	`954`	`+ String[] outputEvents = outCaptor.toString().trim().split("\n");`
`955`	`955`
`956`	`956`	`Arrays.stream(outputEvents).forEach(this::extractDataLines);`
`957`	`957`	`}`