You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ju...@apache.org on 2025/06/07 12:46:24 UTC
(iotdb) branch dev/1.3 updated: [To dev/1.3] Pipe: Fixed the metric NPE caused by batch disable (#15672) (#15673)
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 <87...@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