Procházet zdrojové kódy

HUE-2547 [core] Reset MapReduce API cache after YARN RM switch

Piotr Ackermann před 11 roky
rodič
revize
1f14101
1 změnil soubory, kde provedl 2 přidání a 0 odebrání
  1. 2 0
      desktop/libs/hadoop/src/hadoop/cluster.py

+ 2 - 0
desktop/libs/hadoop/src/hadoop/cluster.py

@@ -188,6 +188,8 @@ def get_next_ha_yarncluster():
             LOG.warn('Picking RM HA: %s' % name)
             from hadoop.yarn import resource_manager_api
             resource_manager_api._api_cache = None # Reset cache
+            from hadoop.yarn import mapreduce_api
+            mapreduce_api._api_cache = None
             return (config, rm)
           else:
             LOG.info('RM %s is not RUNNING, skipping it: %s' % (name, cluster_info))