From 1868c56764a380a7dca80429c90b8faf58e2b51f Mon Sep 17 00:00:00 2001 From: "dk.technoboy" Date: Fri, 20 Dec 2019 15:30:45 +0800 Subject: [PATCH] add sleep 1s for no command --- .../server/master/runner/MasterSchedulerThread.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerThread.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerThread.java index 6e95285ce3..8d7d5a0add 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerThread.java +++ b/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); processDao.moveToErrorCommand(command, e.toString()); } + } else{ + //indicate that no command ,sleep for 1s + Thread.sleep(Constants.SLEEP_TIME_MILLIS); } } }catch (Exception e){