Repository: ambari Updated Branches: refs/heads/trunk 3c9f125cc -> c0882898d
AMBARI-21210 ADDENDUM Add ability to Log Search to test a log entry if it is parseable (mgergely) Change-Id: Icb847dc5cc9b6f63eb02cffe8046c78be0e585dc Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/c0882898 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/c0882898 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/c0882898 Branch: refs/heads/trunk Commit: c0882898deed4b6f0ecbd6f12cd935dc6b75cfdf Parents: 3c9f125 Author: Miklos Gergely <mgerg...@hortonworks.com> Authored: Mon Jul 10 14:45:41 2017 +0200 Committer: Miklos Gergely <mgerg...@hortonworks.com> Committed: Mon Jul 10 14:45:41 2017 +0200 ---------------------------------------------------------------------- .../org/apache/ambari/logfeeder/common/LogEntryParseTester.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/c0882898/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/common/LogEntryParseTester.java ---------------------------------------------------------------------- diff --git a/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/common/LogEntryParseTester.java b/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/common/LogEntryParseTester.java index 97bc3a2..5356159 100644 --- a/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/common/LogEntryParseTester.java +++ b/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/common/LogEntryParseTester.java @@ -76,7 +76,7 @@ public class LogEntryParseTester { ConfigHandler configHandler = new ConfigHandler(); Input input = configHandler.getTestInput(inputConfig, logId); final Map<String, Object> result = new HashMap<>(); - input.init(); + input.getFirstFilter().init(); input.addOutput(new Output() { @Override public void write(String block, InputMarker inputMarker) throws Exception {