RANGER-4675: Using the ozone service id specified in the config inste…

…ad of hardcoded value for resource lookup (#297)
apache · Jan 17, 2024 · 7aa17a1 · 7aa17a1
1 parent a664de5
commit 7aa17a1
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/plugin-ozone/src/main/java/org/apache/ranger/services/ozone/client/OzoneClient.java b/plugin-ozone/src/main/java/org/apache/ranger/services/ozone/client/OzoneClient.java
@@ -54,7 +54,8 @@ public OzoneClient(String serviceName, Map<String,String> connectionProperties)
             }
         }
         Subject.doAs(getLoginSubject(), (PrivilegedExceptionAction<Void>) () -> {
-            ozoneClient = OzoneClientFactory.getRpcClient("ozone1", conf);
+            String[] serviceIds = conf.getTrimmedStrings("ozone.om.service.ids", "ozone1");
+            ozoneClient = OzoneClientFactory.getRpcClient(serviceIds[0], conf);
             return null;
         });
     }