Skip to content

Commit a30f171

Browse files
committed
Revert changes
1 parent a729400 commit a30f171

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

saga/seata-saga-spring/src/main/java/org/apache/seata/saga/engine/store/db/DbAndReportTcStateLogStore.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,6 @@ public void recordStateMachineStarted(StateMachineInstance machineInstance, Proc
110110

111111
// save to db
112112
machineInstance.setSerializedStartParams(paramsSerializer.serialize(machineInstance.getStartParams()));
113-
sql = stateLogStoreSqls.getRecordStateMachineStartedSql(dbType);
114113
int effect = executeUpdate(stateLogStoreSqls.getRecordStateMachineStartedSql(dbType),
115114
STATE_MACHINE_INSTANCE_TO_STATEMENT_FOR_INSERT, machineInstance);
116115
if (effect < 1) {
@@ -121,7 +120,7 @@ public void recordStateMachineStarted(StateMachineInstance machineInstance, Proc
121120
LOGGER.error("Record statemachine start error: {}, StateMachine: {}, XID: {}, Reason: {}",
122121
e.getErrcode(), machineInstance.getStateMachine().getName(), machineInstance.getId(), e.getMessage(), e);
123122
this.clearUp(context);
124-
throw new NullPointerException(e.getMessage() + "\n sql : " + sql + "default_xid : " + machineInstance.getId());
123+
throw e;
125124
}
126125
}
127126
}

0 commit comments

Comments
 (0)