[hotfix] change FileSourceSplit to JdbcSourceSplit

apache · Oct 14, 2024 · 3b24566 · 3b24566
1 parent 1fcb9dd
commit 3b24566
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...va/org/apache/flink/connector/jdbc/core/datastream/source/split/JdbcSourceSplitState.java b/...va/org/apache/flink/connector/jdbc/core/datastream/source/split/JdbcSourceSplitState.java
@@ -79,7 +79,7 @@ public void setPosition(CheckpointedOffset offset) {
         this.recordsToSkipAfterOffset = offset.getRecordsAfterOffset();
     }
 
-    /** Use the current row count as the starting row count to create a new FileSourceSplit. */
+    /** Use the current row count as the starting row count to create a new JdbcSourceSplit. */
     @SuppressWarnings("unchecked")
     public SplitT toJdbcSourceSplit() {
         final CheckpointedOffset position =