|
@@ -299,7 +299,7 @@ class HiveServerTColumnDesc:
|
|
|
|
|
|
|
|
|
|
|
|
|
class HiveServerClient:
|
|
class HiveServerClient:
|
|
|
- HS2_MECHANISMS = {'KERBEROS': 'GSSAPI', 'NONE': 'PLAIN', 'NOSASL': 'NOSASL'}
|
|
|
|
|
|
|
+ HS2_MECHANISMS = {'KERBEROS': 'GSSAPI', 'NONE': 'PLAIN', 'NOSASL': 'NOSASL', 'LDAP': 'PLAIN'}
|
|
|
|
|
|
|
|
def __init__(self, query_server, user):
|
|
def __init__(self, query_server, user):
|
|
|
self.query_server = query_server
|
|
self.query_server = query_server
|
|
@@ -376,7 +376,7 @@ class HiveServerClient:
|
|
|
hive_mechanism = hive_site.get_hiveserver2_authentication()
|
|
hive_mechanism = hive_site.get_hiveserver2_authentication()
|
|
|
if hive_mechanism not in HiveServerClient.HS2_MECHANISMS:
|
|
if hive_mechanism not in HiveServerClient.HS2_MECHANISMS:
|
|
|
raise Exception(_('%s server authentication not supported. Valid are %s.' % (hive_mechanism, HiveServerClient.HS2_MECHANISMS.keys())))
|
|
raise Exception(_('%s server authentication not supported. Valid are %s.' % (hive_mechanism, HiveServerClient.HS2_MECHANISMS.keys())))
|
|
|
- use_sasl = hive_mechanism in ('KERBEROS', 'NONE')
|
|
|
|
|
|
|
+ use_sasl = hive_mechanism in ('KERBEROS', 'NONE', 'LDAP')
|
|
|
mechanism = HiveServerClient.HS2_MECHANISMS[hive_mechanism]
|
|
mechanism = HiveServerClient.HS2_MECHANISMS[hive_mechanism]
|
|
|
impersonation_enabled = hive_site.hiveserver2_impersonation_enabled()
|
|
impersonation_enabled = hive_site.hiveserver2_impersonation_enabled()
|
|
|
|
|
|