Skip to content

Commit 1be6d2d

Browse files
committed
add log to find problem
1 parent 67c00fe commit 1be6d2d

File tree

2 files changed

+6
-0
lines changed

2 files changed

+6
-0
lines changed

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/test/java/com/ververica/cdc/connectors/oracle/source/OracleSourceITCase.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -159,6 +159,9 @@ public void testEnableBackfillWithPreHighWaterMark() throws Exception {
159159
"+I[15213, user_15213, Shanghai, 123567891234]");
160160
// when enable backfill, the wal log between [snapshot_point, high_watermark) will be
161161
// applied as snapshot image
162+
StringBuilder stringBuilder = new StringBuilder();
163+
records.stream().forEach(item -> stringBuilder.append(item));
164+
log.info(stringBuilder.toString());
162165
assertEqualsInAnyOrder(expectedRecords, records);
163166
}
164167

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/com/ververica/cdc/connectors/sqlserver/source/SqlServerSourceITCase.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -150,6 +150,9 @@ public void testEnableBackfillWithPreHighWaterMark() throws Exception {
150150
"+I[15213, user_15213, Shanghai, 123567891234]");
151151
// when enable backfill, the wal log between [snapshot_point, high_watermark) will be
152152
// applied as snapshot image
153+
StringBuilder stringBuilder = new StringBuilder();
154+
records.stream().forEach(item -> stringBuilder.append(item));
155+
log.info(stringBuilder.toString());
153156
assertEqualsInAnyOrder(expectedRecords, records);
154157
}
155158

0 commit comments

Comments
 (0)