diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/components/connector/secrets/ParameterProviderSecretsManager.java b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/components/connector/secrets/ParameterProviderSecretsManager.java index 37d7d5c57559..5547170e9794 100644 --- a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/components/connector/secrets/ParameterProviderSecretsManager.java +++ b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/components/connector/secrets/ParameterProviderSecretsManager.java @@ -22,6 +22,7 @@ import org.apache.nifi.components.validation.ValidationStatus; import org.apache.nifi.controller.ParameterProviderNode; import org.apache.nifi.controller.flow.FlowManager; +import org.apache.nifi.parameter.ParameterProvider; import org.apache.nifi.util.FormatUtils; import org.apache.nifi.util.NiFiProperties; import org.slf4j.Logger; @@ -117,9 +118,8 @@ public Set getSecretProviders() { if (providerId != null) { final ValidationStatus priorWarnedStatus = lastWarnedStatus.remove(providerId); if (priorWarnedStatus != null) { - logger.info("Parameter Provider [{}] (id={}) returned to VALID after being logged as {};" - + " SecretReferences backed by this provider will resolve again", - parameterProviderNode.getName(), providerId, priorWarnedStatus); + final ParameterProvider parameterProvider = parameterProviderNode.getParameterProvider(); + logger.info("{} returned to VALID after being logged as [{}] now resolving Secret References", parameterProvider, priorWarnedStatus); } } providers.add(new ParameterProviderSecretProvider(parameterProviderNode)); @@ -144,7 +144,7 @@ public Optional getSecret(final SecretReference secretReference) { if (!cacheDuration.isZero()) { final CachedSecret cached = secretCache.get(fqn); if (cached != null && !isExpired(cached)) { - logger.debug("Cache hit for secret [{}]", fqn); + logger.debug("Cached Secret found [{}]", fqn); return Optional.ofNullable(cached.secret()); } } @@ -228,7 +228,7 @@ private Map fetchSecretsWithCache(final Set providers) {