Skip to content

Commit fd62e7a

Browse files
PanternBaoyanhuqing666
authored andcommitted
reset fail state when last xa transaction fail to execute. (#1512)
1 parent 28c8819 commit fd62e7a

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

src/main/java/com/actiontech/dble/backend/mysql/nio/handler/MultiNodeHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ public abstract class MultiNodeHandler implements ResponseHandler {
2626
private static final Logger LOGGER = LoggerFactory.getLogger(MultiNodeHandler.class);
2727
protected final ReentrantLock lock = new ReentrantLock();
2828
protected final NonBlockingSession session;
29-
private AtomicBoolean isFailed = new AtomicBoolean(false);
29+
protected AtomicBoolean isFailed = new AtomicBoolean(false);
3030
protected volatile String error;
3131
protected byte packetId;
3232
protected final AtomicBoolean errorResponse = new AtomicBoolean(false);

src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/AbstractCommitNodesHandler.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,7 @@ public void reset() {
6767
firstResponsed = false;
6868
unResponseRrns.clear();
6969
packetId = 0;
70+
isFailed.set(false);
7071
}
7172

7273
public void debugCommitDelay() {

0 commit comments

Comments
 (0)