瀏覽代碼

YARN-11701. [Federation] Enhance Federation Cache Clean Conditions. (#6889) Contributed by Shilun Fan.

Reviewed-by: Ayush Saxena <ayushsaxena@apache.org>
slfan1989 10 月之前
父節點
當前提交
9710a8d52f

+ 3 - 1
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/cache/FederationCaffeineCache.java

@@ -79,7 +79,9 @@ public class FederationCaffeineCache extends FederationCache {
 
   @Override
   public void clearCache() {
-    this.cache.cleanUp();
+    if (this.cache != null) {
+      this.cache.cleanUp();
+    }
     this.cache = null;
   }
 

+ 3 - 1
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/cache/FederationGuavaCache.java

@@ -76,7 +76,9 @@ public class FederationGuavaCache extends FederationCache {
 
   @Override
   public void clearCache() {
-    cache.invalidateAll();
+    if (this.cache != null) {
+      cache.invalidateAll();
+    }
     cache = null;
   }
 

+ 3 - 1
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/cache/FederationJCache.java

@@ -91,7 +91,9 @@ public class FederationJCache extends FederationCache {
 
   @Override
   public void clearCache() {
-    this.cache.clear();
+    if (this.cache != null) {
+      this.cache.clear();
+    }
     this.cache = null;
   }