You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by st...@apache.org on 2016/03/24 13:08:57 UTC
[25/51] [abbrv] ambari git commit: Operation message fix for service
start and stop
Operation message fix for service start and stop
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/bc8ea681
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/bc8ea681
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/bc8ea681
Branch: refs/heads/audit_logging
Commit: bc8ea681c30ae9099ac4cc4f964844cfa58c04c7
Parents: b644807
Author: Daniel Gergely <dg...@hortonworks.com>
Authored: Mon Feb 29 17:01:26 2016 +0100
Committer: Toader, Sebastian <st...@hortonworks.com>
Committed: Thu Mar 24 13:06:48 2016 +0100
----------------------------------------------------------------------
.../audit/request/eventcreator/ServiceEventCreator.java | 9 +++++++++
1 file changed, 9 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ambari/blob/bc8ea681/ambari-server/src/main/java/org/apache/ambari/server/audit/request/eventcreator/ServiceEventCreator.java
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/java/org/apache/ambari/server/audit/request/eventcreator/ServiceEventCreator.java b/ambari-server/src/main/java/org/apache/ambari/server/audit/request/eventcreator/ServiceEventCreator.java
index 352c3d0..09a8f89 100644
--- a/ambari-server/src/main/java/org/apache/ambari/server/audit/request/eventcreator/ServiceEventCreator.java
+++ b/ambari-server/src/main/java/org/apache/ambari/server/audit/request/eventcreator/ServiceEventCreator.java
@@ -132,6 +132,15 @@ public class ServiceEventCreator implements RequestAuditEventCreator {
}
}
}
+ if("SERVICE".equals(request.getBody().getRequestInfoProperties().get(RequestOperationLevel.OPERATION_LEVEL_ID))) {
+ for (Map<String, Object> map : request.getBody().getPropertySets()) {
+ if (map.containsKey(PropertyHelper.getPropertyId("ServiceInfo", "state"))) {
+ operation = String.valueOf(map.get(PropertyHelper.getPropertyId("ServiceInfo", "state"))) + ": " + map.get(PropertyHelper.getPropertyId("ServiceInfo", "service_name"))
+ + " (" + request.getBody().getRequestInfoProperties().get(RequestOperationLevel.OPERATION_CLUSTER_ID) + ")";
+ break;
+ }
+ }
+ }
return operation;
}