|
@@ -151,7 +151,7 @@ def all_mrclusters():
|
|
|
|
|
|
|
|
def get_yarn():
|
|
def get_yarn():
|
|
|
global MR_NAME_CACHE
|
|
global MR_NAME_CACHE
|
|
|
- if MR_NAME_CACHE in conf.YARN_CLUSTERS:
|
|
|
|
|
|
|
+ if MR_NAME_CACHE in conf.YARN_CLUSTERS and conf.YARN_CLUSTERS[MR_NAME_CACHE].SUBMIT_TO.get():
|
|
|
return conf.YARN_CLUSTERS[MR_NAME_CACHE]
|
|
return conf.YARN_CLUSTERS[MR_NAME_CACHE]
|
|
|
|
|
|
|
|
for name in conf.YARN_CLUSTERS.keys():
|
|
for name in conf.YARN_CLUSTERS.keys():
|