(nifi) branch main updated: NIFI-13706 Handled Exceptions Fetching Parameters on Startup (#9227)

[exceptionfactory]

This is an automated email from the ASF dual-hosted git repository.

exceptionfactory 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 0510e716b4 NIFI-13706 Handled Exceptions Fetching Parameters on 
Startup (#9227)
0510e716b4 is described below

commit 0510e716b480e8e6b20db2170d3cf21c7ce1e6c2
Author: David Handermann <exceptionfact...@apache.org>
AuthorDate: Tue Sep 3 16:29:32 2024 -0500

    NIFI-13706 Handled Exceptions Fetching Parameters on Startup (#9227)
---
 .../controller/serialization/VersionedFlowSynchronizer.java  | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

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<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 @@ 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;
     }