Merge pull request #199 from DSL-UMD/distributed

change to MICROSECONDS
umd-dslam · Sep 26, 2019 · 3a49c18 · 3a49c18
2 parents dc747d8 + 5fe2925
commit 3a49c18
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...t/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/INodeKeyedObjects.java b/...t/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/INodeKeyedObjects.java
@@ -44,7 +44,7 @@ public static void BackupSetToDB() {
           public void run() {
             int i = 0;
             final int num = 1024;
-            if (concurrentHashSet.size() >= num) {
+            if (concurrentHashSet.size() > 0) {
               Iterator<Long> iterator = concurrentHashSet.iterator();
               if (LOG.isInfoEnabled()) {
                 LOG.info("Sync files/directories from cache to database.");
@@ -99,7 +99,7 @@ public void run() {
     }
 
     final ScheduledFuture<?> updateHandle =
-        scheduler.scheduleWithFixedDelay(updateToDB, 100, delay, MILLISECONDS);
+        scheduler.scheduleWithFixedDelay(updateToDB, 100, delay, MICROSECONDS);
 
     scheduler.schedule(
         new Runnable() {