You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by jo...@apache.org on 2020/02/14 18:31:36 UTC
[nifi] 03/14: NIFI-6958: - Addressing issue causing errors
preventing version changes when there is a processor to enable or disable
in a sub process group.
This is an automated email from the ASF dual-hosted git repository.
joewitt pushed a commit to branch support/nifi-1.11.x
in repository https://gitbox.apache.org/repos/asf/nifi.git
commit b485d0e26b22c8879f7e8ad55b0b0851e5946490
Author: Matt Gilman <ma...@gmail.com>
AuthorDate: Wed Feb 5 12:49:01 2020 -0500
NIFI-6958:
- Addressing issue causing errors preventing version changes when there is a processor to enable or disable in a sub process group.
---
.../src/main/java/org/apache/nifi/groups/StandardProcessGroup.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/groups/StandardProcessGroup.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/groups/StandardProcessGroup.java
index fbcf664..dedb6a9 100644
--- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/groups/StandardProcessGroup.java
+++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/groups/StandardProcessGroup.java
@@ -4633,9 +4633,9 @@ public final class StandardProcessGroup implements ProcessGroup {
processor.setPosition(new Position(proposed.getPosition().getX(), proposed.getPosition().getY()));
if (proposed.getScheduledState() == org.apache.nifi.registry.flow.ScheduledState.DISABLED) {
- disableProcessor(processor);
+ processor.getProcessGroup().disableProcessor(processor);
} else if (processor.getScheduledState() == ScheduledState.DISABLED) {
- enableProcessor(processor);
+ processor.getProcessGroup().enableProcessor(processor);
}
if (!isEqual(processor.getBundleCoordinate(), proposed.getBundle())) {