Skip to content

Commit

Permalink
NIFI-13789: Fixed StatelessFlowManager so that it registers any Proce…
Browse files Browse the repository at this point in the history
…ss Group that it creates in its internal map in the same way that StandardFlowManager does; this ensures that the Process Group can be retrieved by ID during flow synchronization.
  • Loading branch information
markap14 committed Sep 22, 2024
1 parent 6ddae78 commit af6e38f
Showing 1 changed file with 5 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,6 @@
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javax.net.ssl.SSLContext;
import java.net.URL;
import java.util.ArrayList;
import java.util.Collection;
Expand All @@ -86,6 +85,7 @@
import java.util.Set;
import java.util.concurrent.TimeUnit;
import java.util.function.BooleanSupplier;
import javax.net.ssl.SSLContext;

import static java.util.Objects.requireNonNull;

Expand Down Expand Up @@ -221,7 +221,7 @@ public Port createLocalOutputPort(final String id, final String name) {

@Override
public ProcessGroup createProcessGroup(final String id) {
return new StandardProcessGroup(id, statelessEngine.getControllerServiceProvider(),
final ProcessGroup created = new StandardProcessGroup(id, statelessEngine.getControllerServiceProvider(),
statelessEngine.getProcessScheduler(),
statelessEngine.getPropertyEncryptor(),
statelessEngine.getExtensionManager(),
Expand All @@ -232,6 +232,9 @@ public ProcessGroup createProcessGroup(final String id) {
null,
group -> null,
statelessEngine.getAssetManager());

onProcessGroupAdded(created);
return created;
}

@Override
Expand Down

0 comments on commit af6e38f

Please sign in to comment.