[ 
https://issues.apache.org/jira/browse/HDDS-6612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Siyao Meng updated HDDS-6612:
-----------------------------
    Description: 
We need to have a config key to enable the feature. Otherwise the multi-tenancy 
Ranger client might err out during OM startup.

{code}
diff --git 
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/utils/OzoneManagerRatisUtils.java
 
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/utils/OzoneManagerRatisUtils.java
index b425ea4424..1e7231d8fd 100644
--- 
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/utils/OzoneManagerRatisUtils.java
+++ 
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/utils/OzoneManagerRatisUtils.java
@@ -190,6 +190,7 @@ public static OMClientRequest createClientRequest(OMRequest 
omRequest,
     case PurgePaths:
       return new OMPathsPurgeRequestWithFSO(omRequest);
     case CreateTenant:
+      ozoneManager.getConfiguration().getBoolean("OZONE_MT_ENABLED", false);   
// TODO
       return new OMTenantCreateRequest(omRequest);
     case DeleteTenant:
       return new OMTenantDeleteRequest(omRequest);
diff --git 
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/protocolPB/OzoneManagerRequestHandler.java
 
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/protocolPB/OzoneManagerRequestHandler.java
index 5ab4a3b051..d0739c1441 100644
--- 
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/protocolPB/OzoneManagerRequestHandler.java
+++ 
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/protocolPB/OzoneManagerRequestHandler.java
@@ -235,6 +235,7 @@ public OMResponse handleReadRequest(OMRequest request) {
         responseBuilder.setGetS3VolumeContextResponse(s3VolumeContextResponse);
         break;
       case TenantGetUserInfo:
+        impl.getConfiguration().getBoolean("OZONE_MT_ENABLED", false);   // 
TODO
         TenantGetUserInfoResponse getUserInfoResponse = tenantGetUserInfo(
             request.getTenantGetUserInfoRequest());
         responseBuilder.setTenantGetUserInfoResponse(getUserInfoResponse);

{code}

  was:
{code}
diff --git 
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/utils/OzoneManagerRatisUtils.java
 
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/utils/OzoneManagerRatisUtils.java
index b425ea4424..1e7231d8fd 100644
--- 
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/utils/OzoneManagerRatisUtils.java
+++ 
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/utils/OzoneManagerRatisUtils.java
@@ -190,6 +190,7 @@ public static OMClientRequest createClientRequest(OMRequest 
omRequest,
     case PurgePaths:
       return new OMPathsPurgeRequestWithFSO(omRequest);
     case CreateTenant:
+      ozoneManager.getConfiguration().getBoolean("OZONE_MT_ENABLED", false);   
// TODO
       return new OMTenantCreateRequest(omRequest);
     case DeleteTenant:
       return new OMTenantDeleteRequest(omRequest);
diff --git 
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/protocolPB/OzoneManagerRequestHandler.java
 
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/protocolPB/OzoneManagerRequestHandler.java
index 5ab4a3b051..d0739c1441 100644
--- 
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/protocolPB/OzoneManagerRequestHandler.java
+++ 
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/protocolPB/OzoneManagerRequestHandler.java
@@ -235,6 +235,7 @@ public OMResponse handleReadRequest(OMRequest request) {
         responseBuilder.setGetS3VolumeContextResponse(s3VolumeContextResponse);
         break;
       case TenantGetUserInfo:
+        impl.getConfiguration().getBoolean("OZONE_MT_ENABLED", false);   // 
TODO
         TenantGetUserInfoResponse getUserInfoResponse = tenantGetUserInfo(
             request.getTenantGetUserInfoRequest());
         responseBuilder.setTenantGetUserInfoResponse(getUserInfoResponse);

{code}


> Add config key to enable or disable Multi-Tenancy feature
> ---------------------------------------------------------
>
>                 Key: HDDS-6612
>                 URL: https://issues.apache.org/jira/browse/HDDS-6612
>             Project: Apache Ozone
>          Issue Type: Sub-task
>            Reporter: Siyao Meng
>            Priority: Major
>
> We need to have a config key to enable the feature. Otherwise the 
> multi-tenancy Ranger client might err out during OM startup.
> {code}
> diff --git 
> a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/utils/OzoneManagerRatisUtils.java
>  
> b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/utils/OzoneManagerRatisUtils.java
> index b425ea4424..1e7231d8fd 100644
> --- 
> a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/utils/OzoneManagerRatisUtils.java
> +++ 
> b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/utils/OzoneManagerRatisUtils.java
> @@ -190,6 +190,7 @@ public static OMClientRequest 
> createClientRequest(OMRequest omRequest,
>      case PurgePaths:
>        return new OMPathsPurgeRequestWithFSO(omRequest);
>      case CreateTenant:
> +      ozoneManager.getConfiguration().getBoolean("OZONE_MT_ENABLED", false); 
>   // TODO
>        return new OMTenantCreateRequest(omRequest);
>      case DeleteTenant:
>        return new OMTenantDeleteRequest(omRequest);
> diff --git 
> a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/protocolPB/OzoneManagerRequestHandler.java
>  
> b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/protocolPB/OzoneManagerRequestHandler.java
> index 5ab4a3b051..d0739c1441 100644
> --- 
> a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/protocolPB/OzoneManagerRequestHandler.java
> +++ 
> b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/protocolPB/OzoneManagerRequestHandler.java
> @@ -235,6 +235,7 @@ public OMResponse handleReadRequest(OMRequest request) {
>          
> responseBuilder.setGetS3VolumeContextResponse(s3VolumeContextResponse);
>          break;
>        case TenantGetUserInfo:
> +        impl.getConfiguration().getBoolean("OZONE_MT_ENABLED", false);   // 
> TODO
>          TenantGetUserInfoResponse getUserInfoResponse = tenantGetUserInfo(
>              request.getTenantGetUserInfoRequest());
>          responseBuilder.setTenantGetUserInfoResponse(getUserInfoResponse);
> {code}



--
This message was sent by Atlassian Jira
(v8.20.7#820007)

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to