azkaban-aplcache

Standardize on "System.currentTimeMillis()" within the

8/10/2017 9:43:54 PM

Details

diff --git a/azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java b/azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java
index 400dc60..a0990fc 100644
--- a/azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java
+++ b/azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java
@@ -1687,10 +1687,10 @@ public class ExecutorManager extends EventHandler implements
 
     private void cleanExecutionLogs() {
       logger.info("Cleaning old logs from execution_logs");
-      long cutoff = DateTime.now().getMillis() - executionLogsRetentionMs;
+      long cutoff = System.currentTimeMillis() - executionLogsRetentionMs;
       logger.info("Cleaning old log files before "
           + new DateTime(cutoff).toString());
-      cleanOldExecutionLogs(DateTime.now().getMillis()
+      cleanOldExecutionLogs(System.currentTimeMillis()
           - executionLogsRetentionMs);
     }
   }