From 0cb392ad64f842d42adae6ab7decfacf06556896 Mon Sep 17 00:00:00 2001 From: Pierre Villard Date: Mon, 6 Jul 2026 16:54:04 +0200 Subject: [PATCH 1/2] NIFI-16048 - Add property descriptor for Flow Registry Client Sync Interval --- .../flow/AbstractFlowRegistryClient.java | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/src/main/java/org/apache/nifi/registry/flow/AbstractFlowRegistryClient.java b/src/main/java/org/apache/nifi/registry/flow/AbstractFlowRegistryClient.java index 38aae15..2505e71 100644 --- a/src/main/java/org/apache/nifi/registry/flow/AbstractFlowRegistryClient.java +++ b/src/main/java/org/apache/nifi/registry/flow/AbstractFlowRegistryClient.java @@ -17,13 +17,31 @@ package org.apache.nifi.registry.flow; import org.apache.nifi.components.AbstractConfigurableComponent; +import org.apache.nifi.components.PropertyDescriptor; import org.apache.nifi.logging.ComponentLog; +import org.apache.nifi.processor.util.StandardValidators; import java.util.Optional; import javax.net.ssl.SSLContext; public abstract class AbstractFlowRegistryClient extends AbstractConfigurableComponent implements FlowRegistryClient { + /** + * Property that controls how often NiFi checks this Flow Registry Client for updated versions of the flows that + * are under version control against it. When this property is left blank, NiFi falls back to the global + * {@code nifi.flowcontroller.registry.sync.interval} property. Concrete Flow Registry Client implementations should + * include this descriptor in the List returned by {@link #getSupportedPropertyDescriptors()} in order to allow the + * synchronization interval to be configured on a per-client basis. + */ + public static final PropertyDescriptor SYNCHRONIZATION_INTERVAL = new PropertyDescriptor.Builder() + .name("Synchronization Interval") + .description(""" + How often NiFi checks this Flow Registry Client for newer versions of the flows that are under version control against it. \ + When left blank, the global nifi.flowcontroller.registry.sync.interval property is used.""") + .required(false) + .addValidator(StandardValidators.TIME_PERIOD_VALIDATOR) + .build(); + private volatile String identifier; private volatile Optional systemSslContext; private volatile ComponentLog logger; From dbed32690c102efdd0ae3db3a99eaa5f2d3494d6 Mon Sep 17 00:00:00 2001 From: Pierre Villard Date: Mon, 6 Jul 2026 16:54:58 +0200 Subject: [PATCH 2/2] Update src/main/java/org/apache/nifi/registry/flow/AbstractFlowRegistryClient.java Co-authored-by: David Handermann --- .../apache/nifi/registry/flow/AbstractFlowRegistryClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/org/apache/nifi/registry/flow/AbstractFlowRegistryClient.java b/src/main/java/org/apache/nifi/registry/flow/AbstractFlowRegistryClient.java index 2505e71..6640000 100644 --- a/src/main/java/org/apache/nifi/registry/flow/AbstractFlowRegistryClient.java +++ b/src/main/java/org/apache/nifi/registry/flow/AbstractFlowRegistryClient.java @@ -37,7 +37,7 @@ public abstract class AbstractFlowRegistryClient extends AbstractConfigurableCom .name("Synchronization Interval") .description(""" How often NiFi checks this Flow Registry Client for newer versions of the flows that are under version control against it. \ - When left blank, the global nifi.flowcontroller.registry.sync.interval property is used.""") + When left blank, the application uses the nifi.flowcontroller.registry.sync.interval property""") .required(false) .addValidator(StandardValidators.TIME_PERIOD_VALIDATOR) .build();