rollback remaining

Author: Caideyipi

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/overview/PipeDataNodeSinglePipeMetrics.java

@@ -42,7 +42,6 @@
 import java.util.Objects;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicBoolean;
 
 public class PipeDataNodeSinglePipeMetrics implements IMetricSet {
 
@@ -229,33 +228,27 @@ private void removeAutoGauge(final String pipeID) {
   public void register(final IoTDBDataRegionExtractor extractor) {
     // The metric is global thus the regionId is omitted
     final String pipeID = extractor.getPipeName() + "_" + extractor.getCreationTime();
-    final AtomicBoolean first = new AtomicBoolean(false);
     remainingEventAndTimeOperatorMap.computeIfAbsent(
         pipeID,
-        k -> {
-          first.set(true);
-          return new PipeDataNodeRemainingEventAndTimeOperator(
-              extractor.getPipeName(), extractor.getCreationTime());
-        });
-    if (Objects.nonNull(metricService) && first.get()) {
+        k ->
+            new PipeDataNodeRemainingEventAndTimeOperator(
+                extractor.getPipeName(), extractor.getCreationTime()));
+    if (Objects.nonNull(metricService)) {
       createMetrics(pipeID);
     }
   }
 
   public void register(final IoTDBSchemaRegionExtractor extractor) {
     // The metric is global thus the regionId is omitted
     final String pipeID = extractor.getPipeName() + "_" + extractor.getCreationTime();
-    final AtomicBoolean first = new AtomicBoolean(false);
     remainingEventAndTimeOperatorMap
         .computeIfAbsent(
             pipeID,
-            k -> {
-              first.set(true);
-              return new PipeDataNodeRemainingEventAndTimeOperator(
-                  extractor.getPipeName(), extractor.getCreationTime());
-            })
+            k ->
+                new PipeDataNodeRemainingEventAndTimeOperator(
+                    extractor.getPipeName(), extractor.getCreationTime()))
         .register(extractor);
-    if (Objects.nonNull(metricService) && first.get()) {
+    if (Objects.nonNull(metricService)) {
       createMetrics(pipeID);
     }
   }

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/overview/PipeTsFileToTabletsMetrics.java

@@ -104,7 +104,8 @@ private void removeMetrics(final String pipeID) {
 
   public void register(final IoTDBDataRegionExtractor extractor) {
     final String pipeID = extractor.getPipeName() + "_" + extractor.getCreationTime();
-    if (Objects.nonNull(metricService) && pipe.add(pipeID)) {
+    pipe.add(pipeID);
+    if (Objects.nonNull(metricService)) {
       createMetrics(pipeID);
     }
   }