polish 6322374d81

2024-04-21 10:21:39 +00:00 · 2020-05-24 16:54:17 +08:00
parent c20e9f9170
commit da90f46e43
1 changed files with 12 additions and 4 deletions
@@ -108,10 +108,18 @@ public class GlobalJobControllerImpl extends JobControllerImpl {

        @Override
        public void run() {
-            if (job != null) {
-                Job temp = job;
-                job = null;
-                temp.terminate();
+            try {
+                if (job != null) {
+                    Job temp = job;
+                    job = null;
+                    temp.terminate();
+                }
+            } catch (Throwable e) {
+                try {
+                    logger.error("JobTimeoutTask error, job id: {}, line: {}", job.id(), job.line(), e);
+                } catch (Throwable t) {
+                    // ignore
+                }
            }
        }