update

JNSimba · Sep 9, 2024 · a1c84f8 · a1c84f8
1 parent 9c05ed5
commit a1c84f8
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 1 deletion.
diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/source/DorisSource.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/source/DorisSource.java
@@ -125,6 +125,7 @@ public SplitEnumerator<DorisSourceSplit, PendingSplitsCheckpoint> restoreEnumera
             SplitEnumeratorContext<DorisSourceSplit> context, PendingSplitsCheckpoint checkpoint)
             throws Exception {
         Collection<DorisSourceSplit> splits = checkpoint.getSplits();
+        LOG.info("Restore {} splits from checkpoint, detail {}", splits.size(), splits);
         DorisSplitAssigner splitAssigner = new SimpleSplitAssigner(splits);
         return new DorisSourceEnumerator(context, splitAssigner);
     }

diff --git a/...-connector/src/main/java/org/apache/doris/flink/source/assigners/SimpleSplitAssigner.java b/...-connector/src/main/java/org/apache/doris/flink/source/assigners/SimpleSplitAssigner.java
@@ -52,6 +52,7 @@ public void addSplits(Collection<DorisSourceSplit> splits) {
 
     @Override
     public PendingSplitsCheckpoint snapshotState(long checkpointId) {
+        LOG.info("Checkpointing {} splits: {}", checkpointId, splits);
         return new PendingSplitsCheckpoint(splits);
     }
 

diff --git a/...nnector/src/main/java/org/apache/doris/flink/source/enumerator/DorisSourceEnumerator.java b/...nnector/src/main/java/org/apache/doris/flink/source/enumerator/DorisSourceEnumerator.java
@@ -85,7 +85,7 @@ public void addSplitsBack(List<DorisSourceSplit> splits, int subtaskId) {
 
     @Override
     public void addReader(int subtaskId) {
-        // do nothing
+        LOG.info("Doris Source Enumerator adds reader: {}", subtaskId);
     }
 
     @Override