Cleanup cache directories before initializiing the cache (#455)

qubole · Sep 23, 2020 · 9383d53 · 9383d53
1 parent 4f62453
commit 9383d53
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/rubix-bookkeeper/src/main/java/com/qubole/rubix/bookkeeper/BookKeeper.java b/rubix-bookkeeper/src/main/java/com/qubole/rubix/bookkeeper/BookKeeper.java
@@ -154,9 +154,9 @@ public boolean isBookKeeperAlive()
     this.metrics = bookKeeperMetrics.getMetricsRegistry();
     this.ticker = ticker;
     this.splitSize = CacheConfig.getCacheFileSplitSize(conf);
+    cleanupOldCacheFiles(conf);
     initializeMetrics();
     initializeCache(conf, ticker);
-    cleanupOldCacheFiles(conf);
 
     fetchProcessor = null;
     if (CacheConfig.isParallelWarmupEnabled(conf)) {