fix #1515 (#1516)

5 years ago · 67cde18cc3
1 changed files with 1 additions and 2 deletions
--- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/runner/FetchTaskThread.java
+++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/runner/FetchTaskThread.java
@ -147,9 +147,8 @@ public class FetchTaskThread implements Runnable{
                //check memory and cpu usage and threads
                boolean runCheckFlag = OSUtils.checkResource(workerConfig.getWorkerMaxCpuloadAvg(), workerConfig.getWorkerReservedMemory()) && checkThreadCount(poolExecutor);

-                Thread.sleep(Constants.SLEEP_TIME_MILLIS);
-
                if(!runCheckFlag) {
+                    Thread.sleep(Constants.SLEEP_TIME_MILLIS);
                    continue;
                }