[
https://issues.apache.org/jira/browse/FLUME-2942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15794265#comment-15794265
]
Laxman edited comment on FLUME-2942 at 1/3/17 6:11 AM:
-------------------------------------------------------
Thanks [~sebalf] for the update. Will review and try to verify soon.
Can you please post the complete configuration you used to verify this patch.
Similar to the one you posted earlier in this issue.
was (Author: lakshman):
Thanks [~sebalf] for the update. Will review and try to verify soon.
> AvroEventDeserializer ignores header from spool source
> ------------------------------------------------------
>
> Key: FLUME-2942
> URL: https://issues.apache.org/jira/browse/FLUME-2942
> Project: Flume
> Issue Type: Bug
> Affects Versions: v1.6.0
> Reporter: Sebastian Alfers
> Attachments: FLUME-2942-0.patch
>
>
> I have a spool file source and use avro for de-/serialization
> In detail, serialized events store the topic of the kafka sink in the header.
> When I load the events from the spool directory, the header are ignored.
> Please see:
> https://github.com/apache/flume/blob/caa64a1a6d4bc97be5993cb468516e9ffe862794/flume-ng-core/src/main/java/org/apache/flume/serialization/AvroEventDeserializer.java#L122
> You can see, it uses the whole event as body but does not distinguish between
> the header and body encoded by avro.
> Please verify that this is a bug.
> I fixed this but by using the record that stores header and body separately.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
