This is an automated email from the ASF dual-hosted git repository.
rong 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 e1b6e890dbc Pipe: Fixed the NPE when closing sync connector (#15772)
e1b6e890dbc is described below
commit e1b6e890dbc68fa7d5181639e132e8240004deba
Author: Caideyipi <[email protected]>
AuthorDate: Wed Jun 18 18:38:14 2025 +0800
Pipe: Fixed the NPE when closing sync connector (#15772)
---
.../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 03238fe4752..d320204ab73 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
@@ -586,7 +586,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() {
