AMBARI-24386 - [Log Search] Input config validator unable to parse an…

…y log entry (apache#1923)
kasakrisz · Jul 31, 2018 · 7a4ecb8 · 7a4ecb8
1 parent 26a48ea
commit 7a4ecb8
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/...earch-logfeeder/src/main/java/org/apache/ambari/logfeeder/common/LogEntryParseTester.java b/...earch-logfeeder/src/main/java/org/apache/ambari/logfeeder/common/LogEntryParseTester.java
@@ -25,6 +25,7 @@
 import java.util.List;
 import java.util.Map;
 
+import org.apache.ambari.logfeeder.conf.LogEntryCacheConfig;
 import org.apache.ambari.logfeeder.conf.LogFeederProps;
 import org.apache.ambari.logfeeder.input.InputFileMarker;
 import org.apache.ambari.logfeeder.input.InputManagerImpl;
@@ -82,13 +83,20 @@ public Map<String, Object> parse() throws Exception {
     ConfigHandler configHandler = new ConfigHandler(null);
     configHandler.setInputManager(new InputManagerImpl());
     OutputManagerImpl outputManager = new OutputManagerImpl();
+    LogFeederProps logFeederProps = new LogFeederProps();
+    LogEntryCacheConfig logEntryCacheConfig = new LogEntryCacheConfig();
+    logEntryCacheConfig.setCacheEnabled(false);
+    logEntryCacheConfig.setCacheSize(0);
+    logFeederProps.setLogEntryCacheConfig(logEntryCacheConfig);
+    outputManager.setLogFeederProps(logFeederProps);
     LogLevelFilterHandler logLevelFilterHandler = new LogLevelFilterHandler(null);
-    logLevelFilterHandler.setLogFeederProps(new LogFeederProps());
+    logLevelFilterHandler.setLogFeederProps(logFeederProps);
     outputManager.setLogLevelFilterHandler(logLevelFilterHandler);
     configHandler.setOutputManager(outputManager);
     Input input = configHandler.getTestInput(inputConfig, logId);
+    input.init(logFeederProps);
     final Map<String, Object> result = new HashMap<>();
-    input.getFirstFilter().init(new LogFeederProps());
+    input.getFirstFilter().init(logFeederProps);
     input.addOutput(new Output<LogFeederProps, InputFileMarker>() {
       @Override
       public void init(LogFeederProps logFeederProperties) throws Exception {