Repository: ranger Updated Branches: refs/heads/ranger-1.2 01d94239e -> 76c90c8d9
RANGER-2249:Ranger Audit not flushed immediately to hdfs Signed-off-by: rmani <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/ranger/repo Commit: http://git-wip-us.apache.org/repos/asf/ranger/commit/76c90c8d Tree: http://git-wip-us.apache.org/repos/asf/ranger/tree/76c90c8d Diff: http://git-wip-us.apache.org/repos/asf/ranger/diff/76c90c8d Branch: refs/heads/ranger-1.2 Commit: 76c90c8d9e772b37579b6f756bb12c695f2a369f Parents: 01d9423 Author: rmani <[email protected]> Authored: Thu Oct 11 17:51:11 2018 -0700 Committer: rmani <[email protected]> Committed: Fri Oct 12 10:43:29 2018 -0700 ---------------------------------------------------------------------- .../org/apache/ranger/audit/destination/HDFSAuditDestination.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ranger/blob/76c90c8d/agents-audit/src/main/java/org/apache/ranger/audit/destination/HDFSAuditDestination.java ---------------------------------------------------------------------- diff --git a/agents-audit/src/main/java/org/apache/ranger/audit/destination/HDFSAuditDestination.java b/agents-audit/src/main/java/org/apache/ranger/audit/destination/HDFSAuditDestination.java index 66d8504..01fc5e7 100644 --- a/agents-audit/src/main/java/org/apache/ranger/audit/destination/HDFSAuditDestination.java +++ b/agents-audit/src/main/java/org/apache/ranger/audit/destination/HDFSAuditDestination.java @@ -178,7 +178,7 @@ public class HDFSAuditDestination extends AuditDestination { } finally { logger.info("Flushing HDFS audit. Event Size:" + events.size()); if (out != null) { - out.flush(); + flush(); } } addSuccessCount(events.size());
