|
@@ -48,21 +48,24 @@ def get_resource_manager():
|
|
|
yarn_cluster = cluster.get_cluster_conf_for_job_submission()
|
|
yarn_cluster = cluster.get_cluster_conf_for_job_submission()
|
|
|
if yarn_cluster is None:
|
|
if yarn_cluster is None:
|
|
|
raise PopupException(_('No Resource Manager are available.'))
|
|
raise PopupException(_('No Resource Manager are available.'))
|
|
|
- _api_cache = ResourceManagerApi(yarn_cluster.RESOURCE_MANAGER_API_URL.get(), yarn_cluster.SECURITY_ENABLED.get())
|
|
|
|
|
|
|
+ _api_cache = ResourceManagerApi(yarn_cluster.RESOURCE_MANAGER_API_URL.get(), yarn_cluster.SECURITY_ENABLED.get(), yarn_cluster.SSL_CERT_CA_VERIFY.get())
|
|
|
finally:
|
|
finally:
|
|
|
_api_cache_lock.release()
|
|
_api_cache_lock.release()
|
|
|
return _api_cache
|
|
return _api_cache
|
|
|
|
|
|
|
|
|
|
|
|
|
class ResourceManagerApi(object):
|
|
class ResourceManagerApi(object):
|
|
|
- def __init__(self, oozie_url, security_enabled=False):
|
|
|
|
|
|
|
+ def __init__(self, oozie_url, security_enabled=False, ssl_cert_ca_verify=False):
|
|
|
self._url = posixpath.join(oozie_url, 'ws', _API_VERSION)
|
|
self._url = posixpath.join(oozie_url, 'ws', _API_VERSION)
|
|
|
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 = security_enabled
|
|
self._security_enabled = security_enabled
|
|
|
|
|
+ self._ssl_cert_ca_verify = ssl_cert_ca_verify
|
|
|
|
|
|
|
|
if self._security_enabled:
|
|
if self._security_enabled:
|
|
|
self._client.set_kerberos_auth()
|
|
self._client.set_kerberos_auth()
|
|
|
|
|
+ if ssl_cert_ca_verify:
|
|
|
|
|
+ self._client.set_verify(True)
|
|
|
|
|
|
|
|
def __str__(self):
|
|
def __str__(self):
|
|
|
return "ResourceManagerApi at %s" % (self._url,)
|
|
return "ResourceManagerApi at %s" % (self._url,)
|