(iotdb) branch master updated: Pipe Consensus: Fix failed to read tsfile when counting points on receivers (#12839)

[rong]

This is an automated email from the ASF dual-hosted git repository.

rong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new fb140af6a7b Pipe Consensus: Fix failed to read tsfile when counting 
points on receivers (#12839)
fb140af6a7b is described below

commit fb140af6a7b6a3bc39e3fea8d8cf880539b990d3
Author: Steve Yurong Su <r...@apache.org>
AuthorDate: Tue Jul 2 21:25:41 2024 +0800

    Pipe Consensus: Fix failed to read tsfile when counting points on receivers 
(#12839)
---
 .../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()) {