|
@@ -27,6 +27,7 @@ from beeswax.server.hive_server2_lib import HiveServerClient
|
|
|
|
|
|
|
|
from ImpalaService import ImpalaHiveServer2Service
|
|
from ImpalaService import ImpalaHiveServer2Service
|
|
|
from impala.impala_flags import get_webserver_certificate_file
|
|
from impala.impala_flags import get_webserver_certificate_file
|
|
|
|
|
+from impala.conf import DAEMON_API_USERNAME, DAEMON_API_PASSWORD
|
|
|
|
|
|
|
|
|
|
|
|
|
LOG = logging.getLogger(__name__)
|
|
LOG = logging.getLogger(__name__)
|
|
@@ -141,6 +142,10 @@ class ImpalaDaemonApi(object):
|
|
|
def __init__(self, server_url):
|
|
def __init__(self, server_url):
|
|
|
self._url = server_url
|
|
self._url = server_url
|
|
|
self._client = HttpClient(self._url, logger=LOG)
|
|
self._client = HttpClient(self._url, logger=LOG)
|
|
|
|
|
+ # You can set username/password for Impala Web UI which overrides kerberos
|
|
|
|
|
+ if DAEMON_API_USERNAME.get() is not None and DAEMON_API_PASSWORD.get() is not None:
|
|
|
|
|
+ self._client.set_digest_auth(DAEMON_API_USERNAME.get(), DAEMON_API_PASSWORD.get())
|
|
|
|
|
+
|
|
|
self._root = Resource(self._client)
|
|
self._root = Resource(self._client)
|
|
|
self._security_enabled = False
|
|
self._security_enabled = False
|
|
|
self._thread_local = threading.local()
|
|
self._thread_local = threading.local()
|