Github user merrimanr commented on a diff in the pull request:

    https://github.com/apache/metron/pull/1213#discussion_r220995913
  
    --- Diff: 
metron-platform/metron-parsers/src/test/java/org/apache/metron/parsers/integration/ParserDriver.java
 ---
    @@ -83,49 +86,21 @@ public void close() throws Exception {
         List<byte[]> errors = new ArrayList<>();
     
         public ShimParserBolt(List<byte[]> output) {
    -      super(null
    -          , Collections.singletonMap(
    -              sensorType == null ? config.getSensorTopic() : sensorType,
    -              new ParserComponents(
    -              ReflectionUtils.createInstance(config.getParserClassName()),
    -                  null,
    -                  new WriterHandler(new CollectingWriter(output))
    -              )
    -         )
    -      );
    +      super(null, parserRunner, Collections.singletonMap(sensorType, new 
WriterHandler(new CollectingWriter(output))));
    --- End diff --
    
    Not sure this ShimParserBolt is necessary anymore.


---

Reply via email to