diff --git a/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/xa/XAHandler.java b/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/xa/XAHandler.java
index d969f8a80..1bafc3ebf 100644
--- a/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/xa/XAHandler.java
+++ b/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/xa/XAHandler.java
@@ -14,6 +14,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import java.util.*;
+import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.locks.Condition;
 import java.util.concurrent.locks.Lock;
@@ -24,7 +25,7 @@ public class XAHandler {
     private static final String XARECOVER_SQL = "XA RECOVER";
     private static final String KILL_SQL = "KILL CONNECTION ";
     private static final String[] MYSQL_RECOVER_COLS = new String[]{"formatID", "gtrid_length", "bqual_length", "data"};
-    private final Map<PhysicalDbInstance, List<Map<String, String>>> results = new HashMap<>(8);
+    private final Map<PhysicalDbInstance, List<Map<String, String>>> results = new ConcurrentHashMap<>(8);
     private final List<SQLJob> sqlJobs = new ArrayList<>();
     private final AtomicInteger count = new AtomicInteger();
     private final Lock lock;