From 947d8044d7101ace1f95f08b511088737eb4ba1e Mon Sep 17 00:00:00 2001 From: "dk.technoboy" Date: Wed, 18 Dec 2019 21:00:54 +0800 Subject: [PATCH] fix #1515 --- .../dolphinscheduler/server/worker/runner/FetchTaskThread.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git 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 index ae4ee792c5..68f27d76d8 100644 --- 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; }