|
@@ -48,6 +48,7 @@ from desktop.settings import LOAD_BALANCER_COOKIE
|
|
|
from hadoop.fs.exceptions import WebHdfsException
|
|
from hadoop.fs.exceptions import WebHdfsException
|
|
|
from useradmin.models import get_profile
|
|
from useradmin.models import get_profile
|
|
|
from useradmin.views import ensure_home_directory, require_change_password
|
|
from useradmin.views import ensure_home_directory, require_change_password
|
|
|
|
|
+from notebook.connectors.base import get_api
|
|
|
|
|
|
|
|
LOG = logging.getLogger(__name__)
|
|
LOG = logging.getLogger(__name__)
|
|
|
|
|
|
|
@@ -202,6 +203,15 @@ def dt_logout(request, next_page=None):
|
|
|
'operationText': 'Logged out user: %s' % username
|
|
'operationText': 'Logged out user: %s' % username
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ # Close Impala session on logout
|
|
|
|
|
+ session_app = "impala"
|
|
|
|
|
+ if request.user.has_hue_permission(action='access', app=session_app):
|
|
|
|
|
+ session = {"type":session_app,"sourceMethod":"dt_logout"}
|
|
|
|
|
+ try:
|
|
|
|
|
+ get_api(request, session).close_session(session)
|
|
|
|
|
+ except Exception, e:
|
|
|
|
|
+ LOG.warn("Error closing Impala session: %s" % e)
|
|
|
|
|
+
|
|
|
backends = get_backends()
|
|
backends = get_backends()
|
|
|
if backends:
|
|
if backends:
|
|
|
for backend in backends:
|
|
for backend in backends:
|