[hadoop] branch branch-3.3 updated: HDFS-16042. DatanodeAdminMonitor scan should be delay based. Contributed by Ahmed Hussein.

[jbrennan]

This is an automated email from the ASF dual-hosted git repository.

jbrennan pushed a commit to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/hadoop.git


The following commit(s) were added to refs/heads/branch-3.3 by this push:
     new 0f2b89b  HDFS-16042. DatanodeAdminMonitor scan should be delay based. 
Contributed by Ahmed Hussein.
0f2b89b is described below

commit 0f2b89b7915f49eac429faafcb72a431756e2101
Author: Jim Brennan <jbren...@apache.org>
AuthorDate: Thu Jul 15 20:47:02 2021 +0000

    HDFS-16042. DatanodeAdminMonitor scan should be delay based. Contributed by 
Ahmed Hussein.
---
 .../apache/hadoop/hdfs/server/blockmanagement/DatanodeAdminManager.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/DatanodeAdminManager.java
 
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/DatanodeAdminManager.java
index 5d6b826..7d0ba54 100644
--- 
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/DatanodeAdminManager.java
+++ 
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/DatanodeAdminManager.java
@@ -148,7 +148,7 @@ public class DatanodeAdminManager {
       throw new RuntimeException("Unable to create the Decommission monitor " +
           "from "+cls, e);
     }
-    executor.scheduleAtFixedRate(monitor, intervalSecs, intervalSecs,
+    executor.scheduleWithFixedDelay(monitor, intervalSecs, intervalSecs,
         TimeUnit.SECONDS);
 
     LOG.debug("Activating DatanodeAdminManager with interval {} seconds, " +

---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org