From 1e337d24202231c61f916f2cc51e8af42728dd37 Mon Sep 17 00:00:00 2001 From: Tboy Date: Wed, 16 Oct 2019 13:46:22 +0800 Subject: [PATCH] update hearbeat thread num = 1 (#1029) * move updateTaskState into try/catch block in case of exception * fix NPE * using conf.getInt instead of getString * for AbstractZKClient, remove the log, for it will print the same log message in createZNodePath. for AlertDao, correct the spelling. * duplicate * refactor getTaskWorkerGroupId * add friendly log * update hearbeat thread num = 1 --- .../java/org/apache/dolphinscheduler/common/Constants.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/Constants.java b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/Constants.java index 2240aa9b43..7460cebb5a 100644 --- a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/Constants.java +++ b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/Constants.java @@ -368,7 +368,7 @@ public final class Constants { /** * heartbeat threads number */ - public static final int defaulWorkerHeartbeatThreadNum = 5; + public static final int defaulWorkerHeartbeatThreadNum = 1; /** * heartbeat interval @@ -431,7 +431,7 @@ public final class Constants { /** * default master heartbeat thread number */ - public static final int defaulMasterHeartbeatThreadNum = 5; + public static final int defaulMasterHeartbeatThreadNum = 1; /**