Return-Path: 
 <user-return-7159-apmail-flume-user-archive=flume.apache.org@flume.apache.org>
X-Original-To: apmail-flume-user-archive@www.apache.org
Delivered-To: apmail-flume-user-archive@www.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id 37C911816D
	for <apmail-flume-user-archive@www.apache.org>;
 Fri,  2 Oct 2015 10:37:47 +0000 (UTC)
Received: (qmail 83165 invoked by uid 500); 2 Oct 2015 10:37:46 -0000
Delivered-To: apmail-flume-user-archive@flume.apache.org
Received: (qmail 83108 invoked by uid 500); 2 Oct 2015 10:37:46 -0000
Mailing-List: contact user-help@flume.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:user-help@flume.apache.org>
List-Unsubscribe: <mailto:user-unsubscribe@flume.apache.org>
List-Post: <mailto:user@flume.apache.org>
List-Id: <user.flume.apache.org>
Reply-To: user@flume.apache.org
Delivered-To: mailing list user@flume.apache.org
Received: (qmail 83098 invoked by uid 99); 2 Oct 2015 10:37:46 -0000
Received: from Unknown (HELO spamd1-us-west.apache.org) (209.188.14.142)
    by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 02 Oct 2015 10:37:46 +0000
Received: from localhost (localhost [127.0.0.1])
	by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org)
 with ESMTP id 562F8C155F
	for <user@flume.apache.org>; Fri,  2 Oct 2015 10:37:46 +0000 (UTC)
X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org
X-Spam-Flag: NO
X-Spam-Score: 3.129
X-Spam-Level: ***
X-Spam-Status: No, score=3.129 tagged_above=-999 required=6.31
	tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1,
	FREEMAIL_ENVFROM_END_DIGIT=0.25, HTML_MESSAGE=3,
	RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001]
	autolearn=disabled
Authentication-Results: spamd1-us-west.apache.org (amavisd-new);
	dkim=pass (2048-bit key) header.d=gmail.com
Received: from mx1-us-east.apache.org ([10.40.0.8])
	by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new,
 port 10024)
	with ESMTP id CisDWy4fUBPH for <user@flume.apache.org>;
	Fri,  2 Oct 2015 10:37:45 +0000 (UTC)
Received: from mail-wi0-f179.google.com (mail-wi0-f179.google.com
 [209.85.212.179])
	by mx1-us-east.apache.org (ASF Mail Server at mx1-us-east.apache.org) with
 ESMTPS id 5209E42B2F
	for <user@flume.apache.org>; Fri,  2 Oct 2015 10:37:45 +0000 (UTC)
Received: by wiclk2 with SMTP id lk2so25292660wic.1
        for <user@flume.apache.org>; Fri, 02 Oct 2015 03:37:44 -0700 (PDT)
DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
        d=gmail.com; s=20120113;
        h=mime-version:from:date:message-id:subject:to:content-type;
        bh=5aD3xIBpqh+Q/akkDfrH77bMFADxEZN03XNo7pD+iSA=;
        b=wBmhVtcqK+u2gsD1OFIV5WSISmWTr5xtbRv+5k69W8mt3oDP5PmUzh0QjrbhY6XYE8
         KZZXK9tEpwZ1nb8MGYAm64P7ENhIM4R3mSFqHGWtinCPd7xRqLTSEHemjApA6snkrAiC
         AbO6Fz107iL+zjWrbnyEXFcB11GKDhqszO1KFYt3VfeKC02uulCdBz0aczIKWmX3mbko
         xOMXl54RQed2xAI8eeejAuJ4GnqUA+/79vjmu4mNgUp36+bCtRjPAlfpDDDDeuDxU5ci
         eIQiMaYphpGEMNQ0PgOqiipvq1M1E/KH2cmx2y8ro38BBzdit2HRM4O60UbarX5Mqywk
         3Dmw==
X-Received: by 10.180.188.47 with SMTP id fx15mr3423922wic.41.1443782264309;
 Fri, 02 Oct 2015 03:37:44 -0700 (PDT)
MIME-Version: 1.0
Received: by 10.194.116.74 with HTTP; Fri, 2 Oct 2015 03:37:04 -0700 (PDT)
From: Simone Roselli <simoneroselli78@gmail.com>
Date: Fri, 2 Oct 2015 12:37:04 +0200
Message-ID: 
 <CAH34K+kt5k+RfiQ+pwUdw50oNgX6AMVB+apNbo9-MJAwA1C9EA@mail.gmail.com>
Subject: Flume-ng 1.6 - Got an IOException during write
To: user@flume.apache.org
Content-Type: multipart/alternative; boundary=001a11c37b36ff4d8605211cc0bc

--001a11c37b36ff4d8605211cc0bc
Content-Type: text/plain; charset=UTF-8

