diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobScheduleHelper.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobScheduleHelper.java index ef728fba..5634aa03 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobScheduleHelper.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobScheduleHelper.java @@ -149,12 +149,21 @@ public class JobScheduleHelper { // tx stop - conn.commit(); + } catch (Exception e) { if (!scheduleThreadToStop) { logger.error(">>>>>>>>>>> xxl-job, JobScheduleHelper#scheduleThread error:{}", e); } } finally { + + // commit + try { + conn.commit(); + } catch (SQLException e) { + e.printStackTrace(); + } + + // close PreparedStatement if (null != preparedStatement) { try { preparedStatement.close();