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) {

Reply via email to