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
index 2b1b31671..1b05453ad 100644
--- 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,7 +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);
+        LOG.info("Restore splits from checkpoint, size {}, splits {}", splits.size(), splits);
         DorisSplitAssigner splitAssigner = new SimpleSplitAssigner(splits);
         return new DorisSourceEnumerator(context, splitAssigner);
     }
diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/source/assigners/SimpleSplitAssigner.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/source/assigners/SimpleSplitAssigner.java
index 3409f6038..7948244ca 100644
--- a/flink-doris-connector/src/main/java/org/apache/doris/flink/source/assigners/SimpleSplitAssigner.java
+++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/source/assigners/SimpleSplitAssigner.java
@@ -52,7 +52,7 @@ public void addSplits(Collection<DorisSourceSplit> splits) {
 
     @Override
     public PendingSplitsCheckpoint snapshotState(long checkpointId) {
-        LOG.info("Checkpointing splits: {}, id {}", splits, checkpointId);
+        LOG.info("Snapshot splits {} for checkpoint {}", splits, checkpointId);
         return new PendingSplitsCheckpoint(splits);
     }
 
diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator/DorisSourceEnumerator.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator/DorisSourceEnumerator.java
index e0600787b..be93f39dc 100644
--- a/flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator/DorisSourceEnumerator.java
+++ b/flink-doris-connector/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) {
-        LOG.info("Doris Source Enumerator adds reader: {}", subtaskId);
+        LOG.info("add reader: {}", subtaskId);
     }
 
     @Override
diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceReader.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceReader.java
index 287f51370..dce23ee20 100644
--- a/flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceReader.java
+++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceReader.java
@@ -68,7 +68,7 @@ protected void onSplitFinished(Map<String, DorisSourceSplitState> finishedSplitI
 
     @Override
     protected DorisSourceSplitState initializedState(DorisSourceSplit split) {
-        LOG.info("Initialized state for split: {}", split);
+        LOG.info("Initialized reader state for split: {}", split);
         return new DorisSourceSplitState(split);
     }
 
diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceSplitReader.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceSplitReader.java
index a0337b9f5..39187f87c 100644
--- a/flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceSplitReader.java
+++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceSplitReader.java
@@ -89,11 +89,9 @@ private DorisSplitRecords finishSplit() {
             }
             valueReader = null;
         }
-        LOG.info("Finished split {}", currentSplitId);
 
         final DorisSplitRecords finishRecords = DorisSplitRecords.finishedSplit(currentSplitId);
         currentSplitId = null;
-        LOG.info("After Finished split {}, {} ", currentSplitId, finishRecords.finishedSplits());
         return finishRecords;
     }