diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/test/java/com/ververica/cdc/connectors/oracle/source/OracleSourceITCase.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/test/java/com/ververica/cdc/connectors/oracle/source/OracleSourceITCase.java index ca3d6d0b228..257082bd3b2 100644 --- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/test/java/com/ververica/cdc/connectors/oracle/source/OracleSourceITCase.java +++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/test/java/com/ververica/cdc/connectors/oracle/source/OracleSourceITCase.java @@ -159,6 +159,9 @@ public void testEnableBackfillWithPreHighWaterMark() throws Exception { "+I[15213, user_15213, Shanghai, 123567891234]"); // when enable backfill, the wal log between [snapshot_point, high_watermark) will be // applied as snapshot image + StringBuilder stringBuilder = new StringBuilder(); + records.stream().forEach(item -> stringBuilder.append(item)); + log.info(stringBuilder.toString()); assertEqualsInAnyOrder(expectedRecords, records); } diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/com/ververica/cdc/connectors/sqlserver/source/SqlServerSourceITCase.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/com/ververica/cdc/connectors/sqlserver/source/SqlServerSourceITCase.java index 5dcf104ada5..c287aab591a 100644 --- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/com/ververica/cdc/connectors/sqlserver/source/SqlServerSourceITCase.java +++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/com/ververica/cdc/connectors/sqlserver/source/SqlServerSourceITCase.java @@ -150,6 +150,9 @@ public void testEnableBackfillWithPreHighWaterMark() throws Exception { "+I[15213, user_15213, Shanghai, 123567891234]"); // when enable backfill, the wal log between [snapshot_point, high_watermark) will be // applied as snapshot image + StringBuilder stringBuilder = new StringBuilder(); + records.stream().forEach(item -> stringBuilder.append(item)); + log.info(stringBuilder.toString()); assertEqualsInAnyOrder(expectedRecords, records); }