Pārlūkot izejas kodu

[connector] Add use Sasl property to Hive dialect

Romain Rigaux 4 gadi atpakaļ
vecāks
revīzija
be4b8ccd02

+ 1 - 1
apps/beeswax/src/beeswax/server/dbms.py

@@ -282,7 +282,7 @@ def get_query_server_config_via_connector(connector):
       'auth_password': AUTH_PASSWORD.get(),
 
       'impersonation_enabled': impersonation_enabled,
-      'use_sasl': connector['dialect'] in ('hive', 'sparksql'),
+      'use_sasl': connector['options'].get('use_sasl', True),
       'SESSION_TIMEOUT_S': 15 * 60,
       'querycache_rows': 1000,
       'QUERY_TIMEOUT_S': 15 * 60,

+ 3 - 0
desktop/core/src/desktop/lib/connectors/types.py

@@ -38,6 +38,7 @@ CONNECTOR_TYPES = [
       {'name': 'server_host', 'value': 'localhost'},
       {'name': 'server_port', 'value': 10000},
       {'name': 'is_llap', 'value': False},  # cf. _get_session_by_id() or create a separate connector
+      {'name': 'use_sasl', 'value': True},
     ],
     'properties': {
       'is_sql': True,
@@ -66,6 +67,7 @@ CONNECTOR_TYPES = [
       {'name': 'url', 'value': 'hive://localhost:10000'},
       {'name': 'has_ssh', 'value': False},
       {'name': 'ssh_server_host', 'value': '127.0.0.1'},
+      {'name': 'use_sasl', 'value': True},
     ],
     'properties': {
       'is_sql': True,
@@ -234,6 +236,7 @@ CONNECTOR_TYPES = [
       {'name': 'impersonation_enabled', 'value': False},
       {'name': 'has_ssh', 'value': False},
       {'name': 'ssh_server_host', 'value': '127.0.0.1'},
+      {'name': 'use_sasl', 'value': True},
     ],
     'category': 'editor',
     'description': 'Via Thrift Server and Hive interface',