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 <[email protected]> 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;
