You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by fe...@apache.org on 2024/04/23 13:12:46 UTC
(nifi) branch main updated: NIFI-13088 Populate missing parameter context ids in MiNiFi flows.json.raw
This is an automated email from the ASF dual-hosted git repository.
ferdei pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new 4b5b7ac2bb NIFI-13088 Populate missing parameter context ids in MiNiFi flows.json.raw
4b5b7ac2bb is described below
commit 4b5b7ac2bb98168bfcafdc87c342c611d48dd820
Author: Ferenc Kis <br...@gmail.com>
AuthorDate: Tue Apr 23 12:57:34 2024 +0200
NIFI-13088 Populate missing parameter context ids in MiNiFi flows.json.raw
Signed-off-by: Ferenc Erdei <er...@gmail.com>
This closes #8692.
---
.../minifi/commons/service/StandardFlowEnrichService.java | 11 +++++++++++
1 file changed, 11 insertions(+)
diff --git a/minifi/minifi-commons/minifi-commons-framework/src/main/java/org/apache/nifi/minifi/commons/service/StandardFlowEnrichService.java b/minifi/minifi-commons/minifi-commons-framework/src/main/java/org/apache/nifi/minifi/commons/service/StandardFlowEnrichService.java
index 95cc77abec..007fe71605 100644
--- a/minifi/minifi-commons/minifi-commons-framework/src/main/java/org/apache/nifi/minifi/commons/service/StandardFlowEnrichService.java
+++ b/minifi/minifi-commons/minifi-commons-framework/src/main/java/org/apache/nifi/minifi/commons/service/StandardFlowEnrichService.java
@@ -24,6 +24,7 @@ import static java.util.Objects.isNull;
import static java.util.Optional.empty;
import static java.util.Optional.ofNullable;
import static java.util.UUID.randomUUID;
+import static java.util.stream.Collectors.toList;
import static java.util.stream.Collectors.toMap;
import static java.util.stream.Collectors.toSet;
import static org.apache.commons.lang3.StringUtils.EMPTY;
@@ -95,6 +96,16 @@ public class StandardFlowEnrichService implements FlowEnrichService {
versionedDataflow.setReportingTasks(ofNullable(versionedDataflow.getReportingTasks()).orElseGet(ArrayList::new));
versionedDataflow.setRegistries(ofNullable(versionedDataflow.getRegistries()).orElseGet(ArrayList::new));
versionedDataflow.setControllerServices(ofNullable(versionedDataflow.getControllerServices()).orElseGet(ArrayList::new));
+ versionedDataflow.setParameterContexts(
+ ofNullable(versionedDataflow.getParameterContexts()).orElseGet(ArrayList::new)
+ .stream()
+ .map(versionedParameterContext -> {
+ versionedParameterContext.setIdentifier(ofNullable(versionedParameterContext.getIdentifier()).orElseGet(randomUUID()::toString));
+ versionedParameterContext.setInstanceIdentifier(ofNullable(versionedParameterContext.getInstanceIdentifier()).orElseGet(randomUUID()::toString));
+ return versionedParameterContext;
+ })
+ .collect(toList())
+ );
Optional<Integer> maxConcurrentThreads = ofNullable(minifiProperties.getProperty(MiNiFiProperties.NIFI_MINIFI_FLOW_MAX_CONCURRENT_THREADS.getKey()))
.map(Integer::parseInt);