in elasticjob-cloud/elasticjob-cloud-scheduler/src/main/java/org/apache/shardingsphere/elasticjob/cloud/scheduler/mesos/MesosStateService.java [138:161]
private Collection<JsonObject> findExecutors(final JsonArray frameworks, final String appName) throws JsonParseException {
Optional<String> frameworkIDOptional = frameworkIDService.fetch();
String frameworkID;
if (frameworkIDOptional.isPresent()) {
frameworkID = frameworkIDOptional.get();
} else {
return Collections.emptyList();
}
List<JsonObject> result = new LinkedList<>();
for (int i = 0; i < frameworks.size(); i++) {
JsonObject framework = frameworks.get(i).getAsJsonObject();
if (!framework.get("id").getAsString().equals(frameworkID)) {
continue;
}
JsonArray executors = framework.get("executors").getAsJsonArray();
for (int j = 0; j < executors.size(); j++) {
JsonObject executor = executors.get(j).getAsJsonObject();
if (null == appName || appName.equals(getExecutorId(executor).split("@-@")[0])) {
result.add(executor);
}
}
}
return result;
}