diff --git a/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/polardbx/PolardbxSourceTCase.java b/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/polardbx/PolardbxSourceTCase.java index e170fb348..68073f3b8 100644 --- a/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/polardbx/PolardbxSourceTCase.java +++ b/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/polardbx/PolardbxSourceTCase.java @@ -356,7 +356,6 @@ public class PolardbxSourceTCase extends AbstractTestBase { TableResult tableResult = tEnv.executeSql("select * from polardbx_full_types"); CloseableIterator iterator = tableResult.collect(); List realSnapshotData = fetchRows(iterator, 1); - realSnapshotData.forEach(System.out::println); String[] expectedSnapshotData = new String[] { "+I[100001, 127, 255, 32767, 65535, 8388607, 16777215, 2147483647, 4294967295, 2147483647, "