|
|
@@ -79,7 +79,8 @@ def get(user, query_server=None, cluster=None):
|
|
|
def get_query_server_config(name='beeswax', server=None, cluster=None):
|
|
|
if cluster and cluster != CLUSTER_ID.get():
|
|
|
if cluster and 'altus:dataware:k8s' in cluster:
|
|
|
- cluster_config = {'server_host': 'impala-coordinatortim', 'name': cluster}
|
|
|
+ name = re.search('cluster:(.+?)/', cluster).group(1)
|
|
|
+ cluster_config = {'server_host': 'impala-coordinator' + name, 'name': cluster}
|
|
|
else:
|
|
|
cluster_config = Cluster(user=None).get_config(cluster)
|
|
|
else:
|