Tom Kujala created FLUME-2656:
---------------------------------
Summary: avro sink reset-connection-interval not respected
Key: FLUME-2656
URL: https://issues.apache.org/jira/browse/FLUME-2656
Project: Flume
Issue Type: Bug
Components: Sinks+Sources
Affects Versions: v1.4.0, v1.5.2
Reporter: Tom Kujala
Priority: Minor
When the reset-connection-interval is set on the avro sink and the destination
source goes down, additional reset intervals are added. This can be traced to
the AbstractRpcSink class, specifically the calls to verifyConnection() from
process(). When verifyConnection() is called, it in turn calls
createConnection(), which schedules another reset, in addition to any that are
already scheduled. If the destination source is down for any extended period of
time, the number of scheduled resets can grow pretty large requiring Flume to
be restarted.
Instead, new reset threads should only be scheduled as the result of another
reset thread or at initialization.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