Hi,

I get this warning from the Thrift source on a file-channel configuration:

WARN  [Thread-2]
(org.apache.thrift.server.AbstractNonblockingServer$FrameBuffer.write:385)
 - Got an IOException during write!
java.io.IOException: Broken pipe
at sun.nio.ch.FileDispatcherImpl.write0(Native Method)
at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:47)
at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:93)
at sun.nio.ch.IOUtil.write(IOUtil.java:65)
at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:488)
at
org.apache.thrift.transport.TNonblockingSocket.write(TNonblockingSocket.java:164)
at
org.apache.thrift.server.AbstractNonblockingServer$FrameBuffer.write(AbstractNonblockingServer.java:381)
at
org.apache.thrift.server.AbstractNonblockingServer$AbstractSelectThread.handleWrite(AbstractNonblockingServer.java:220)
at
org.apache.thrift.server.TThreadedSelectorServer$SelectorThread.select(TThreadedSelectorServer.java:579)
at
org.apache.thrift.server.TThreadedSelectorServer$SelectorThread.run(TThreadedSelectorServer.java:536)

I don't fully understand whether this could come from any wrong
configuration

# Channel configuration
agent1.channels.ch1.type = file
agent1.channels.ch1.checkpointDir = /opt/flume-ng/chekpoint
agent1.channels.ch1.dataDirs = /opt/flume-ng/data

# Source
agent1.sources.thriftSrc.type = thrift
agent1.sources.thriftSrc.channels = ch1
agent1.sources.thriftSrc.bind = 0.0.0.0
agent1.sources.thriftSrc.port = 4042


Thanks
Simone

--001a11c37b36ff4d8605211cc0bc
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr">Hi,<div><br></div><div>I get this warning from the Thrift =
source on a file-channel configuration:</div><div><br></div><div><div>WARN =
=C2=A0[Thread-2] (org.apache.thrift.server.AbstractNonblockingServer$FrameB=
uffer.write:385) =C2=A0- Got an IOException during write!</div><div>java.io=
.IOException: Broken pipe</div><div><span class=3D"" style=3D"white-space:p=
re">	</span>at sun.nio.ch.FileDispatcherImpl.write0(Native Method)</div><di=
v><span class=3D"" style=3D"white-space:pre">	</span>at sun.nio.ch.SocketDi=
spatcher.write(SocketDispatcher.java:47)</div><div><span class=3D"" style=
=3D"white-space:pre">	</span>at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOU=
til.java:93)</div><div><span class=3D"" style=3D"white-space:pre">	</span>a=
t sun.nio.ch.IOUtil.write(IOUtil.java:65)</div><div><span class=3D"" style=
=3D"white-space:pre">	</span>at sun.nio.ch.SocketChannelImpl.write(SocketCh=
annelImpl.java:488)</div><div><span class=3D"" style=3D"white-space:pre">	<=
/span>at org.apache.thrift.transport.TNonblockingSocket.write(TNonblockingS=
ocket.java:164)</div><div><span class=3D"" style=3D"white-space:pre">	</spa=
n>at org.apache.thrift.server.AbstractNonblockingServer$FrameBuffer.write(A=
bstractNonblockingServer.java:381)</div><div><span class=3D"" style=3D"whit=
e-space:pre">	</span>at org.apache.thrift.server.AbstractNonblockingServer$=
AbstractSelectThread.handleWrite(AbstractNonblockingServer.java:220)</div><=
div><span class=3D"" style=3D"white-space:pre">	</span>at org.apache.thrift=
.server.TThreadedSelectorServer$SelectorThread.select(TThreadedSelectorServ=
er.java:579)</div><div><span class=3D"" style=3D"white-space:pre">	</span>a=
t org.apache.thrift.server.TThreadedSelectorServer$SelectorThread.run(TThre=
adedSelectorServer.java:536)</div></div><div><br></div><div>I don&#39;t ful=
ly understand whether this could come from any wrong configuration</div><di=
v><br></div><div># Channel configuration</div><div><div>agent1.channels.ch1=
.type =3D file</div><div>agent1.channels.ch1.checkpointDir =3D /opt/flume-n=
g/chekpoint</div><div>agent1.channels.ch1.dataDirs =3D /opt/flume-ng/data</=
div></div><div><br></div><div># Source</div><div><div>agent1.sources.thrift=
Src.type =3D thrift</div><div>agent1.sources.thriftSrc.channels =3D ch1</di=
v><div>agent1.sources.thriftSrc.bind =3D 0.0.0.0</div><div>agent1.sources.t=
hriftSrc.port =3D 4042</div></div><div><br></div><div><br></div><div>Thanks=
</div><div>Simone</div></div>

--001a11c37b36ff4d8605211cc0bc--