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

elek pushed a commit to branch HDDS-2267
in repository https://gitbox.apache.org/repos/asf/hadoop-ozone.git

commit c04fa855f1e9f794dd1ff6ddc207d4b6f04ec39d
Author: Doroszlai, Attila <adorosz...@apache.org>
AuthorDate: Wed Oct 9 08:13:15 2019 +0200

    HDDS-2267. Container metadata scanner interval mismatch
---
 .../hadoop/ozone/container/ozoneimpl/ContainerMetadataScanner.java | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ozoneimpl/ContainerMetadataScanner.java
 
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ozoneimpl/ContainerMetadataScanner.java
index 46aaf73..3eb1f97 100644
--- 
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ozoneimpl/ContainerMetadataScanner.java
+++ 
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ozoneimpl/ContainerMetadataScanner.java
@@ -94,10 +94,11 @@ public class ContainerMetadataScanner extends Thread {
           metrics.getNumScanIterations(),
           metrics.getNumContainersScanned(),
           metrics.getNumUnHealthyContainers());
-      // ensure to delay next metadata scan with respect to user config.
-      if (interval < metadataScanInterval) {
+      long elapsedMillis = TimeUnit.NANOSECONDS.toMillis(interval);
+      long remainingSleep = metadataScanInterval - elapsedMillis;
+      if (remainingSleep > 0) {
         try {
-          Thread.sleep(metadataScanInterval - interval);
+          Thread.sleep(remainingSleep);
         } catch (InterruptedException e) {
           LOG.info("Background ContainerMetadataScanner interrupted." +
               " Going to exit");


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

Reply via email to