#289 fix the error handling when xa transaction error in prepare

This commit is contained in:
sunzhengfang
2017-10-18 14:02:20 +08:00
parent 2d3eaa2da8
commit 602b727764
2 changed files with 6 additions and 1 deletions
@@ -105,6 +105,11 @@ public abstract class AbstractCommitNodesHandler extends MultiNodeHandler implem
}
@Override
public void reset(int initCount) {
nodeCount = initCount;
packetId = 0;
}
public void debugCommitDelay() {
@@ -88,7 +88,7 @@ public class XACommitNodesHandler extends AbstractCommitNodesHandler {
public void run() {
ErrorPacket error = new ErrorPacket();
error.setErrNo(ER_ERROR_DURING_COMMIT);
error.setMessage(errorMsg.getBytes());
error.setMessage(errorMsg == null ? null : errorMsg.getBytes());
XAAutoRollbackNodesHandler nextHandler = new XAAutoRollbackNodesHandler(session, error.toBytes(), null, null);
nextHandler.rollback();
}