fix

Caideyipi · Caideyipi · commit a6a9221d2810 · 2025-12-19T12:07:30.000+08:00
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/writeback/WriteBackSink.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/writeback/WriteBackSink.java
@@ -364,7 +364,6 @@ private void doTransfer(final PipeStatementInsertionEvent pipeStatementInsertion
   @Override
   public void close() throws Exception {
     if (session != null) {
-      SESSION_MANAGER.removeCurrSession();
       SESSION_MANAGER.closeSession(session, COORDINATOR::cleanupQueryExecution, false);
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -364,7 +364,6 @@ private void doTransfer(final PipeStatementInsertionEvent pipeStatementInsertion`
`364`	`364`	`@Override`
`365`	`365`	`public void close() throws Exception {`
`366`	`366`	`if (session != null) {`
`367`		`- SESSION_MANAGER.removeCurrSession();`
`368`	`367`	`SESSION_MANAGER.closeSession(session, COORDINATOR::cleanupQueryExecution, false);`
`369`	`368`	`}`
`370`	`369`	`}`