Pipe: Fixed the metric NPE caused by batch disable (#15672)

Caideyipi · web-flow · commit 3e0163df0b24 · 2025-06-07T20:40:21.000+08:00
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
@@ -763,7 +763,7 @@ public int getRetryEventQueueSize() {
   }
 
   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
@@ -590,7 +590,7 @@ public synchronized void discardEventsOfPipe(final String pipeNameToDrop, final
   }
 
   public int getBatchSize() {
-    return tabletBatchBuilder.size();
+    return Objects.nonNull(tabletBatchBuilder) ? tabletBatchBuilder.size() : 0;
   }
 
   @Override

Original file line number	Diff line number	Diff line change
`@@ -763,7 +763,7 @@ public int getRetryEventQueueSize() {`
`763`	`763`	`}`
`764`	`764`
`765`	`765`	`public int getBatchSize() {`
`766`		`- return tabletBatchBuilder.size();`
	`766`	`+ return Objects.nonNull(tabletBatchBuilder) ? tabletBatchBuilder.size() : 0;`
`767`	`767`	`}`
`768`	`768`
`769`	`769`	`public int getPendingHandlersSize() {`
Original file line number	Diff line number	Diff line change
`@@ -590,7 +590,7 @@ public synchronized void discardEventsOfPipe(final String pipeNameToDrop, final`
`590`	`590`	`}`
`591`	`591`
`592`	`592`	`public int getBatchSize() {`
`593`		`- return tabletBatchBuilder.size();`
	`593`	`+ return Objects.nonNull(tabletBatchBuilder) ? tabletBatchBuilder.size() : 0;`
`594`	`594`	`}`
`595`	`595`
`596`	`596`	`@Override`