in src/main/java/org/apache/fluo/yarn/FluoYarnLauncher.java [78:93]
private static int getNumRunning(TwillController controller) {
ResourceReport report = controller.getResourceReport();
if (report == null) {
return 0;
}
int total = 0;
Collection<TwillRunResources> resources = report.getRunnableResources(ORACLE_ID);
if (resources != null) {
total += resources.size();
}
resources = report.getRunnableResources(WORKER_ID);
if (resources != null) {
total += resources.size();
}
return total;
}