commit 7aa17a15504218785df22246b45d1ae762e29eb4
author Fateh Singh <fateh288@gmail.com> Wed Jan 17 12:03:48 2024 -0800
committer GitHub <noreply@github.com> Wed Jan 17 12:03:48 2024 -0800
tree a6cb0fb48c1e8390b0e7b26b3e877808787d9923
parent a664de553120f165d927e962e3677fe1abd0d722

RANGER-4675: Using the ozone service id specified in the config instead of hardcoded value for resource lookup (#297)

plugin-ozone/src/main/java/org/apache/ranger/services/ozone/client/OzoneClient.java

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
index 0bf2cd6..0bda6b6 100644
--- 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 @@
             }
         }
         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;
         });
     }