(nifi) branch main updated: NIFI-14214 Set RPG input port's scheduledState to RUNNING by default when converting a NiFi flow to MiNiFi flow so the RPG will transmit when starting MiNiFi

[briansolo1985]

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

briansolo1985 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 5b014cf2c9 NIFI-14214 Set RPG input port's scheduledState to RUNNING 
by default when converting a NiFi flow to MiNiFi flow so the RPG will transmit 
when starting MiNiFi
5b014cf2c9 is described below

commit 5b014cf2c9d1762f870518f8bd3fd27ac8235e21
Author: Peter Kedvessy <pkedve...@gmail.com>
AuthorDate: Wed Feb 5 13:57:16 2025 +0100

    NIFI-14214 Set RPG input port's scheduledState to RUNNING by default when 
converting a NiFi flow to MiNiFi flow so the RPG will transmit when starting 
MiNiFi
    
    This closes #9699.
    
    Signed-off-by: Ferenc Kis <briansolo1...@gmail.com>
---
 .../json/TransformNifiCommandFactory.java          | 26 +++++++++++++++++++++-
 1 file changed, 25 insertions(+), 1 deletion(-)

diff --git 
a/minifi/minifi-toolkit/minifi-toolkit-configuration/src/main/java/org/apache/nifi/minifi/toolkit/configuration/json/TransformNifiCommandFactory.java
 
b/minifi/minifi-toolkit/minifi-toolkit-configuration/src/main/java/org/apache/nifi/minifi/toolkit/configuration/json/TransformNifiCommandFactory.java
index 01edccb199..61b289061e 100644
--- 
a/minifi/minifi-toolkit/minifi-toolkit-configuration/src/main/java/org/apache/nifi/minifi/toolkit/configuration/json/TransformNifiCommandFactory.java
+++ 
b/minifi/minifi-toolkit/minifi-toolkit-configuration/src/main/java/org/apache/nifi/minifi/toolkit/configuration/json/TransformNifiCommandFactory.java
@@ -23,6 +23,10 @@ import java.io.OutputStream;
 import java.util.ArrayList;
 
 import org.apache.nifi.controller.flow.VersionedDataflow;
+import org.apache.nifi.flow.ScheduledState;
+import org.apache.nifi.flow.VersionedProcessGroup;
+import org.apache.nifi.flow.VersionedRemoteGroupPort;
+import org.apache.nifi.flow.VersionedRemoteProcessGroup;
 import org.apache.nifi.minifi.toolkit.configuration.ConfigMain;
 import org.apache.nifi.minifi.toolkit.configuration.ConfigTransformException;
 import org.apache.nifi.minifi.toolkit.configuration.PathInputStreamFactory;
@@ -65,7 +69,7 @@ public class TransformNifiCommandFactory {
             VersionedDataflow versionedDataflow = new VersionedDataflow();
             
versionedDataflow.setRootGroup(registeredFlowSnapshot.getFlowContents());
             versionedDataflow.setParameterContexts(new 
ArrayList<>(registeredFlowSnapshot.getParameterContexts().values()));
-            
versionedDataflow.setMaxTimerDrivenThreadCount(CorePropertiesSchema.DEFAULT_MAX_CONCURRENT_THREADS);
+            setDefaultValues(versionedDataflow);
 
             persistFlowJson(versionedDataflow, targetMiNiFiJsonPath);
         } catch (ConfigTransformException e) {
@@ -101,4 +105,24 @@ public class TransformNifiCommandFactory {
                     ConfigMain.ERR_UNABLE_TO_SAVE_CONFIG, e);
         }
     }
+
+    private void setDefaultValues(VersionedDataflow versionedDataflow) {
+        
versionedDataflow.setMaxTimerDrivenThreadCount(CorePropertiesSchema.DEFAULT_MAX_CONCURRENT_THREADS);
+        setDefaultValues(versionedDataflow.getRootGroup());
+    }
+
+    private void setDefaultValues(VersionedProcessGroup versionedProcessGroup) 
{
+        
versionedProcessGroup.getRemoteProcessGroups().forEach(this::setDefaultValues);
+        
versionedProcessGroup.getProcessGroups().forEach(this::setDefaultValues);
+    }
+
+    private void setDefaultValues(VersionedRemoteProcessGroup 
versionedRemoteProcessGroup) {
+        
versionedRemoteProcessGroup.getInputPorts().forEach(this::setDefaultValues);
+    }
+
+    private void setDefaultValues(VersionedRemoteGroupPort 
versionedRemoteGroupPort) {
+        versionedRemoteGroupPort.setScheduledState(ScheduledState.RUNNING);
+    }
+
+
 }