|
@@ -22,6 +22,7 @@ from operator import itemgetter
|
|
|
|
|
|
|
|
from desktop.lib import thrift_util
|
|
from desktop.lib import thrift_util
|
|
|
from desktop.conf import LDAP_PASSWORD, LDAP_USERNAME
|
|
from desktop.conf import LDAP_PASSWORD, LDAP_USERNAME
|
|
|
|
|
+from desktop.conf import DEFAULT_USER
|
|
|
from hadoop import cluster
|
|
from hadoop import cluster
|
|
|
|
|
|
|
|
from TCLIService import TCLIService
|
|
from TCLIService import TCLIService
|
|
@@ -43,7 +44,7 @@ from impala import conf as impala_conf
|
|
|
LOG = logging.getLogger(__name__)
|
|
LOG = logging.getLogger(__name__)
|
|
|
|
|
|
|
|
IMPALA_RESULTSET_CACHE_SIZE = 'impala.resultset.cache.size'
|
|
IMPALA_RESULTSET_CACHE_SIZE = 'impala.resultset.cache.size'
|
|
|
-
|
|
|
|
|
|
|
+DEFAULT_USER = DEFAULT_USER.get()
|
|
|
|
|
|
|
|
class HiveServerTable(Table):
|
|
class HiveServerTable(Table):
|
|
|
"""
|
|
"""
|
|
@@ -375,7 +376,7 @@ class HiveServerClient:
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
if self.impersonation_enabled:
|
|
if self.impersonation_enabled:
|
|
|
- kwargs.update({'username': 'hue'})
|
|
|
|
|
|
|
+ kwargs.update({'username': DEFAULT_USER})
|
|
|
|
|
|
|
|
if self.query_server['server_name'] == 'impala': # Only when Impala accepts it
|
|
if self.query_server['server_name'] == 'impala': # Only when Impala accepts it
|
|
|
kwargs['configuration'].update({'impala.doas.user': user.username})
|
|
kwargs['configuration'].update({'impala.doas.user': user.username})
|