You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by al...@apache.org on 2018/07/12 01:31:14 UTC
[06/10] nifi git commit: NIFI-5362: When a processor is terminated
and has no more active threads,
ensure that we set this.hasActiveThreads = false
NIFI-5362: When a processor is terminated and has no more active threads, ensure that we set this.hasActiveThreads = false
Signed-off-by: Pierre Villard <pi...@gmail.com>
This closes #2832.
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/cfdb0de8
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/cfdb0de8
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/cfdb0de8
Branch: refs/heads/support/nifi-1.7.x
Commit: cfdb0de8f83c3e7d732cac6a5d18b2f1631d20e5
Parents: e09ab9b
Author: Mark Payne <ma...@hotmail.com>
Authored: Mon Jul 2 10:00:38 2018 -0400
Committer: Andy LoPresto <al...@apache.org>
Committed: Wed Jul 11 18:29:37 2018 -0700
----------------------------------------------------------------------
.../main/java/org/apache/nifi/controller/StandardProcessorNode.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/cfdb0de8/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardProcessorNode.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardProcessorNode.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardProcessorNode.java
index 413f097..c2b98e6 100644
--- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardProcessorNode.java
+++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardProcessorNode.java
@@ -1453,6 +1453,7 @@ public class StandardProcessorNode extends ProcessorNode implements Connectable
getLogger().terminate();
scheduledState.set(ScheduledState.STOPPED);
+ hasActiveThreads = false;
return count;
}