Update flink/v1.18/flink/src/main/java/org/apache/iceberg/flink/sourc…

…e/reader/IcebergSourceSplitReader.java Co-authored-by: Mason Chen <[email protected]>
apache · Dec 18, 2023 · 191f860 · 191f860
1 parent bd8d436
commit 191f860
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceSplitReader.java b/.../flink/src/main/java/org/apache/iceberg/flink/source/reader/IcebergSourceSplitReader.java
@@ -98,7 +98,7 @@ public RecordsWithSplitIds<RecordAndPosition<T>> fetch() throws IOException {
             LOG.info("Reader {} paused reading split {}", indexOfSubtask, currentSplitId);
             first = false;
           } else {
-            LOG.trace("Reader {} is Still paused reading split {}", indexOfSubtask, currentSplitId);
+            LOG.trace("Reader {} is still paused reading split {}", indexOfSubtask, currentSplitId);
           }
 
           synchronized (wakeUp) {