This is an automated email from the ASF dual-hosted git repository.
joewitt pushed a commit to branch support/nifi-1.x
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/support/nifi-1.x by this push:
new c110836594 NIFI-13971 Removed Parameter Context debug logging in Flow
Synchronizer This closes #9489
c110836594 is described below
commit c1108365949268631526d5016b1a163a82f8e9df
Author: exceptionfactory <[email protected]>
AuthorDate: Tue Nov 5 11:21:24 2024 -0600
NIFI-13971 Removed Parameter Context debug logging in Flow Synchronizer
This closes #9489
Signed-off-by: Joseph Witt <[email protected]>
---
.../nifi/controller/serialization/VersionedFlowSynchronizer.java | 7 -------
1 file changed, 7 deletions(-)
diff --git
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/serialization/VersionedFlowSynchronizer.java
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/serialization/VersionedFlowSynchronizer.java
index cf005441bd..f39ccd401c 100644
---
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/serialization/VersionedFlowSynchronizer.java
+++
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/serialization/VersionedFlowSynchronizer.java
@@ -116,7 +116,6 @@ import java.util.HashSet;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Map;
-import java.util.Map.Entry;
import java.util.Objects;
import java.util.Optional;
import java.util.Set;
@@ -803,12 +802,6 @@ public class VersionedFlowSynchronizer implements
FlowSynchronizer {
final Map<String, String> currentValues = new HashMap<>();
parameterContext.getParameters().values().forEach(param ->
currentValues.put(param.getDescriptor().getName(), param.getValue()));
- if (logger.isDebugEnabled()) {
- final Map<String, String> proposedValues =
parameters.entrySet().stream()
- .collect(Collectors.toMap(Entry::getKey, entry ->
entry.getValue().getValue()));
- logger.debug("For Parameter Context {}, current parameters = {},
proposed = {}", parameterContext.getName(), currentValues, proposedValues);
- }
-
final Map<String, Parameter> updatedParameters = new HashMap<>();
final Set<String> proposedParameterNames = new HashSet<>();
for (final VersionedParameter parameter :
versionedParameterContext.getParameters()) {