Browse Source

add sleep 1s for no command

pull/2/head
dk.technoboy 5 years ago
parent
commit
1868c56764
  1. 3
      dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerThread.java

3
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerThread.java

@ -128,6 +128,9 @@ public class MasterSchedulerThread implements Runnable {
logger.error("scan command error ", e); logger.error("scan command error ", e);
processDao.moveToErrorCommand(command, e.toString()); processDao.moveToErrorCommand(command, e.toString());
} }
} else{
//indicate that no command ,sleep for 1s
Thread.sleep(Constants.SLEEP_TIME_MILLIS);
} }
} }
}catch (Exception e){ }catch (Exception e){

Loading…
Cancel
Save