Pipe: degrade progress index rebind log (#13821)

apache · Oct 18, 2024 · 2b8d6c6 · 2b8d6c6
1 parent 82a77b6
commit 2b8d6c6
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/...g/apache/iotdb/db/pipe/extractor/dataregion/realtime/assigner/PipeDataRegionAssigner.java b/...g/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()));