diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/overview/PipeDataNodeRemainingEventAndTimeOperator.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/overview/PipeDataNodeRemainingEventAndTimeOperator.java index db19cc477d821..f54e8bcfccb2c 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/overview/PipeDataNodeRemainingEventAndTimeOperator.java +++ b/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. * diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/overview/PipeDataNodeSinglePipeMetrics.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/overview/PipeDataNodeSinglePipeMetrics.java index f52b28ba2d7f2..7ff3c428f6ee7 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/overview/PipeDataNodeSinglePipeMetrics.java +++ b/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 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 ////////////////////////////