Description
It should be 'StormTopologyName', not 'StromTopologyName'.
public static List<String> getStormResources(String serviceName, Map<String, String> configs,ResourceLookupContext context) {
String userInput = context.getUserInput();
Map<String, List<String>> resourceMap = context.getResources();
List<String> resultList = null;
List<String> StormTopologyList = null;
String StromTopologyName = null;
if ( resourceMap != null && !resourceMap.isEmpty() &&
resourceMap.get(TOPOLOGY) != null )
else
{ StromTopologyName = userInput; }if (configs == null || configs.isEmpty())
{ LOG.error("Connection Config is empty"); }else
{ String url = configs.get("nimbus.url"); String username = configs.get("username"); String password = configs.get("password"); String lookupPrincipal = configs.get("lookupprincipal"); String lookupKeytab = configs.get("lookupkeytab"); String nameRules = configs.get("namerules"); resultList = getStormResources(url, username, password,lookupPrincipal, lookupKeytab, nameRules, StromTopologyName,StormTopologyList); } return resultList;
}