@@ -359,8 +359,10 @@ public class TaskSqlServiceImpl implements TaskSqlService {
transactionManager.commit(status);
} catch (Exception e) {
log.error("datasource[{}] commit error:{}", dsid, e.getMessage());
+ // 回滚事务
transactionManager.rollback(status);
- runResult = -1;
+ // 抛出异常到外层进行缓存处理
+ throw e;
}
return runResult;