diff --git a/doc/XXL-JOB官方文档.md b/doc/XXL-JOB官方文档.md index 23fd6f47..42c15677 100644 --- a/doc/XXL-JOB官方文档.md +++ b/doc/XXL-JOB官方文档.md @@ -2698,7 +2698,8 @@ public void execute() { - b、本次升级针对客户端rollinglog依赖字段做规范约束,如不关注该功能 v2.4.* 及后续版本客户端不需要升级/可兼容,否则需要升级客户端版本; ### 7.42 版本 v3.3.1 Release Notes[ING] -- 1、【TODO】任务调度触发后分批批量更新,提升调度性能; +- 1、【修复】调度组件事务代码优化,修复DB超时等小概率情况下调度终止问题; +- 2、【TODO】任务调度触发后分批批量更新,提升调度性能; ### TODO LIST diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/scheduler/thread/JobScheduleHelper.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/scheduler/thread/JobScheduleHelper.java index de7df79c..e2c93eb6 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/scheduler/thread/JobScheduleHelper.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/scheduler/thread/JobScheduleHelper.java @@ -63,8 +63,9 @@ public class JobScheduleHelper { boolean preReadSuc = true; // transaction start - TransactionStatus transactionStatus = XxlJobAdminBootstrap.getInstance().getTransactionManager().getTransaction(new DefaultTransactionDefinition()); + TransactionStatus transactionStatus = null; try { + transactionStatus = XxlJobAdminBootstrap.getInstance().getTransactionManager().getTransaction(new DefaultTransactionDefinition()); // 1、job lock String lockedRecord = XxlJobAdminBootstrap.getInstance().getXxlJobLockMapper().scheduleLock(); long nowTime = System.currentTimeMillis();