(iotdb) branch master updated: Pipe: Added close for tree session in WriteBackConnector (#15211)

[rong]

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 7fe614c7cc2 Pipe: Added close for tree session in WriteBackConnector 
(#15211)
7fe614c7cc2 is described below

commit 7fe614c7cc209536977f5a057f6273551fa3d55a
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Thu Mar 27 17:14:12 2025 +0800

    Pipe: Added close for tree session in WriteBackConnector (#15211)
---
 .../iotdb/db/pipe/connector/protocol/writeback/WriteBackConnector.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/writeback/WriteBackConnector.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/writeback/WriteBackConnector.java
index 1c3e4bbc112..201f776b9e6 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/writeback/WriteBackConnector.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/writeback/WriteBackConnector.java
@@ -305,6 +305,9 @@ public class WriteBackConnector implements PipeConnector {
     if (session != null) {
       SESSION_MANAGER.closeSession(session, 
COORDINATOR::cleanupQueryExecution);
     }
+    if (treeSession != null) {
+      SESSION_MANAGER.closeSession(treeSession, 
COORDINATOR::cleanupQueryExecution);
+    }
   }
 
   private TSStatus executeStatementForTableModel(Statement statement, String 
dataBaseName) {