| 
															
																@@ -149,12 +149,21 @@ public class JobScheduleHelper { 
															 | 
														
													
												
													
														
															| 
															 | 
															
																  
															 | 
															
															 | 
															
																  
															 | 
														
													
												
													
														
															| 
															 | 
															
																                         // tx stop 
															 | 
															
															 | 
															
																                         // tx stop 
															 | 
														
													
												
													
														
															| 
															 | 
															
																  
															 | 
															
															 | 
															
																  
															 | 
														
													
												
													
														
															| 
															 | 
															
																-                        conn.commit(); 
															 | 
															
															 | 
															
																 
															 | 
														
													
												
													
														
															| 
															 | 
															
																 
															 | 
															
															 | 
															
																+ 
															 | 
														
													
												
													
														
															| 
															 | 
															
																                     } catch (Exception e) { 
															 | 
															
															 | 
															
																                     } catch (Exception e) { 
															 | 
														
													
												
													
														
															| 
															 | 
															
																                         if (!scheduleThreadToStop) { 
															 | 
															
															 | 
															
																                         if (!scheduleThreadToStop) { 
															 | 
														
													
												
													
														
															| 
															 | 
															
																                             logger.error(">>>>>>>>>>> xxl-job, JobScheduleHelper#scheduleThread error:{}", e); 
															 | 
															
															 | 
															
																                             logger.error(">>>>>>>>>>> xxl-job, JobScheduleHelper#scheduleThread error:{}", e); 
															 | 
														
													
												
													
														
															| 
															 | 
															
																                         } 
															 | 
															
															 | 
															
																                         } 
															 | 
														
													
												
													
														
															| 
															 | 
															
																                     } finally { 
															 | 
															
															 | 
															
																                     } finally { 
															 | 
														
													
												
													
														
															| 
															 | 
															
																 
															 | 
															
															 | 
															
																+ 
															 | 
														
													
												
													
														
															| 
															 | 
															
																 
															 | 
															
															 | 
															
																+                        // commit 
															 | 
														
													
												
													
														
															| 
															 | 
															
																 
															 | 
															
															 | 
															
																+                        try { 
															 | 
														
													
												
													
														
															| 
															 | 
															
																 
															 | 
															
															 | 
															
																+                            conn.commit(); 
															 | 
														
													
												
													
														
															| 
															 | 
															
																 
															 | 
															
															 | 
															
																+                        } catch (SQLException e) { 
															 | 
														
													
												
													
														
															| 
															 | 
															
																 
															 | 
															
															 | 
															
																+                            e.printStackTrace(); 
															 | 
														
													
												
													
														
															| 
															 | 
															
																 
															 | 
															
															 | 
															
																+                        } 
															 | 
														
													
												
													
														
															| 
															 | 
															
																 
															 | 
															
															 | 
															
																+ 
															 | 
														
													
												
													
														
															| 
															 | 
															
																 
															 | 
															
															 | 
															
																+                        // close PreparedStatement 
															 | 
														
													
												
													
														
															| 
															 | 
															
																                         if (null != preparedStatement) { 
															 | 
															
															 | 
															
																                         if (null != preparedStatement) { 
															 | 
														
													
												
													
														
															| 
															 | 
															
																                             try { 
															 | 
															
															 | 
															
																                             try { 
															 | 
														
													
												
													
														
															| 
															 | 
															
																                                 preparedStatement.close(); 
															 | 
															
															 | 
															
																                                 preparedStatement.close(); 
															 |