HAWQ-1276. hawq should error out directly when ranger plugin service is unavailable, not a warning.
Project: http://git-wip-us.apache.org/repos/asf/incubator-hawq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-hawq/commit/326fa4f9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-hawq/tree/326fa4f9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-hawq/diff/326fa4f9 Branch: refs/heads/2.1.0.0-incubating Commit: 326fa4f918b2be14adb3d667aea6cd707a24fa16 Parents: 21f1e29 Author: stanlyxiang <[email protected]> Authored: Wed Jan 18 15:40:12 2017 +0800 Committer: hubertzhang <[email protected]> Committed: Thu Jan 19 11:54:40 2017 +0800 ---------------------------------------------------------------------- src/backend/libpq/rangerrest.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-hawq/blob/326fa4f9/src/backend/libpq/rangerrest.c ---------------------------------------------------------------------- diff --git a/src/backend/libpq/rangerrest.c b/src/backend/libpq/rangerrest.c index dc5d193..c920575 100644 --- a/src/backend/libpq/rangerrest.c +++ b/src/backend/libpq/rangerrest.c @@ -425,7 +425,7 @@ static int call_ranger_rest(CURL_HANDLE curl_handle, const char* request) /* check for errors */ if(res != CURLE_OK) { - elog(WARNING, "ranger plugin service from http://%s:%d/%s is unavailable : %s.\n", + elog(ERROR, "ranger plugin service from http://%s:%d/%s is unavailable : %s.\n", rps_addr_host, rps_addr_port, rps_addr_suffix, curl_easy_strerror(res)); } else @@ -467,7 +467,7 @@ int check_privilege_from_ranger(List *request_list, List *result_list) int ret = parse_ranger_response(curl_context_ranger.response.buffer, result_list); if (ret < 0) { - elog(WARNING, "parse ranger response failed, ranger response content is %s", + elog(ERROR, "parse ranger response failed, ranger response content is %s", curl_context_ranger.response.buffer == NULL? "empty.":curl_context_ranger.response.buffer); } if (curl_context_ranger.response.buffer != NULL)
