diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/realtime/assigner/PipeDataRegionAssigner.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/realtime/assigner/PipeDataRegionAssigner.java
index 9cfdc249df11..1b6ec932eea4 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/realtime/assigner/PipeDataRegionAssigner.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/realtime/assigner/PipeDataRegionAssigner.java
@@ -165,11 +165,13 @@ private void bindOrUpdateProgressIndexForTsFileInsertionEvent(
         .isProgressIndexAfterOrEquals(
             dataRegionId, event.getTimePartitionId(), event.getProgressIndex())) {
       event.bindProgressIndex(maxProgressIndexForTsFileInsertionEvent.get());
-      LOGGER.info(
-          "Data region {} bind {} to event {} because it was flushed prematurely.",
-          dataRegionId,
-          maxProgressIndexForTsFileInsertionEvent,
-          event.coreReportMessage());
+      if (LOGGER.isDebugEnabled()) {
+        LOGGER.debug(
+            "Data region {} bind {} to event {} because it was flushed prematurely.",
+            dataRegionId,
+            maxProgressIndexForTsFileInsertionEvent,
+            event.coreReportMessage());
+      }
     } else {
       maxProgressIndexForTsFileInsertionEvent.updateAndGet(
           index -> index.updateToMinimumEqualOrIsAfterProgressIndex(event.getProgressIndex()));