Browse Source

add log

pull/2/head
Technoboy- 5 years ago
parent
commit
16c29a008e
  1. 4
      dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterBaseTaskExecThread.java
  2. 1
      dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterTaskExecThread.java

4
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterBaseTaskExecThread.java

@ -134,9 +134,9 @@ public class MasterBaseTaskExecThread implements Callable<Boolean> {
return task;
}
if(!submitDB){
logger.error("task commit to db failed , task has already retry {} times, please check the database", retryTimes);
logger.error("task commit to db failed , taskId {} has already retry {} times, please check the database", taskInstance.getId(), retryTimes);
}else if(!submitQueue){
logger.error("task commit to queue failed , task has already retry {} times, please check the database", retryTimes);
logger.error("task commit to queue failed , taskId {} has already retry {} times, please check the queue", taskInstance.getId(), retryTimes);
}
Thread.sleep(commitRetryInterval);
} catch (Exception e) {

1
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterTaskExecThread.java

@ -75,6 +75,7 @@ public class MasterTaskExecThread extends MasterBaseTaskExecThread {
Boolean result = false;
this.taskInstance = submit();
if(this.taskInstance == null){
logger.error("submit task instance to mysql and queue failed , please check and fix it");
return result;
}
if(!this.taskInstance.getState().typeIsFinished()) {

Loading…
Cancel
Save