diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/serialization/VersionedFlowSynchronizer.java b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/serialization/VersionedFlowSynchronizer.java index d8b5998d4b..eb5c78b7e7 100644 --- a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/serialization/VersionedFlowSynchronizer.java +++ b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/serialization/VersionedFlowSynchronizer.java @@ -1067,8 +1067,14 @@ public class VersionedFlowSynchronizer implements FlowSynchronizer { } private Map getProvidedParameters(final ParameterProviderNode parameterProviderNode, final String parameterGroupName) { - logger.debug("Fetching Parameters for Group [{}] from Provider [{}]", parameterGroupName, parameterProviderNode.getIdentifier()); - parameterProviderNode.fetchParameters(); + final String providerId = parameterProviderNode.getIdentifier(); + logger.debug("Fetching Parameters for Group [{}] from Provider [{}]", parameterGroupName, providerId); + + try { + parameterProviderNode.fetchParameters(); + } catch (final Exception e) { + logger.warn("Fetching Parameters for Group [{}] from Provider [{}] failed", parameterGroupName, providerId, e); + } final Map parameters; final Optional foundParameterGroup = parameterProviderNode.findFetchedParameterGroup(parameterGroupName); @@ -1082,7 +1088,7 @@ public class VersionedFlowSynchronizer implements FlowSynchronizer { parameters = Collections.emptyMap(); } - logger.info("Fetched Parameters [{}] for Group [{}] from Provider [{}]", parameters.size(), parameterGroupName, parameterProviderNode.getIdentifier()); + logger.info("Fetched Parameters [{}] for Group [{}] from Provider [{}]", parameters.size(), parameterGroupName, providerId); return parameters; }