diff --git a/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/TransactionHandlerManager.java b/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/TransactionHandlerManager.java
index 2f99b1fea..b978e78f9 100644
--- a/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/TransactionHandlerManager.java
+++ b/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/TransactionHandlerManager.java
@@ -60,6 +60,10 @@ public class TransactionHandlerManager {
         }
     }
 
+    public NormalTransactionHandler getNormalTransactionHandler() {
+        return (NormalTransactionHandler) normalHandler;
+    }
+
     public void commit() {
         if (xaTxId != null) {
             xaHandler.commit();
diff --git a/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/normal/stage/CommitStage.java b/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/normal/stage/CommitStage.java
index f311abfae..24fd5b888 100644
--- a/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/normal/stage/CommitStage.java
+++ b/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/normal/stage/CommitStage.java
@@ -34,7 +34,7 @@ public class CommitStage implements TransactionStage {
         if (session.closed()) {
             return null;
         }
-
+        session.getTransactionManager().getNormalTransactionHandler().clearResources();
         if (isFail) {
             session.setFinishedCommitTime();
             session.setResponseTime(false);
diff --git a/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/normal/stage/RollbackStage.java b/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/normal/stage/RollbackStage.java
index 166f7aa76..4f6e98422 100644
--- a/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/normal/stage/RollbackStage.java
+++ b/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/normal/stage/RollbackStage.java
@@ -31,7 +31,7 @@ public class RollbackStage implements TransactionStage {
         if (session.closed()) {
             return null;
         }
-
+        session.getTransactionManager().getNormalTransactionHandler().clearResources();
         session.setResponseTime(false);
         if (isFail) {
             session.getSource().write(sendData);