(iotdb) branch dev/1.3 updated: [To dev/1.3] Pipe: Fixed the metric NPE caused by batch disable (#15672) (#15673)

[justinchen]

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

justinchen pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new dd01534a852 [To dev/1.3] Pipe: Fixed the metric NPE caused by batch 
disable (#15672) (#15673)
dd01534a852 is described below

commit dd01534a852ad99fa20639e0332418efbf7cd53f
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Sat Jun 7 20:46:19 2025 +0800

    [To dev/1.3] Pipe: Fixed the metric NPE caused by batch disable (#15672) 
(#15673)
---
 .../connector/protocol/thrift/async/IoTDBDataRegionAsyncConnector.java  | 2 +-
 .../connector/protocol/thrift/sync/IoTDBDataRegionSyncConnector.java    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/IoTDBDataRegionAsyncConnector.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/IoTDBDataRegionAsyncConnector.java
index c50b651f3be..46f3cfb71d1 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/IoTDBDataRegionAsyncConnector.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/IoTDBDataRegionAsyncConnector.java
@@ -746,7 +746,7 @@ public class IoTDBDataRegionAsyncConnector extends 
IoTDBConnector {
   }
 
   public int getBatchSize() {
-    return tabletBatchBuilder.size();
+    return Objects.nonNull(tabletBatchBuilder) ? tabletBatchBuilder.size() : 0;
   }
 
   public int getPendingHandlersSize() {
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/sync/IoTDBDataRegionSyncConnector.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/sync/IoTDBDataRegionSyncConnector.java
index e5ae94f5b2d..5ed868a43d3 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/sync/IoTDBDataRegionSyncConnector.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/sync/IoTDBDataRegionSyncConnector.java
@@ -510,7 +510,7 @@ public class IoTDBDataRegionSyncConnector extends 
IoTDBDataNodeSyncConnector {
   }
 
   public int getBatchSize() {
-    return tabletBatchBuilder.size();
+    return Objects.nonNull(tabletBatchBuilder) ? tabletBatchBuilder.size() : 0;
   }
 
   @Override