diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ranger/RangerRestClientImpl.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ranger/RangerRestClientImpl.java index 13d3836efd..0dcb373860 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ranger/RangerRestClientImpl.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ranger/RangerRestClientImpl.java @@ -66,7 +66,7 @@ private static final Logger LOG = LoggerFactory.getLogger(RangerRestClientImpl.class); private static final String RANGER_REST_URL_EXPORTJSONFILE = "/service/plugins/policies/exportJson"; private static final String RANGER_REST_URL_IMPORTJSONFILE = - "/service/plugins/policies/importPoliciesFromFile?updateIfExists=true"; + "service/plugins/policies/importPoliciesFromFile?updateIfExists=true"; public RangerExportPolicyList exportRangerPolicies(String sourceRangerEndpoint, String dbName, @@ -176,7 +176,7 @@ public RangerExportPolicyList importRangerPolicies(RangerExportPolicyList ranger String jsonRangerExportPolicyList = gson.toJson(rangerExportPolicyList); String url = baseUrl - + (uri.startsWith("/") ? uri : ("/" + uri)); + + (baseUrl.endsWith("/") ? uri : ("/" + uri)); LOG.debug("URL to import policies on target Ranger: {}", url); Retry retriable = new Retry(Exception.class) {