This is an automated email from the ASF dual-hosted git repository.
rfellows pushed a commit to branch NIFI-15258
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/NIFI-15258 by this push:
new 00ad24bd47 NIFI-15468: Ensure that we properly initialize
ConnectorNode even if a Ghost Connector is created (#10775)
00ad24bd47 is described below
commit 00ad24bd47385de206f4de1ccb4fdaaafbbacf86
Author: Mark Payne <[email protected]>
AuthorDate: Thu Jan 15 09:27:30 2026 -0500
NIFI-15468: Ensure that we properly initialize ConnectorNode even if a
Ghost Connector is created (#10775)
This closes #10775
---
.../apache/nifi/controller/ExtensionBuilder.java | 34 +++++++++++++---------
1 file changed, 20 insertions(+), 14 deletions(-)
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/ExtensionBuilder.java
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/ExtensionBuilder.java
index 3f16f8d25e..989956fd0d 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/ExtensionBuilder.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/ExtensionBuilder.java
@@ -554,20 +554,26 @@ public class ExtensionBuilder {
// If an instance class loader has been created for this connector,
remove it because it's no longer necessary.
extensionManager.removeInstanceClassLoader(identifier);
- return new StandardConnectorNode(
- identifier,
- flowController.getFlowManager(),
- extensionManager,
- connectorsAuthorizable,
- connectorDetails,
- componentType,
- type,
- activeConfigurationContext,
- connectorStateTransition,
- flowContextFactory,
- connectorValidationTrigger,
- true
- );
+ final ConnectorNode connectorNode = new StandardConnectorNode(
+ identifier,
+ flowController.getFlowManager(),
+ extensionManager,
+ connectorsAuthorizable,
+ connectorDetails,
+ componentType,
+ type,
+ activeConfigurationContext,
+ connectorStateTransition,
+ flowContextFactory,
+ connectorValidationTrigger,
+ true
+ );
+
+ // Initialize the ghost connector so that it can be properly
configured during flow synchronization
+ final FrameworkConnectorInitializationContext initContext =
createConnectorInitializationContext(managedProcessGroup, componentLog);
+ connectorNode.initializeConnector(initContext);
+
+ return connectorNode;
}
private void initializeDefaultValues(final Connector connector, final
FrameworkFlowContext flowContext) {