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();