This is an automated email from the ASF dual-hosted git repository. riemer pushed a commit to branch dev in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 7d091ba95a5e4c170cce914a6fbb4c66032558e9 Author: Dominik Riemer <[email protected]> AuthorDate: Wed Jan 18 10:02:53 2023 +0100 Fix checkstyle issue (#1096) --- .../java/org/apache/streampipes/manager/health/PipelineHealthCheck.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/PipelineHealthCheck.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/PipelineHealthCheck.java index 076ba9866..5f0abc067 100644 --- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/PipelineHealthCheck.java +++ b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/PipelineHealthCheck.java @@ -70,7 +70,7 @@ public class PipelineHealthCheck implements Runnable { List<InvocableStreamPipesEntity> graphs = RunningPipelineElementStorage .runningProcessorsAndSinks .get(pipeline.getPipelineId()); - + graphs.forEach(graph -> { String instanceId = extractInstanceId(graph); if (allRunningInstances.stream().noneMatch(runningInstanceId -> runningInstanceId.equals(instanceId))) {
