TSocket socket = new TSocket(host, Integer.parseInt(port));
TTransport transport = new TFramedTransport(socket);
TProtocol protocol = new TBinaryProtocol(transport, true, true);
cassandra_client = new Cassandra.Client(protocol);
cassandra_client.execute_cql3_query(
ByteBuffer.wrap(queryBuilder.toString().getBytes(Constants.CHARSET_UTF8)),
Compression.NONE,
ConsistencyLevel.ONE);
On Sat, Apr 26, 2014 at 5:19 AM, Alex Popescu <al...@datastax.com> wrote:
> Can you share the relevant code snippet that leads to this exception?
>
>
> On Fri, Apr 25, 2014 at 4:47 PM, Vivek Mishra <mishra.v...@gmail.com>wrote:
>
>> datastax java driver 2.0.1
>>
>>
>>
>>
>> On Sat, Apr 26, 2014 at 1:35 AM, Chris Lohfink
>> <clohf...@blackbirdit.com>wrote:
>>
>>> what client are you using?
>>>
>>> On Apr 25, 2014, at 3:01 PM, Vivek Mishra <mishra.v...@gmail.com> wrote:
>>>
>>> It's a simple cql3 query to create keyspace.
>>>
>>> -Vivek
>>>
>>>
>>> On Sat, Apr 26, 2014 at 1:28 AM, Chris Lohfink <clohf...@blackbirdit.com
>>> > wrote:
>>>
>>>> Did you send an enormous write or batch write and it wrapped? Or is
>>>> your client trying to use non-framed transport?
>>>>
>>>> Chris
>>>>
>>>> On Apr 25, 2014, at 2:50 PM, Vivek Mishra <mishra.v...@gmail.com>
>>>> wrote:
>>>>
>>>> > This is what i am getting with Cassandra 2.0.7 with Thrift.
>>>> >
>>>> >
>>>> > Caused by: org.apache.thrift.transport.TTransportException: Read a
>>>> negative frame size (-2113929216)!
>>>> > at
>>>> org.apache.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java:133)
>>>> > at
>>>> org.apache.thrift.transport.TFramedTransport.read(TFramedTransport.java:101)
>>>> > at
>>>> org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
>>>> > at
>>>> org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:362)
>>>> > at
>>>> org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:284)
>>>> > at
>>>> org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:191)
>>>> > at
>>>> org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:69)
>>>> >
>>>> > Any pointer/suggestions?
>>>> >
>>>> > -Vivek
>>>>
>>>>
>>>
>>>
>>
>
>
> --
>
> :- a)
>
>
> Alex Popescu
> Sen. Product Manager @ DataStax
> @al3xandru
>
