Benjamin Fiorini created FLUME-2355:
---------------------------------------
Summary: Exception in process of Avro sink does not reset the
cxnResetExecutor
Key: FLUME-2355
URL: https://issues.apache.org/jira/browse/FLUME-2355
Project: Flume
Issue Type: Bug
Components: Sinks+Sources
Affects Versions: v1.4.0
Reporter: Benjamin Fiorini
In the AbstractRpcSink, when an exception occurs during the process, say a
timeout, the connection is destroyed. But when the connection is created again,
*a new* cxnResetExecutor is scheduled. The first one being still scheduled,
this may result in many jobs reseting the connection far too often.
I suppose the createConnection should take care of shutting down any existing
reset job before creating new ones.
--
This message was sent by Atlassian JIRA
(v6.2#6252)
