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.
---