From 768273e8266df193031dbae3ec518a5b34f50ba9 Mon Sep 17 00:00:00 2001
From: wenmo <32723967+aiwenmo@users.noreply.github.com>
Date: Wed, 22 Jan 2025 20:24:39 +0800
Subject: [PATCH] Remove irrelevant code

---
 .../flink/cdc/composer/flink/FlinkPipelineTransformITCase.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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
index c2641fc1d89..7df5a2673c2 100644
--- 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);
     }