Github user mmiklavc commented on a diff in the pull request:
https://github.com/apache/metron/pull/1184#discussion_r223827440
--- Diff:
metron-platform/metron-parsers/src/main/java/org/apache/metron/parsers/bolt/ParserBolt.java
---
@@ -383,7 +408,7 @@ public void execute(Tuple tuple) {
}
}
- protected void handleError(byte[] originalMessage, Tuple tuple,
Throwable ex, OutputCollector collector) {
+ protected void handleError(Object originalMessage, Tuple tuple,
Throwable ex, OutputCollector collector) {
--- End diff --
Does this need to be relaxed to Object? It looks to me like byte[] is still
used everywhere for original message.
---
