Pipe: Reduce warn log when PipeConfigRegionExtractorMetrics does not …

…exist (#12673)
apache · Jun 6, 2024 · 0073a3d · 0073a3d
1 parent baa9e5d
commit 0073a3d
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 6 deletions.
diff --git a/...ava/org/apache/iotdb/confignode/manager/pipe/metric/PipeConfigRegionExtractorMetrics.java b/...ava/org/apache/iotdb/confignode/manager/pipe/metric/PipeConfigRegionExtractorMetrics.java
@@ -122,10 +122,8 @@ public void deregister(final String taskID) {
   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/.../main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeRemainingEventAndTimeOperator.java b/.../main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeRemainingEventAndTimeOperator.java
@@ -23,7 +23,6 @@
 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>