HDFS-13529. Fix default trash policy emptier trigger time correctly. …

…Contributed by He Xiaoqiao. Signed-off-by: Wei-Chiu Chuang <weichiu@apache.org>
apache · Aug 1, 2019 · f86de6f · f86de6f
1 parent e111789
commit f86de6f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...p-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/TrashPolicyDefault.java b/...p-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/TrashPolicyDefault.java
@@ -271,9 +271,9 @@ protected class Emptier implements Runnable {
     public void run() {
       if (emptierInterval == 0)
         return;                                   // trash disabled
-      long now = Time.now();
-      long end;
+      long now, end;
       while (true) {
+        now = Time.now();
         end = ceiling(now, emptierInterval);
         try {                                     // sleep for interval
           Thread.sleep(end - now);