[
https://issues.apache.org/jira/browse/FLUME-312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Lorenz-Alten resolved FLUME-312.
------------------------------------------
Resolution: Won't Fix
> agentDFOSink returns attempt failed.
> ------------------------------------
>
> Key: FLUME-312
> URL: https://issues.apache.org/jira/browse/FLUME-312
> Project: Flume
> Issue Type: Bug
> Affects Versions: v0.9.4
> Reporter: Anurag Phadke
>
> h1: exec("/usr/bin/perl /home/aphadke/buildbot/rpc.pl",false,true,30000) |
> agentDFOSink("h2",35853);
> h2 : collectorSource(35853) |
> collectorSink("hdfs://h3/flume/%{host}/%Y-%m-%d/%H","build-logs");
> The above config returns following error on h1:
> 10/11/03 10:49:45 INFO thrift.ThriftEventSink: ThriftEventSink on port 35853
> closed
> 10/11/03 10:49:45 INFO diskfailover.DiskFailoverSource: end of file
> com.cloudera.flume.agent.diskfailover.NaiveFileFailoverManager$StateChangeDeco@6d581e80
> 10/11/03 10:49:45 INFO diskfailover.NaiveFileFailoverManager: opening new
> file for log.00000025.20101103-104921136-0700.4302031757228167.seq
> 10/11/03 10:49:45 INFO debug.StubbornAppendSink: Opening Stubborn Append Sink
> com.cloudera.flume.handlers.debug.StubbornAppendSink@154e45b3
> 10/11/03 10:49:45 INFO debug.InsistentOpenDecorator: open attempt 0 failed,
> backoff (1000ms): Failed to open thrift event sink at h2:35853 :
> java.net.ConnectException: Connection refused
> 10/11/03 10:49:46 INFO debug.InsistentOpenDecorator: open attempt 1 failed,
> backoff (2000ms): Failed to open thrift event sink at h2:35853 :
> java.net.ConnectException: Connection refused
> 10/11/03 10:49:48 INFO debug.InsistentOpenDecorator: open attempt 2 failed,
> backoff (4000ms): Failed to open thrift event sink at h2:35853 :
> java.net.ConnectException: Connection refused
> 10/11/03 10:49:52 INFO debug.InsistentOpenDecorator: open attempt 3 failed,
> backoff (8000ms): Failed to open thrift event sink at h2:35853 :
> java.net.ConnectException: Connection refused
> 10/11/03 10:49:55 INFO hdfs.SeqfileEventSink: closed
> /tmp/flume/agent/h1/dfo_writing/log.00000019.20101103-104945436-0700.4302056056679167.seq
> 10/11/03 10:49:55 INFO diskfailover.NaiveFileFailoverManager: File lives in
> /tmp/flume/agent/h1/dfo_writing/log.00000019.20101103-104945436-0700.4302056056679167.seq
> 10/11/03 10:49:55 INFO hdfs.SeqfileEventSink: constructed new seqfile event
> sink:
> file=/tmp/flume/agent/h1/dfo_writing/log.00000025.20101103-104955517-0700.4302066137680167.seq
> Any idea why h1 is trying to open port 35853 and failing? Do I need to add
> something to my config?
--
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
