(iotdb) branch master updated: Pipe: Fixed the metric NPE caused by batch disable (#15672)

[justinchen]

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

justinchen 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 3e0163df0b2 Pipe: Fixed the metric NPE caused by batch disable (#15672)
3e0163df0b2 is described below

commit 3e0163df0b24616f9c5d87e6bb0ff5de1dec6eb2
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Sat Jun 7 20:40:21 2025 +0800

    Pipe: Fixed the metric NPE caused by batch disable (#15672)
---
 .../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 7ea783f5317..43e921008bf 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
@@ -763,7 +763,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 65c544e4de8..03238fe4752 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
@@ -590,7 +590,7 @@ public class IoTDBDataRegionSyncConnector extends 
IoTDBDataNodeSyncConnector {
   }
 
   public int getBatchSize() {
-    return tabletBatchBuilder.size();
+    return Objects.nonNull(tabletBatchBuilder) ? tabletBatchBuilder.size() : 0;
   }
 
   @Override