| commit | 509dc2dece1c9102880cf52d139cdb5ef523639e | [log] [tgz] |
|---|---|---|
| author | Isuru Ranawaka <irjanith@gmail.com> | Thu Mar 23 15:47:22 2023 -0400 |
| committer | GitHub <noreply@github.com> | Thu Mar 23 15:47:22 2023 -0400 |
| tree | 431d3711dd800288b1129ee01e875efee2ddc903 | |
| parent | 407d1ef028327e406bc2acf2223272402f578c70 [diff] | |
| parent | 2357f58ffdc0f38a436c3e6f7505376dd82ea553 [diff] |
Merge pull request #207 from apache/service_monitoring 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());