This is an automated email from the ASF dual-hosted git repository.

smolnar pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/knox.git


The following commit(s) were added to refs/heads/master by this push:
     new 5ed96ecc0 KNOX-2909 - Ignoring CORE_SETTINGS CM service discovery 
(#758)
5ed96ecc0 is described below

commit 5ed96ecc04c27dea41c21bfce12929c1c29ccd79
Author: Sandor Molnar <[email protected]>
AuthorDate: Fri Jun 2 14:45:56 2023 +0200

    KNOX-2909 - Ignoring CORE_SETTINGS CM service discovery (#758)
---
 .../topology/discovery/cm/ClouderaManagerServiceDiscovery.java   | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git 
a/gateway-discovery-cm/src/main/java/org/apache/knox/gateway/topology/discovery/cm/ClouderaManagerServiceDiscovery.java
 
b/gateway-discovery-cm/src/main/java/org/apache/knox/gateway/topology/discovery/cm/ClouderaManagerServiceDiscovery.java
index 016b9467a..f503771a5 100644
--- 
a/gateway-discovery-cm/src/main/java/org/apache/knox/gateway/topology/discovery/cm/ClouderaManagerServiceDiscovery.java
+++ 
b/gateway-discovery-cm/src/main/java/org/apache/knox/gateway/topology/discovery/cm/ClouderaManagerServiceDiscovery.java
@@ -74,6 +74,7 @@ public class ClouderaManagerServiceDiscovery implements 
ServiceDiscovery, Cluste
 
   public static final String CM_SERVICE_TYPE  = "CM";
   public static final String CM_ROLE_TYPE  = "CM_SERVER";
+  public static final String CORE_SETTINGS_TYPE = "CORE_SETTINGS";
 
   private ServiceModelGeneratorsHolder serviceModelGeneratorsHolder = 
ServiceModelGeneratorsHolder.getInstance();
 
@@ -273,8 +274,8 @@ public class ClouderaManagerServiceDiscovery implements 
ServiceDiscovery, Cluste
         }
         log.discoveringService(service.getName(), service.getType());
         ApiServiceConfig serviceConfig = null;
-        /* no reason to check service config for CM service */
-        if(!CM_SERVICE_TYPE.equals(service.getType())) {
+        /* no reason to check service config for CM or CORE_SETTINGS services 
*/
+        if (!CM_SERVICE_TYPE.equals(service.getType()) && 
!CORE_SETTINGS_TYPE.equals(service.getType())) {
           serviceConfig = getServiceConfig(client.getConfig(), 
servicesResourceApi, service);
         }
         ApiRoleList roleList = getRoles(client.getConfig(), rolesResourceApi, 
clusterName, service);
@@ -382,13 +383,13 @@ public class ClouderaManagerServiceDiscovery implements 
ServiceDiscovery, Cluste
       try {
         log.lookupRolesFromCM();
         /* Populate roles for CM Service since they are not discoverable */
-        if(CM_SERVICE_TYPE.equalsIgnoreCase(serviceName)) {
+        if (CM_SERVICE_TYPE.equalsIgnoreCase(serviceName)) {
           roles = new ApiRoleList();
           final ApiRole cmRole = new ApiRole();
           cmRole.setName(CM_ROLE_TYPE);
           cmRole.setType(CM_ROLE_TYPE);
           roles.addItemsItem(cmRole);
-        } else {
+        } else if (!CORE_SETTINGS_TYPE.equalsIgnoreCase(serviceName)) { 
//CORE_SETTINGS has no roles, it does not make sense to discover them
           roles = rolesResourceApi.readRoles(clusterName, serviceName, "", 
VIEW_SUMMARY);
         }
 

Reply via email to