[streampipes] 02/05: Fix checkstyle issues (#1096)

[ri...@apache.org]

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 ec5e75171f22fe1271009cc108c479f8c8bb1641
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Mon Jan 16 22:21:51 2023 +0100

    Fix checkstyle issues (#1096)
---
 .../streampipes/manager/execution/PipelineExecutionTaskFactory.java  | 2 +-
 .../org/apache/streampipes/manager/health/PipelineHealthCheck.java   | 5 ++++-
 .../java/org/apache/streampipes/manager/operations/Operations.java   | 2 +-
 3 files changed, 6 insertions(+), 3 deletions(-)

diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/PipelineExecutionTaskFactory.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/PipelineExecutionTaskFactory.java
index e290c485d..3fab1d07e 100644
--- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/PipelineExecutionTaskFactory.java
+++ b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/PipelineExecutionTaskFactory.java
@@ -24,10 +24,10 @@ import org.apache.streampipes.manager.execution.provider.CurrentPipelineElementP
 import org.apache.streampipes.manager.execution.provider.StoredPipelineElementProvider;
 import org.apache.streampipes.manager.execution.task.AfterInvocationTask;
 import org.apache.streampipes.manager.execution.task.DiscoverEndpointsTask;
-import org.apache.streampipes.manager.execution.task.SubmitRequestTask;
 import org.apache.streampipes.manager.execution.task.PipelineExecutionTask;
 import org.apache.streampipes.manager.execution.task.SecretEncryptionTask;
 import org.apache.streampipes.manager.execution.task.StorePipelineStatusTask;
+import org.apache.streampipes.manager.execution.task.SubmitRequestTask;
 import org.apache.streampipes.manager.execution.task.UpdateGroupIdTask;
 import org.apache.streampipes.model.message.PipelineStatusMessageType;
 import org.apache.streampipes.model.pipeline.Pipeline;
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 c0e159df0..076ba9866 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
@@ -67,7 +67,10 @@ public class PipelineHealthCheck implements Runnable {
         List<String> failedInstances = new ArrayList<>();
         List<String> recoveredInstances = new ArrayList<>();
         List<String> pipelineNotifications = new ArrayList<>();
-        List<InvocableStreamPipesEntity> graphs = RunningPipelineElementStorage.runningProcessorsAndSinks.get(pipeline.getPipelineId());
+        List<InvocableStreamPipesEntity> graphs = RunningPipelineElementStorage
+            .runningProcessorsAndSinks
+            .get(pipeline.getPipelineId());
+        
         graphs.forEach(graph -> {
           String instanceId = extractInstanceId(graph);
           if (allRunningInstances.stream().noneMatch(runningInstanceId -> runningInstanceId.equals(instanceId))) {
diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/operations/Operations.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/operations/Operations.java
index 3457d63ea..15f5e80ba 100644
--- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/operations/Operations.java
+++ b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/operations/Operations.java
@@ -23,12 +23,12 @@ import org.apache.streampipes.commons.exceptions.SepaParseException;
 import org.apache.streampipes.commons.exceptions.SpRuntimeException;
 import org.apache.streampipes.manager.endpoint.EndpointItemFetcher;
 import org.apache.streampipes.manager.execution.PipelineExecutor;
-import org.apache.streampipes.manager.storage.PipelineStorageService;
 import org.apache.streampipes.manager.matching.DataSetGroundingSelector;
 import org.apache.streampipes.manager.matching.PipelineVerificationHandlerV2;
 import org.apache.streampipes.manager.recommender.ElementRecommender;
 import org.apache.streampipes.manager.remote.ContainerProvidedOptionsHandler;
 import org.apache.streampipes.manager.runtime.PipelineElementRuntimeInfoFetcher;
+import org.apache.streampipes.manager.storage.PipelineStorageService;
 import org.apache.streampipes.manager.template.PipelineTemplateGenerator;
 import org.apache.streampipes.manager.template.PipelineTemplateInvocationGenerator;
 import org.apache.streampipes.manager.template.PipelineTemplateInvocationHandler;