You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ma...@apache.org on 2024/03/04 21:28:06 UTC
(nifi) branch support/nifi-1.x updated: NIFI-12645 Fix to correctly invoke onStopped method of scripted processor
This is an automated email from the ASF dual-hosted git repository.
mattyb149 pushed a commit to branch support/nifi-1.x
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/support/nifi-1.x by this push:
new 7f2f5e77f6 NIFI-12645 Fix to correctly invoke onStopped method of scripted processor
7f2f5e77f6 is described below
commit 7f2f5e77f65af1d688330092b4df9747f68ade50
Author: Jim Steinebrey <jr...@gmail.com>
AuthorDate: Mon Mar 4 13:29:12 2024 -0500
NIFI-12645 Fix to correctly invoke onStopped method of scripted processor
Signed-off-by: Matt Burgess <ma...@apache.org>
---
.../java/org/apache/nifi/processors/script/InvokeScriptedProcessor.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/processors/script/InvokeScriptedProcessor.java b/nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/processors/script/InvokeScriptedProcessor.java
index 5e083e7b74..a7b1d8508e 100644
--- a/nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/processors/script/InvokeScriptedProcessor.java
+++ b/nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/processors/script/InvokeScriptedProcessor.java
@@ -606,7 +606,7 @@ public class InvokeScriptedProcessor extends AbstractSessionFactoryProcessor {
@OnStopped
public void stop(ProcessContext context) {
// If the script needs to be reloaded at this point, it is because it was empty
- if (!scriptNeedsReload.get()) {
+ if (scriptRunner != null) {
invokeScriptedProcessorMethod("onStopped", context);
}
scriptingComponentHelper.stop();