You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ex...@apache.org on 2022/03/30 15:31:05 UTC
[nifi] branch main updated: NIFI-9824 - Address WARN log message in ProcessorAuditor on action RunOnce
This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new cd0b289 NIFI-9824 - Address WARN log message in ProcessorAuditor on action RunOnce
cd0b289 is described below
commit cd0b289146cc4a2d893a58adebd3dca013a866a0
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 99b9495..1a199c5 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 4345b64..50b132f 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);