(iotdb) branch dev/1.3 updated: Pipe: Fixed the NPE when closing sync connector (#15772) (#15776)

[rong]

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

rong 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 5ec14a06325 Pipe: Fixed the NPE when closing sync connector (#15772) 
(#15776)
5ec14a06325 is described below

commit 5ec14a06325ab9b5322ac92d33f4bcbd37a3bf92
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Wed Jun 18 18:39:00 2025 +0800

    Pipe: Fixed the NPE when closing sync connector (#15772) (#15776)
---
 .../connector/protocol/thrift/sync/IoTDBDataRegionSyncConnector.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

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 5ed868a43d3..b8e5795484e 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
@@ -506,7 +506,9 @@ public class IoTDBDataRegionSyncConnector extends 
IoTDBDataNodeSyncConnector {
 
   @Override
   public synchronized void discardEventsOfPipe(final String pipeNameToDrop, 
final int regionId) {
-    tabletBatchBuilder.discardEventsOfPipe(pipeNameToDrop, regionId);
+    if (Objects.nonNull(tabletBatchBuilder)) {
+      tabletBatchBuilder.discardEventsOfPipe(pipeNameToDrop, regionId);
+    }
   }
 
   public int getBatchSize() {