Repository: ambari Updated Branches: refs/heads/branch-1.7.0 f99b49c82 -> 5002575ba
Revert "Fix Hive test" This reverts commit d5d5dd9c6ec783d16a866519715119a019c9e0f6. Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/5002575b Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/5002575b Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/5002575b Branch: refs/heads/branch-1.7.0 Commit: 5002575ba67eff2296d9c50a400f99e5ef0d60fc Parents: f99b49c Author: Mahadev Konar <maha...@apache.org> Authored: Sat Nov 8 01:51:00 2014 -0800 Committer: Mahadev Konar <maha...@apache.org> Committed: Sat Nov 8 01:51:00 2014 -0800 ---------------------------------------------------------------------- .../services/HIVE/package/scripts/service_check.py | 15 +++++++++++++++ 1 file changed, 15 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/5002575b/ambari-server/src/main/resources/stacks/HDP/2.0.6/services/HIVE/package/scripts/service_check.py ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/stacks/HDP/2.0.6/services/HIVE/package/scripts/service_check.py b/ambari-server/src/main/resources/stacks/HDP/2.0.6/services/HIVE/package/scripts/service_check.py index d665da5..bd7537b 100644 --- a/ambari-server/src/main/resources/stacks/HDP/2.0.6/services/HIVE/package/scripts/service_check.py +++ b/ambari-server/src/main/resources/stacks/HDP/2.0.6/services/HIVE/package/scripts/service_check.py @@ -34,6 +34,21 @@ class HiveServiceCheck(Script): port=int(format("{hive_server_port}")) print "Test connectivity to hive server" + if params.security_enabled: + kinitcmd=format("{kinit_path_local} -kt {smoke_user_keytab} {smokeuser}; ") + else: + kinitcmd=None + + try: + check_thrift_port_sasl(address, port, params.hive_server2_authentication, + params.hive_server_principal, kinitcmd) + print "Successfully connected to %s on port %s" % (address, port) + except: + print "Connection to %s on port %s failed" % (address, port) + exit(1) + + hcat_service_check() + webhcat_service_check() if __name__ == "__main__": HiveServiceCheck().execute()
