[Improve][CDC] adjust code style

apache · Jul 11, 2023 · 45f8505 · 45f8505
1 parent d65d52b
commit 45f8505
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/.../seatunnel/connectors/cdc/base/source/reader/external/IncrementalSourceStreamFetcher.java b/.../seatunnel/connectors/cdc/base/source/reader/external/IncrementalSourceStreamFetcher.java
@@ -174,8 +174,8 @@ private boolean shouldEmit(SourceRecord sourceRecord) {
             if (hasEnterPureBinlogPhase(tableId, position)) {
                 return true;
             }
-            // not enter pure binlog mode and need to check whether the current record meets the emitting
-            // conditions.
+            // not enter pure binlog mode and need to check whether the current record meets the
+            // emitting conditions.
             if (finishedSplitsInfo.containsKey(tableId)) {
                 for (CompletedSnapshotSplitInfo splitInfo : finishedSplitsInfo.get(tableId)) {
                     if (taskContext.isRecordBetween(