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 <[email protected]>
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 <[email protected]>
---
.../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();
