Pipe: Added close for tree session in WriteBackConnector (#15211)

Caideyipi · JackieTien97 · commit 6d65b2e9f6fc · 2025-04-11T08:54:23.000+08:00
(cherry picked from commit 7fe614c)
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
@@ -305,6 +305,9 @@ public void close() throws Exception {
     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) {

Original file line number	Diff line number	Diff line change
`@@ -305,6 +305,9 @@ public void close() throws Exception {`
`305`	`305`	`if (session != null) {`
`306`	`306`	`SESSION_MANAGER.closeSession(session, COORDINATOR::cleanupQueryExecution);`
`307`	`307`	`}`
	`308`	`+ if (treeSession != null) {`
	`309`	`+ SESSION_MANAGER.closeSession(treeSession, COORDINATOR::cleanupQueryExecution);`
	`310`	`+ }`
`308`	`311`	`}`
`309`	`312`
`310`	`313`	`private TSStatus executeStatementForTableModel(Statement statement, String dataBaseName) {`