You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flume.apache.org by "Benjamin Fiorini (JIRA)" <ji...@apache.org> on 2014/04/08 12:24:15 UTC

[jira] [Created] (FLUME-2355) Exception in process of Avro sink does not reset the cxnResetExecutor

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)