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 2022/04/04 18:29:16 UTC
[nifi] 21/31: NIFI-9824 - Address WARN log message in ProcessorAuditor on action RunOnce
This is an automated email from the ASF dual-hosted git repository.
joewitt pushed a commit to branch support/nifi-1.16
in repository https://gitbox.apache.org/repos/asf/nifi.git
commit e430349be5643096c2140721e6ecda676b0e4960
Author: Paul Grey <gr...@yahoo.com>
AuthorDate: Wed Mar 23 11:13:31 2022 -0400
NIFI-9824 - Address WARN log message in ProcessorAuditor on action RunOnce
This closes #5890
Signed-off-by: David Handermann <ex...@apache.org>
---
nifi-api/src/main/java/org/apache/nifi/action/Operation.java | 3 ++-
.../src/main/java/org/apache/nifi/audit/ProcessorAuditor.java | 2 ++
2 files changed, 4 insertions(+), 1 deletion(-)
diff --git a/nifi-api/src/main/java/org/apache/nifi/action/Operation.java b/nifi-api/src/main/java/org/apache/nifi/action/Operation.java
index 99b9495573..1a199c5249 100644
--- a/nifi-api/src/main/java/org/apache/nifi/action/Operation.java
+++ b/nifi-api/src/main/java/org/apache/nifi/action/Operation.java
@@ -39,7 +39,8 @@ public enum Operation {
StopVersionControl("Stop Version Control"),
CommitLocalChanges("Commit Local Changes"),
RevertLocalChanges("Revert Local Changes"),
- ChangeVersion("Change Version");
+ ChangeVersion("Change Version"),
+ RunOnce("RunOnce");
private final String label;
diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/audit/ProcessorAuditor.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/audit/ProcessorAuditor.java
index 4345b64c4c..50b132f0cd 100644
--- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/audit/ProcessorAuditor.java
+++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/audit/ProcessorAuditor.java
@@ -263,6 +263,8 @@ public class ProcessorAuditor extends NiFiAuditor {
processorAction.setOperation(Operation.Stop);
} else if (ScheduledState.DISABLED.equals(scheduledState)) {
processorAction.setOperation(Operation.Enable);
+ } else if (ScheduledState.STOPPED.equals(scheduledState)) {
+ processorAction.setOperation(Operation.RunOnce);
}
}
actions.add(processorAction);