This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch pipe-consensus-point-counter in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 9661e10654ffaf53324cd4501e3cd33ca7925f00 Author: Steve Yurong Su <[email protected]> AuthorDate: Tue Jul 2 16:33:21 2024 +0800 Pipe Consensus: Fix failed to read tsfile when counting points on receivers --- .../pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiver.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiver.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiver.java index 1e43056261c..a056d123443 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiver.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiver.java @@ -418,11 +418,11 @@ public class PipeConsensusReceiver { long endPreCheckNanos = System.nanoTime(); pipeConsensusReceiverMetrics.recordTsFileSealPreCheckTimer( endPreCheckNanos - startPreCheckNanos); + updateWritePointCountMetrics(req.getPointCount(), fileAbsolutePath); final TSStatus status = loadFileToDataRegion( fileAbsolutePath, ProgressIndexType.deserializeFrom(ByteBuffer.wrap(req.getProgressIndex()))); - updateWritePointCountMetrics(req.getPointCount(), fileAbsolutePath); pipeConsensusReceiverMetrics.recordTsFileSealLoadTimer(System.nanoTime() - endPreCheckNanos); if (status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) { @@ -538,11 +538,11 @@ public class PipeConsensusReceiver { pipeConsensusReceiverMetrics.recordTsFileSealPreCheckTimer( endPreCheckNanos - startPreCheckNanos); final String tsFileAbsolutePath = fileAbsolutePaths.get(1); + updateWritePointCountMetrics(req.getPointCounts().get(1), tsFileAbsolutePath); final TSStatus status = loadFileToDataRegion( tsFileAbsolutePath, ProgressIndexType.deserializeFrom(ByteBuffer.wrap(req.getProgressIndex()))); - updateWritePointCountMetrics(req.getPointCounts().get(1), tsFileAbsolutePath); pipeConsensusReceiverMetrics.recordTsFileSealLoadTimer(System.nanoTime() - endPreCheckNanos); if (status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
