|
|
@@ -3106,26 +3106,23 @@ def test_hiveserver2_get_security():
|
|
|
|
|
|
|
|
|
# Impala
|
|
|
- cluster_conf = hadoop.cluster.get_cluster_conf_for_job_submission()
|
|
|
+ impala_query_server = {
|
|
|
+ 'server_name': 'impala', 'dialect': 'impala', 'principal': 'impala', 'impersonation_enabled': False, 'auth_username': 'hue',
|
|
|
+ 'auth_password': None, 'use_sasl': False
|
|
|
+ }
|
|
|
+ impala_query_server.update(default_query_server)
|
|
|
+ assert_equal((False, 'GSSAPI', 'impala', False, 'hue', None), HiveServerClient(impala_query_server, user).get_security())
|
|
|
|
|
|
- finish = cluster_conf.SECURITY_ENABLED.set_for_testing(False)
|
|
|
- try:
|
|
|
- impala_query_server = {'server_name': 'impala', 'principal': 'impala', 'impersonation_enabled': False, 'auth_username': 'hue', 'auth_password': None, 'use_sasl': False}
|
|
|
- impala_query_server.update(default_query_server)
|
|
|
- assert_equal((False, 'GSSAPI', 'impala', False, 'hue', None), HiveServerClient(impala_query_server, user).get_security())
|
|
|
+ impala_query_server = {
|
|
|
+ 'server_name': 'impala', 'dialect': 'impala', 'principal': 'impala', 'impersonation_enabled': True, 'auth_username': 'hue',
|
|
|
+ 'auth_password': None, 'use_sasl': False
|
|
|
+ }
|
|
|
+ impala_query_server.update(default_query_server)
|
|
|
+ assert_equal((False, 'GSSAPI', 'impala', True, 'hue', None), HiveServerClient(impala_query_server, user).get_security())
|
|
|
|
|
|
- impala_query_server = {'server_name': 'impala', 'principal': 'impala', 'impersonation_enabled': True, 'auth_username': 'hue', 'auth_password': None, 'use_sasl': False}
|
|
|
- impala_query_server.update(default_query_server)
|
|
|
- assert_equal((False, 'GSSAPI', 'impala', True, 'hue', None), HiveServerClient(impala_query_server, user).get_security())
|
|
|
- finally:
|
|
|
- finish()
|
|
|
|
|
|
- finish = cluster_conf.SECURITY_ENABLED.set_for_testing(True)
|
|
|
- try:
|
|
|
- impala_query_server.update({'use_sasl': True})
|
|
|
- assert_equal((True, 'GSSAPI', 'impala', True, 'hue', None), HiveServerClient(impala_query_server, user).get_security())
|
|
|
- finally:
|
|
|
- finish()
|
|
|
+ impala_query_server.update({'use_sasl': True})
|
|
|
+ assert_equal((True, 'GSSAPI', 'impala', True, 'hue', None), HiveServerClient(impala_query_server, user).get_security())
|
|
|
finally:
|
|
|
if prev is not None:
|
|
|
hive_site._HIVE_SITE_DICT[hive_site._CNF_HIVESERVER2_AUTHENTICATION] = prev
|