| commit | 2357f58ffdc0f38a436c3e6f7505376dd82ea553 | [log] [tgz] |
|---|---|---|
| author | Isuru Ranawaka <irjanith@gmail.com> | Thu Mar 23 15:45:19 2023 -0400 |
| committer | Isuru Ranawaka <irjanith@gmail.com> | Thu Mar 23 15:45:19 2023 -0400 |
| tree | 431d3711dd800288b1129ee01e875efee2ddc903 | |
| parent | 9a72740602b208aa53f7a9296db859d9731cc1be [diff] |
ProcessManager
diff --git a/service-monitor/src/main/java/org/apache/airavata/datalake/service/monitor/ProcessManager.java b/service-monitor/src/main/java/org/apache/airavata/datalake/service/monitor/ProcessManager.java index b3a94d8..b42b8bd 100644 --- a/service-monitor/src/main/java/org/apache/airavata/datalake/service/monitor/ProcessManager.java +++ b/service-monitor/src/main/java/org/apache/airavata/datalake/service/monitor/ProcessManager.java
@@ -39,7 +39,6 @@ while (iterator.hasNext()) { synchronized (this) { String command = iterator.next(); - System.out.println(command); ProcessBuilder processBuilder = new ProcessBuilder(); processBuilder.command("sh", "-c", command); Process process = processBuilder.start();
diff --git a/service-monitor/src/main/java/org/apache/airavata/datalake/service/monitor/ServiceMonitor.java b/service-monitor/src/main/java/org/apache/airavata/datalake/service/monitor/ServiceMonitor.java index ea93a97..085d147 100644 --- a/service-monitor/src/main/java/org/apache/airavata/datalake/service/monitor/ServiceMonitor.java +++ b/service-monitor/src/main/java/org/apache/airavata/datalake/service/monitor/ServiceMonitor.java
@@ -34,10 +34,14 @@ return null; }).collect(Collectors.toList()); - processManager.startServices(servicesToBeStarted); + List<String> listWithoutNulls = servicesToBeStarted.parallelStream() + .filter(Objects::nonNull) + .collect(Collectors.toList()); + + processManager.startServices(listWithoutNulls); List<String> failedServices = processManager.getUnavailableServices(new ArrayList<String>(fileMap.keySet())); - List<String> listWithoutNulls = failedServices.parallelStream() + listWithoutNulls = failedServices.parallelStream() .filter(Objects::nonNull) .collect(Collectors.toList());