(iotdb) branch master updated: Pipe: Reduce warn log when PipeConfigRegionExtractorMetrics does not exist (#12673)

[rong]

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 0073a3d3bf2 Pipe: Reduce warn log when 
PipeConfigRegionExtractorMetrics does not exist (#12673)
0073a3d3bf2 is described below

commit 0073a3d3bf2bfca60fb4fad198eb04916feb66e6
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Thu Jun 6 12:17:25 2024 +0800

    Pipe: Reduce warn log when PipeConfigRegionExtractorMetrics does not exist 
(#12673)
---
 .../manager/pipe/metric/PipeConfigRegionExtractorMetrics.java         | 4 +---
 .../db/pipe/metric/PipeDataNodeRemainingEventAndTimeOperator.java     | 3 ---
 2 files changed, 1 insertion(+), 6 deletions(-)

diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeConfigRegionExtractorMetrics.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeConfigRegionExtractorMetrics.java
index 403fb8a2b6c..b736b2a82e8 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeConfigRegionExtractorMetrics.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeConfigRegionExtractorMetrics.java
@@ -122,10 +122,8 @@ public class PipeConfigRegionExtractorMetrics implements 
IMetricSet {
   public long getRemainingEventCount(final String pipeName, final long 
creationTime) {
     final String taskID = pipeName + "_" + creationTime;
     final IoTDBConfigRegionExtractor extractor = extractorMap.get(taskID);
+    // Do not print log to allow collection when config region extractor does 
not exists
     if (Objects.isNull(extractor)) {
-      LOGGER.warn(
-          "Failed to get remaining event count, IoTDBConfigRegionExtractor({}) 
does not exist",
-          taskID);
       return 0;
     }
     return extractor.getUnTransferredEventCount();
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeRemainingEventAndTimeOperator.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeRemainingEventAndTimeOperator.java
index a4b2fd3e7b7..f7a08295f40 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeRemainingEventAndTimeOperator.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeRemainingEventAndTimeOperator.java
@@ -23,7 +23,6 @@ import org.apache.iotdb.commons.pipe.config.PipeConfig;
 import org.apache.iotdb.db.pipe.extractor.dataregion.IoTDBDataRegionExtractor;
 import 
org.apache.iotdb.db.pipe.extractor.schemaregion.IoTDBSchemaRegionExtractor;
 import org.apache.iotdb.db.pipe.task.subtask.connector.PipeConnectorSubtask;
-import org.apache.iotdb.db.pipe.task.subtask.processor.PipeProcessorSubtask;
 
 import com.codahale.metrics.Clock;
 import com.codahale.metrics.ExponentialMovingAverages;
@@ -41,8 +40,6 @@ class PipeDataNodeRemainingEventAndTimeOperator {
 
   private final ConcurrentMap<IoTDBDataRegionExtractor, 
IoTDBDataRegionExtractor>
       dataRegionExtractors = new ConcurrentHashMap<>();
-  private final ConcurrentMap<PipeProcessorSubtask, PipeProcessorSubtask> 
dataRegionProcessors =
-      new ConcurrentHashMap<>();
   private final ConcurrentMap<PipeConnectorSubtask, PipeConnectorSubtask> 
dataRegionConnectors =
       new ConcurrentHashMap<>();
   private final ConcurrentMap<IoTDBSchemaRegionExtractor, 
IoTDBSchemaRegionExtractor>