|
@@ -23,7 +23,7 @@ import threading
|
|
|
from desktop.lib.rest.http_client import HttpClient
|
|
from desktop.lib.rest.http_client import HttpClient
|
|
|
from desktop.lib.rest.resource import Resource
|
|
from desktop.lib.rest.resource import Resource
|
|
|
|
|
|
|
|
-from spark.conf import get_livy_server_url
|
|
|
|
|
|
|
+from spark.conf import get_livy_server_url, SECURITY_ENABLED
|
|
|
|
|
|
|
|
|
|
|
|
|
LOG = logging.getLogger(__name__)
|
|
LOG = logging.getLogger(__name__)
|
|
@@ -52,13 +52,17 @@ def get_api(user):
|
|
|
|
|
|
|
|
|
|
|
|
|
class JobServerApi(object):
|
|
class JobServerApi(object):
|
|
|
|
|
+
|
|
|
def __init__(self, oozie_url):
|
|
def __init__(self, oozie_url):
|
|
|
self._url = posixpath.join(oozie_url)
|
|
self._url = posixpath.join(oozie_url)
|
|
|
self._client = HttpClient(self._url, logger=LOG)
|
|
self._client = HttpClient(self._url, logger=LOG)
|
|
|
self._root = Resource(self._client)
|
|
self._root = Resource(self._client)
|
|
|
- self._security_enabled = False
|
|
|
|
|
|
|
+ self._security_enabled = SECURITY_ENABLED.get()
|
|
|
self._thread_local = threading.local()
|
|
self._thread_local = threading.local()
|
|
|
|
|
|
|
|
|
|
+ if self.security_enabled:
|
|
|
|
|
+ self._client.set_kerberos_auth()
|
|
|
|
|
+
|
|
|
def __str__(self):
|
|
def __str__(self):
|
|
|
return "JobServerApi at %s" % (self._url,)
|
|
return "JobServerApi at %s" % (self._url,)
|
|
|
|
|
|