[To dev/1.3] Pipe: Delete the heartbeat event count in Remaining Count #16115

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

@@ -120,23 +120,6 @@ public int getInsertNodeEventCount() {
     return insertNodeEventCount.get();
   }
 
-  long getRemainingEvents() {
-    final long remainingEvents =
-        tsfileEventCount.get()
-            + rawTabletEventCount.get()
-            + insertNodeEventCount.get()
-            + heartbeatEventCount.get()
-            + schemaRegionExtractors.stream()
-                .map(IoTDBSchemaRegionSource::getUnTransferredEventCount)
-                .reduce(Long::sum)
-                .orElse(0L);
-
-    // There are cases where the indicator is negative. For example, after the Pipe is restarted,
-    // the Processor SubTask is still collecting Events, resulting in a negative count. This
-    // situation cannot be avoided because the Pipe may be restarted internally.
-    return remainingEvents >= 0 ? remainingEvents : 0;
-  }
-
   /**
    * This will calculate the estimated remaining time of pipe.
    *

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

@@ -89,7 +89,7 @@ private void createAutoGauge(final String pipeID) {
         Metric.PIPE_DATANODE_REMAINING_EVENT_COUNT.toString(),
         MetricLevel.IMPORTANT,
         operator,
-        PipeDataNodeRemainingEventAndTimeOperator::getRemainingEvents,
+        PipeDataNodeRemainingEventAndTimeOperator::getRemainingNonHeartbeatEvents,
         Tag.NAME.toString(),
         operator.getPipeName(),
         Tag.CREATION_TIME.toString(),
@@ -403,7 +403,7 @@ public Pair<Long, Double> getRemainingEventAndTime(
         remainingEventAndTimeOperatorMap.computeIfAbsent(
             pipeName + "_" + creationTime,
             k -> new PipeDataNodeRemainingEventAndTimeOperator(pipeName, creationTime));
-    return new Pair<>(operator.getRemainingEvents(), operator.getRemainingTime());
+    return new Pair<>(operator.getRemainingNonHeartbeatEvents(), operator.getRemainingTime());
   }
 
   //////////////////////////// singleton ////////////////////////////