You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2024/10/18 09:19:06 UTC
(iotdb) branch master updated: Pipe: degrade progress index rebind log (#13821)
This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 2b8d6c6eb70 Pipe: degrade progress index rebind log (#13821)
2b8d6c6eb70 is described below
commit 2b8d6c6eb7069d36b6364f8906a0ee39a4ea4103
Author: V_Galaxy <vg...@apache.org>
AuthorDate: Fri Oct 18 17:19:00 2024 +0800
Pipe: degrade progress index rebind log (#13821)
---
.../dataregion/realtime/assigner/PipeDataRegionAssigner.java | 12 +++++++-----
1 file changed, 7 insertions(+), 5 deletions(-)
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 9cfdc249df1..1b6ec932eea 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 @@ public class PipeDataRegionAssigner implements Closeable {
.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()));