From 04e16245a4ce6d0c89d056c9eef1b7d57cb6ee40 Mon Sep 17 00:00:00 2001 From: xuxueli <931591021@qq.com> Date: Sat, 6 Jul 2019 21:53:33 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E5=BA=A6=E7=BA=BF=E7=A8=8B=E4=BC=98?= =?UTF-8?q?=E5=8C=96=EF=BC=8C=E9=81=BF=E5=85=8D=E5=BC=82=E5=B8=B8=E6=97=A0?= =?UTF-8?q?=E6=B3=95commit=E5=AF=BC=E8=87=B4=E9=94=81=E8=A1=A8=EF=BC=9B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../xxl/job/admin/core/thread/JobScheduleHelper.java | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) 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();