This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch rc/1.3.5 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 4ab5a083cab8ca78b121dfd32ff4fda55a5c51ea Author: Caideyipi <[email protected]> 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() {
