You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flume.apache.org by "Ashish Paliwal (JIRA)" <ji...@apache.org> on 2014/11/05 09:25:34 UTC
[jira] [Resolved] (FLUME-312) agentDFOSink returns attempt failed.
[ https://issues.apache.org/jira/browse/FLUME-312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ashish Paliwal resolved FLUME-312.
----------------------------------
Resolution: Won't Fix
Fix Version/s: v0.9.5
Won't fix. 0.X branch not maintained anymore
> 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
> Fix For: v0.9.5
>
>
> 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 was sent by Atlassian JIRA
(v6.3.4#6332)