From d0b460f2700852dd0f185babaec8267b2ce9402c Mon Sep 17 00:00:00 2001 From: Palakur Eshwitha Sai <59027782+eshwitha@users.noreply.github.com> Date: Sat, 2 Dec 2023 13:40:43 +0530 Subject: [PATCH] HDFS-17233. The conf dfs.datanode.lifeline.interval.seconds is not considering time unit seconds (#6286). Contributed by Palakur Eshwitha Sai. Reviewed-by: huhaiyang Signed-off-by: Ayush Saxena --- .../org/apache/hadoop/hdfs/server/datanode/DNConf.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DNConf.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DNConf.java index 9b5343321d..be36ca70fe 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DNConf.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DNConf.java @@ -220,10 +220,10 @@ public class DNConf { DFS_HEARTBEAT_INTERVAL_DEFAULT, TimeUnit.SECONDS, TimeUnit.MILLISECONDS); long confLifelineIntervalMs = - getConf().getLong(DFS_DATANODE_LIFELINE_INTERVAL_SECONDS_KEY, - 3 * getConf().getTimeDuration(DFS_HEARTBEAT_INTERVAL_KEY, - DFS_HEARTBEAT_INTERVAL_DEFAULT, TimeUnit.SECONDS, - TimeUnit.MILLISECONDS)); + getConf().getTimeDuration(DFS_DATANODE_LIFELINE_INTERVAL_SECONDS_KEY, + 3 * getConf().getTimeDuration(DFS_HEARTBEAT_INTERVAL_KEY, + DFS_HEARTBEAT_INTERVAL_DEFAULT, TimeUnit.SECONDS), + TimeUnit.SECONDS, TimeUnit.MILLISECONDS); if (confLifelineIntervalMs <= heartBeatInterval) { confLifelineIntervalMs = 3 * heartBeatInterval; DataNode.LOG.warn(