[
https://issues.apache.org/jira/browse/FLUME-1121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13252996#comment-13252996
]
Hari Shreedharan commented on FLUME-1121:
-----------------------------------------
Seems like this is because start() never gets called for a channel from the
configuration provider implementations. They start only sources and sinks. Even
if I somehow managed to start it, by adding start calls in the properties file
config provider, there are other issues. The replay function tries to load all
events into the internal memory channel, but if there are more than n events(n
= size of memory channel), due to multiple previous failures or as a result of
reconfiguration, the start() throws an exception and the remaining events in
the backing file are not picked up. Also I used a seq source to generate some
107 events, with a channel of size 100, and no sinks. I expected that only 100
would go to the file, but the next time it starts up, it tries to load all 107
and fails and throws exceptions.
> Recoverable Memory Channel cannot recover data
> -----------------------------------------------
>
> Key: FLUME-1121
> URL: https://issues.apache.org/jira/browse/FLUME-1121
> Project: Flume
> Issue Type: Bug
> Components: Sinks+Sources
> Affects Versions: v1.2.0
> Reporter: Hari Shreedharan
>
> Run an agent with a source, like seq with a recoverable memory channel and no
> sink. kill the process with ctrl-C. Run an agent now with no source, but
> logger sink and the same recoverable memory channel. I expected the events
> generated by the source earlier should be written to the sink, but no events
> with picked up.
--
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
