Mailing-List: contact user-help@cassandra.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@cassandra.apache.org
Received-SPF: pass (nike.apache.org: domain of jshook@gmail.com designates
 209.85.216.44 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:in-reply-to:references:date:message-id:subject:from:to
         :cc:content-type:content-transfer-encoding;
        b=haiuHM3/YUZda/+P+1LnSfoeVRidL4tk8Cs4pAbaHHJBEposlqruk516tmDXk0K1F+
         iQ0dACYGjcONnbJ3w3ycOd8PXeVN6qmld0trQROLNIE6Wt+zl5ewTXYCI4MqfjJvfQUa
         QV6RSHtpwSPzJBH6WXxz4IMGZS0qfUzXGert8=
MIME-Version: 1.0
In-Reply-To: <n2ne06563881004280515qf24bf407h66531c1084fbc203@mail.gmail.com>
References: <201004271320185234997@gmail.com>
	<201004271721171837907@gmail.com>
	<h2oe06563881004270550hc4d1e263n7f76088744aa2e@mail.gmail.com>
	<201004281308026747719@gmail.com>
	<n2ne06563881004280515qf24bf407h66531c1084fbc203@mail.gmail.com>
Date: Fri, 3 Sep 2010 11:26:47 -0500
Message-ID: <AANLkTi=7aafqH5iqzEEo6zf16tLT7VMT5FpptkYP45UK@mail.gmail.com>
Subject: Re: Re: Broken pipe
From: Jonathan Shook <jshook@gmail.com>
To: user@cassandra.apache.org
Cc: Bingbing Liu <rucbing@gmail.com>
Content-Type: text/plain; charset=GB2312
Content-Transfer-Encoding: quoted-printable

I have been able to reproduce this, although it was a bug in
application client code. If you keep a thrift client around longer
after it has had an exception, it may generate this error.

In my case, I was holding a reference via ThreadLocal<> to a stale
storage object.

Another symptom which may help identify this scenario is that the
broken client will not initiate any network traffic, not even a SYN
packet. You may have to shut down other client traffic on the client
node in order to see this...


2010/4/28 Jonathan Ellis <jbellis@gmail.com>:
> did you check the log for exceptions?
>
> On Wed, Apr 28, 2010 at 12:08 AM, Bingbing Liu <rucbing@gmail.com> wrote:
>> but the situation is that ,at the beginning everything goes well, then w=
hen
>> the get_range_slices gets about 13,000,000 rows (set the key range to 20=
00)
>>
>> the exception happens.
>>
>> and when i do the same thing on a smaller data set, no such thing happen=
s.
>>
>> 2010-04-28
>> ________________________________
>> Bingbing Liu
>> ________________________________
>> =B7=A2=BC=FE=C8=CB=A3=BA Jonathan Ellis
>> =B7=A2=CB=CD=CA=B1=BC=E4=A3=BA 2010-04-27  20:51:11
>> =CA=D5=BC=FE=C8=CB=A3=BA user
>> =B3=AD=CB=CD=A3=BA rucbing
>> =D6=F7=CC=E2=A3=BA Re: Broken pipe
>> get_range_slices works fine in the system tests, so something is wrong
>> on your client side.  Some possibilities:
>>  - sending to a non-Thrift port
>>  - using an incompatible set of Thrift bindings than the one your
>> server supports
>>  - mixing a framed client with a non-framed server or vice versa
>> [moving followups to user list]
>> 2010/4/27 Bingbing Liu <rucbing@gmail.com>:
>>> when i use get_range_slices, i get the exceptions , i don't know what h=
appens
>>>
>>> hope someone can help me
>>>
>>>
>>> org.apache.thrift.transport.TTransportException: java.net.SocketExcepti=
on: Broken pipe
>>>    at org.apache.thrift.transport.TIOStreamTransport.write(TIOStreamTra=
nsport.java:142)
>>>    at org.apache.thrift.protocol.TBinaryProtocol.writeI32(TBinaryProtoc=
ol.java:152)
>>>    at org.apache.thrift.protocol.TBinaryProtocol.writeMessageBegin(TBin=
aryProtocol.java:80)
>>>    at org.apache.cassandra.thrift.Cassandra$Client.send_get_range_slice=
s(Cassandra.java:592)
>>>    at org.apache.cassandra.thrift.Cassandra$Client.get_range_slices(Cas=
sandra.java:586)
>>>    at org.clouddb.test.GrepSelect.main(GrepSelect.java:64)
>>> Caused by: java.net.SocketException: Broken pipe
>>>    at java.net.SocketOutputStream.socketWrite0(Native Method)
>>>    at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:9=
2)
>>>    at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
>>>    at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.jav=
a:65)
>>>    at java.io.BufferedOutputStream.write(BufferedOutputStream.java:109)
>>>    at org.apache.thrift.transport.TIOStreamTransport.write(TIOStreamTra=
nsport.java:140)
>>>    ... 5 more
>>>
>>>
>>> 2010-04-27
>>>
>>>
>>>
>>> Bingbing Liu
>>>
>> --
>> Jonathan Ellis
>> Project Chair, Apache Cassandra
>> co-founder of Riptano, the source for professional Cassandra support
>> http://riptano.com
>
>
>
> --
> Jonathan Ellis
> Project Chair, Apache Cassandra
> co-founder of Riptano, the source for professional Cassandra support
> http://riptano.com
>