NIFI-13706 Handled Exceptions Fetching Parameters on Startup (#9227)

apache · Sep 3, 2024 · 0510e71 · 0510e71
1 parent 5c3e22a
commit 0510e71
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/...ore/src/main/java/org/apache/nifi/controller/serialization/VersionedFlowSynchronizer.java b/...ore/src/main/java/org/apache/nifi/controller/serialization/VersionedFlowSynchronizer.java
@@ -1067,8 +1067,14 @@ private Map<String, Parameter> getProvidedParameters(final FlowManager flowManag
     }
 
     private Map<String, Parameter> 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<String, Parameter> parameters;
         final Optional<ParameterGroup> foundParameterGroup = parameterProviderNode.findFetchedParameterGroup(parameterGroupName);
@@ -1082,7 +1088,7 @@ private Map<String, Parameter> getProvidedParameters(final ParameterProviderNode
             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;
     }