[
https://issues.apache.org/jira/browse/FLUME-931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juhani Connolly updated FLUME-931:
----------------------------------
Attachment: flume-931.patch
Posted a properly working version.
The previous version had a couple thread synchronisation issues that should be
fixed in this.
Also changed the headers on both file to the apache header. However, the
cursor.java is actually more or less the same as the one from OG(the only real
change are with the packaging of events), so I'm not entirely sure of what the
proper header for that is?
Also added in multiple file support.
Things not implemented that were in OG:
- Custom delimiters
- directory tailing
An area of concern that remains is with the handling of interrupts:
- In process() i'm currently just returning Status.BACKOFF if the poll gets
interrupted but thinking this may have to be changed to an
EventDeliveryException. I'm not particularly happy with either choice though
and would be curious of other peoples opionions on the matter.
> Flume NG TailSource
> -------------------
>
> Key: FLUME-931
> URL: https://issues.apache.org/jira/browse/FLUME-931
> Project: Flume
> Issue Type: Improvement
> Components: Sinks+Sources
> Reporter: Juhani Connolly
> Fix For: v1.1.0
>
> Attachments: flume-931.patch, flume-tail.patch
>
>
> Flume NG currently doesn't have a TailSource as existed in OG
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
