You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@cassandra.apache.org by ankit tyagi <an...@gmail.com> on 2014/02/14 14:32:57 UTC

Exception in cassandra logs while processing the message

Hello,

I am seeing below exception in my cassandra
logs(/var/log/cassandra/system.log).

INFO [ScheduledTasks:1] 2014-02-13 13:13:57,641 GCInspector.java (line 119)
GC for ParNew: 273 ms for 1 collections, 2319121816 used; max is 445
6448000
 INFO [ScheduledTasks:1] 2014-02-13 13:14:02,695 GCInspector.java (line
119) GC for ParNew: 214 ms for 1 collections, 2315368976 used; max is 445
6448000
 INFO [OptionalTasks:1] 2014-02-13 13:14:08,093 MeteredFlusher.java (line
64) flushing high-traffic column family CFS(Keyspace='comsdb', ColumnFa
mily='product_update') (estimated 213624220 bytes)
 INFO [OptionalTasks:1] 2014-02-13 13:14:08,093 ColumnFamilyStore.java
(line 626) Enqueuing flush of Memtable-product_update@1067619242(31239028/
213625108 serialized/live bytes, 222393 ops)
 INFO [FlushWriter:94] 2014-02-13 13:14:08,127 Memtable.java (line 400)
Writing Memtable-product_update@1067619242(31239028/213625108 serialized/
live bytes, 222393 ops)
 INFO [ScheduledTasks:1] 2014-02-13 13:14:08,696 GCInspector.java (line
119) GC for ParNew: 214 ms for 1 collections, 2480175160 used; max is 445
6448000
* INFO [FlushWriter:94] 2014-02-13 13:14:10,836 Memtable.java (line 438)
Completed flushing /cassandra1/data/comsdb/product_update/comsdb-product_*
*update-ic-416-Data.db (15707248 bytes) for commitlog position
ReplayPosition(segmentId=1391568233618, position=13712751)*
*ERROR [Thrift:13] 2014-02-13 13:15:45,694 CustomTThreadPoolServer.java
(line 213) Thrift error occurred during processing of message.*
*org.apache.thrift.TException: Negative length: -2147418111*
        at
org.apache.thrift.protocol.TBinaryProtocol.checkReadLength(TBinaryProtocol.java:388)
        at
org.apache.thrift.protocol.TBinaryProtocol.readBinary(TBinaryProtocol.java:363)
        at
org.apache.cassandra.thrift.Cassandra$batch_mutate_args.read(Cassandra.java:20304)
        at
org.apache.thrift.ProcessFunction.process(ProcessFunction.java:21)
        at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:34)
        at
org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:199)
        at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1146)
        at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
        at java.lang.Thread.run(Thread.java:679)
ERROR [Thrift:103] 2014-02-13 13:21:25,719 CustomTThreadPoolServer.java
(line 213) Thrift error occurred during processing of message.
org.apache.thrift.TException: Negative length: -2147418111


Below is my cassandra version and hector client version, which is being
used currently.

Cassandra-version: 1.2.11
Hector-client: 1.0-2

Any lead would be appreciated though we are planning to move cassandra 2.0
version with java-driver but it may take some time meanwhile need to find
the root cause and resolve this issue.


Regards,
Ankit Tyagi

Re: Exception in cassandra logs while processing the message

Posted by ankit tyagi <an...@gmail.com>.
Hi Sylvain,

hector core 1.0-2 uses libthrift 0.6.1,but this exception is not
consistent, getting intermittently.

if there would be any issue related to compatibility of thrift jar, then
this error should be consistent ryt?

Regards,
Ankit Tyagi




On Mon, Feb 17, 2014 at 2:30 PM, Sylvain Lebresne <sy...@datastax.com>wrote:

> That looks like a thrift error. My best bet would be that you have an
> incompatibility of versions between the thrift lib used by your Hector
> version and the one of the Cassandra version used. All I can tell you is
> that Cassandra 1.2 uses libthrift 0.7.0, not sure what Hector-client 1.0-2
> uses however.
>
>
> On Mon, Feb 17, 2014 at 9:36 AM, ankit tyagi <an...@gmail.com>wrote:
>
>> Hi,
>>
>> I am using Hector-client: 1.0-2 to insert the data. Problem is , i am
>> not seeing any exception in my application logs where i am inserting data
>> through hector.
>>
>> looks like internal to cassandra.
>>
>> Regards,
>> Ankit TYagi
>>
>>
>> On Mon, Feb 17, 2014 at 1:56 PM, Vivek Mishra <mi...@gmail.com>wrote:
>>
>>> looks like thrift inter operability issue. Seems column family or data
>>> created via CQL3 and using Thrift based API to read it.
>>>
>>> Else, recreate your schema and try.
>>>
>>> -Vivek
>>>
>>>
>>> On Mon, Feb 17, 2014 at 1:50 PM, ankit tyagi <ankittyagi.mnnit@gmail.com
>>> > wrote:
>>>
>>>> Hello,
>>>>
>>>> anyone has the idea regarding this exception.
>>>>
>>>> Regards,
>>>> Ankit Tyagi
>>>>
>>>>
>>>> On Fri, Feb 14, 2014 at 7:02 PM, ankit tyagi <
>>>> ankittyagi.mnnit@gmail.com> wrote:
>>>>
>>>>> Hello,
>>>>>
>>>>> I am seeing below exception in my cassandra
>>>>> logs(/var/log/cassandra/system.log).
>>>>>
>>>>> INFO [ScheduledTasks:1] 2014-02-13 13:13:57,641 GCInspector.java (line
>>>>> 119) GC for ParNew: 273 ms for 1 collections, 2319121816 used; max is
>>>>> 445
>>>>> 6448000
>>>>>  INFO [ScheduledTasks:1] 2014-02-13 13:14:02,695 GCInspector.java
>>>>> (line 119) GC for ParNew: 214 ms for 1 collections, 2315368976 used;
>>>>> max is 445
>>>>> 6448000
>>>>>  INFO [OptionalTasks:1] 2014-02-13 13:14:08,093 MeteredFlusher.java
>>>>> (line 64) flushing high-traffic column family CFS(Keyspace='comsdb',
>>>>> ColumnFa
>>>>> mily='product_update') (estimated 213624220 bytes)
>>>>>  INFO [OptionalTasks:1] 2014-02-13 13:14:08,093 ColumnFamilyStore.java
>>>>> (line 626) Enqueuing flush of Memtable-product_update@1067619242
>>>>> (31239028/
>>>>> 213625108 serialized/live bytes, 222393 ops)
>>>>>  INFO [FlushWriter:94] 2014-02-13 13:14:08,127 Memtable.java (line
>>>>> 400) Writing Memtable-product_update@1067619242(31239028/213625108
>>>>> serialized/
>>>>> live bytes, 222393 ops)
>>>>>  INFO [ScheduledTasks:1] 2014-02-13 13:14:08,696 GCInspector.java
>>>>> (line 119) GC for ParNew: 214 ms for 1 collections, 2480175160 used; max is
>>>>> 445
>>>>> 6448000
>>>>> * INFO [FlushWriter:94] 2014-02-13 13:14:10,836 Memtable.java (line
>>>>> 438) Completed flushing
>>>>> /cassandra1/data/comsdb/product_update/comsdb-product_*
>>>>> *update-ic-416-Data.db (15707248 bytes) for commitlog position
>>>>> ReplayPosition(segmentId=1391568233618, position=13712751)*
>>>>> *ERROR [Thrift:13] 2014-02-13 13:15:45,694
>>>>> CustomTThreadPoolServer.java (line 213) Thrift error occurred during
>>>>> processing of message.*
>>>>> *org.apache.thrift.TException: Negative length: -2147418111
>>>>> <2147418111>*
>>>>>         at
>>>>> org.apache.thrift.protocol.TBinaryProtocol.checkReadLength(TBinaryProtocol.java:388)
>>>>>         at
>>>>> org.apache.thrift.protocol.TBinaryProtocol.readBinary(TBinaryProtocol.java:363)
>>>>>         at
>>>>> org.apache.cassandra.thrift.Cassandra$batch_mutate_args.read(Cassandra.java:20304)
>>>>>         at
>>>>> org.apache.thrift.ProcessFunction.process(ProcessFunction.java:21)
>>>>>         at
>>>>> org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:34)
>>>>>         at
>>>>> org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:199)
>>>>>         at
>>>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1146)
>>>>>         at
>>>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>>>>>         at java.lang.Thread.run(Thread.java:679)
>>>>> ERROR [Thrift:103] 2014-02-13 13:21:25,719
>>>>> CustomTThreadPoolServer.java (line 213) Thrift error occurred during
>>>>> processing of message.
>>>>> org.apache.thrift.TException: Negative length: -2147418111
>>>>>
>>>>>
>>>>> Below is my cassandra version and hector client version, which is
>>>>> being used currently.
>>>>>
>>>>> Cassandra-version: 1.2.11
>>>>> Hector-client: 1.0-2
>>>>>
>>>>> Any lead would be appreciated though we are planning to move cassandra
>>>>> 2.0 version with java-driver but it may take some time meanwhile need to
>>>>> find the root cause and resolve this issue.
>>>>>
>>>>>
>>>>> Regards,
>>>>> Ankit Tyagi
>>>>>
>>>>
>>>>
>>>
>>
>

Re: Exception in cassandra logs while processing the message

Posted by Sylvain Lebresne <sy...@datastax.com>.
That looks like a thrift error. My best bet would be that you have an
incompatibility of versions between the thrift lib used by your Hector
version and the one of the Cassandra version used. All I can tell you is
that Cassandra 1.2 uses libthrift 0.7.0, not sure what Hector-client 1.0-2
uses however.


On Mon, Feb 17, 2014 at 9:36 AM, ankit tyagi <an...@gmail.com>wrote:

> Hi,
>
> I am using Hector-client: 1.0-2 to insert the data. Problem is , i am not
> seeing any exception in my application logs where i am inserting data
> through hector.
>
> looks like internal to cassandra.
>
> Regards,
> Ankit TYagi
>
>
> On Mon, Feb 17, 2014 at 1:56 PM, Vivek Mishra <mi...@gmail.com>wrote:
>
>> looks like thrift inter operability issue. Seems column family or data
>> created via CQL3 and using Thrift based API to read it.
>>
>> Else, recreate your schema and try.
>>
>> -Vivek
>>
>>
>> On Mon, Feb 17, 2014 at 1:50 PM, ankit tyagi <an...@gmail.com>wrote:
>>
>>> Hello,
>>>
>>> anyone has the idea regarding this exception.
>>>
>>> Regards,
>>> Ankit Tyagi
>>>
>>>
>>> On Fri, Feb 14, 2014 at 7:02 PM, ankit tyagi <ankittyagi.mnnit@gmail.com
>>> > wrote:
>>>
>>>> Hello,
>>>>
>>>> I am seeing below exception in my cassandra
>>>> logs(/var/log/cassandra/system.log).
>>>>
>>>> INFO [ScheduledTasks:1] 2014-02-13 13:13:57,641 GCInspector.java (line
>>>> 119) GC for ParNew: 273 ms for 1 collections, 2319121816 used; max is
>>>> 445
>>>> 6448000
>>>>  INFO [ScheduledTasks:1] 2014-02-13 13:14:02,695 GCInspector.java (line
>>>> 119) GC for ParNew: 214 ms for 1 collections, 2315368976 used; max is
>>>> 445
>>>> 6448000
>>>>  INFO [OptionalTasks:1] 2014-02-13 13:14:08,093 MeteredFlusher.java
>>>> (line 64) flushing high-traffic column family CFS(Keyspace='comsdb',
>>>> ColumnFa
>>>> mily='product_update') (estimated 213624220 bytes)
>>>>  INFO [OptionalTasks:1] 2014-02-13 13:14:08,093 ColumnFamilyStore.java
>>>> (line 626) Enqueuing flush of Memtable-product_update@1067619242
>>>> (31239028/
>>>> 213625108 serialized/live bytes, 222393 ops)
>>>>  INFO [FlushWriter:94] 2014-02-13 13:14:08,127 Memtable.java (line 400)
>>>> Writing Memtable-product_update@1067619242(31239028/213625108
>>>> serialized/
>>>> live bytes, 222393 ops)
>>>>  INFO [ScheduledTasks:1] 2014-02-13 13:14:08,696 GCInspector.java (line
>>>> 119) GC for ParNew: 214 ms for 1 collections, 2480175160 used; max is 445
>>>> 6448000
>>>> * INFO [FlushWriter:94] 2014-02-13 13:14:10,836 Memtable.java (line
>>>> 438) Completed flushing
>>>> /cassandra1/data/comsdb/product_update/comsdb-product_*
>>>> *update-ic-416-Data.db (15707248 bytes) for commitlog position
>>>> ReplayPosition(segmentId=1391568233618, position=13712751)*
>>>> *ERROR [Thrift:13] 2014-02-13 13:15:45,694 CustomTThreadPoolServer.java
>>>> (line 213) Thrift error occurred during processing of message.*
>>>> *org.apache.thrift.TException: Negative length: -2147418111
>>>> <2147418111>*
>>>>         at
>>>> org.apache.thrift.protocol.TBinaryProtocol.checkReadLength(TBinaryProtocol.java:388)
>>>>         at
>>>> org.apache.thrift.protocol.TBinaryProtocol.readBinary(TBinaryProtocol.java:363)
>>>>         at
>>>> org.apache.cassandra.thrift.Cassandra$batch_mutate_args.read(Cassandra.java:20304)
>>>>         at
>>>> org.apache.thrift.ProcessFunction.process(ProcessFunction.java:21)
>>>>         at
>>>> org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:34)
>>>>         at
>>>> org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:199)
>>>>         at
>>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1146)
>>>>         at
>>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>>>>         at java.lang.Thread.run(Thread.java:679)
>>>> ERROR [Thrift:103] 2014-02-13 13:21:25,719 CustomTThreadPoolServer.java
>>>> (line 213) Thrift error occurred during processing of message.
>>>> org.apache.thrift.TException: Negative length: -2147418111
>>>>
>>>>
>>>> Below is my cassandra version and hector client version, which is being
>>>> used currently.
>>>>
>>>> Cassandra-version: 1.2.11
>>>> Hector-client: 1.0-2
>>>>
>>>> Any lead would be appreciated though we are planning to move cassandra
>>>> 2.0 version with java-driver but it may take some time meanwhile need to
>>>> find the root cause and resolve this issue.
>>>>
>>>>
>>>> Regards,
>>>> Ankit Tyagi
>>>>
>>>
>>>
>>
>

Re: Exception in cassandra logs while processing the message

Posted by ankit tyagi <an...@gmail.com>.
Hi,

I am using Hector-client: 1.0-2 to insert the data. Problem is , i am not
seeing any exception in my application logs where i am inserting data
through hector.

looks like internal to cassandra.

Regards,
Ankit TYagi


On Mon, Feb 17, 2014 at 1:56 PM, Vivek Mishra <mi...@gmail.com> wrote:

> looks like thrift inter operability issue. Seems column family or data
> created via CQL3 and using Thrift based API to read it.
>
> Else, recreate your schema and try.
>
> -Vivek
>
>
> On Mon, Feb 17, 2014 at 1:50 PM, ankit tyagi <an...@gmail.com>wrote:
>
>> Hello,
>>
>> anyone has the idea regarding this exception.
>>
>> Regards,
>> Ankit Tyagi
>>
>>
>> On Fri, Feb 14, 2014 at 7:02 PM, ankit tyagi <an...@gmail.com>wrote:
>>
>>> Hello,
>>>
>>> I am seeing below exception in my cassandra
>>> logs(/var/log/cassandra/system.log).
>>>
>>> INFO [ScheduledTasks:1] 2014-02-13 13:13:57,641 GCInspector.java (line
>>> 119) GC for ParNew: 273 ms for 1 collections, 2319121816 used; max is 445
>>> 6448000
>>>  INFO [ScheduledTasks:1] 2014-02-13 13:14:02,695 GCInspector.java (line
>>> 119) GC for ParNew: 214 ms for 1 collections, 2315368976 used; max is 445
>>> 6448000
>>>  INFO [OptionalTasks:1] 2014-02-13 13:14:08,093 MeteredFlusher.java
>>> (line 64) flushing high-traffic column family CFS(Keyspace='comsdb',
>>> ColumnFa
>>> mily='product_update') (estimated 213624220 bytes)
>>>  INFO [OptionalTasks:1] 2014-02-13 13:14:08,093 ColumnFamilyStore.java
>>> (line 626) Enqueuing flush of Memtable-product_update@1067619242
>>> (31239028/
>>> 213625108 serialized/live bytes, 222393 ops)
>>>  INFO [FlushWriter:94] 2014-02-13 13:14:08,127 Memtable.java (line 400)
>>> Writing Memtable-product_update@1067619242(31239028/213625108
>>> serialized/
>>> live bytes, 222393 ops)
>>>  INFO [ScheduledTasks:1] 2014-02-13 13:14:08,696 GCInspector.java (line
>>> 119) GC for ParNew: 214 ms for 1 collections, 2480175160 used; max is 445
>>> 6448000
>>> * INFO [FlushWriter:94] 2014-02-13 13:14:10,836 Memtable.java (line 438)
>>> Completed flushing /cassandra1/data/comsdb/product_update/comsdb-product_*
>>> *update-ic-416-Data.db (15707248 bytes) for commitlog position
>>> ReplayPosition(segmentId=1391568233618, position=13712751)*
>>> *ERROR [Thrift:13] 2014-02-13 13:15:45,694 CustomTThreadPoolServer.java
>>> (line 213) Thrift error occurred during processing of message.*
>>> *org.apache.thrift.TException: Negative length: -2147418111*
>>>         at
>>> org.apache.thrift.protocol.TBinaryProtocol.checkReadLength(TBinaryProtocol.java:388)
>>>         at
>>> org.apache.thrift.protocol.TBinaryProtocol.readBinary(TBinaryProtocol.java:363)
>>>         at
>>> org.apache.cassandra.thrift.Cassandra$batch_mutate_args.read(Cassandra.java:20304)
>>>         at
>>> org.apache.thrift.ProcessFunction.process(ProcessFunction.java:21)
>>>         at
>>> org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:34)
>>>         at
>>> org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:199)
>>>         at
>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1146)
>>>         at
>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>>>         at java.lang.Thread.run(Thread.java:679)
>>> ERROR [Thrift:103] 2014-02-13 13:21:25,719 CustomTThreadPoolServer.java
>>> (line 213) Thrift error occurred during processing of message.
>>> org.apache.thrift.TException: Negative length: -2147418111
>>>
>>>
>>> Below is my cassandra version and hector client version, which is being
>>> used currently.
>>>
>>> Cassandra-version: 1.2.11
>>> Hector-client: 1.0-2
>>>
>>> Any lead would be appreciated though we are planning to move cassandra
>>> 2.0 version with java-driver but it may take some time meanwhile need to
>>> find the root cause and resolve this issue.
>>>
>>>
>>> Regards,
>>> Ankit Tyagi
>>>
>>
>>
>

Re: Exception in cassandra logs while processing the message

Posted by Vivek Mishra <mi...@gmail.com>.
looks like thrift inter operability issue. Seems column family or data
created via CQL3 and using Thrift based API to read it.

Else, recreate your schema and try.

-Vivek


On Mon, Feb 17, 2014 at 1:50 PM, ankit tyagi <an...@gmail.com>wrote:

> Hello,
>
> anyone has the idea regarding this exception.
>
> Regards,
> Ankit Tyagi
>
>
> On Fri, Feb 14, 2014 at 7:02 PM, ankit tyagi <an...@gmail.com>wrote:
>
>> Hello,
>>
>> I am seeing below exception in my cassandra
>> logs(/var/log/cassandra/system.log).
>>
>> INFO [ScheduledTasks:1] 2014-02-13 13:13:57,641 GCInspector.java (line
>> 119) GC for ParNew: 273 ms for 1 collections, 2319121816 used; max is 445
>> 6448000
>>  INFO [ScheduledTasks:1] 2014-02-13 13:14:02,695 GCInspector.java (line
>> 119) GC for ParNew: 214 ms for 1 collections, 2315368976 used; max is 445
>> 6448000
>>  INFO [OptionalTasks:1] 2014-02-13 13:14:08,093 MeteredFlusher.java (line
>> 64) flushing high-traffic column family CFS(Keyspace='comsdb', ColumnFa
>> mily='product_update') (estimated 213624220 bytes)
>>  INFO [OptionalTasks:1] 2014-02-13 13:14:08,093 ColumnFamilyStore.java
>> (line 626) Enqueuing flush of Memtable-product_update@1067619242
>> (31239028/
>> 213625108 serialized/live bytes, 222393 ops)
>>  INFO [FlushWriter:94] 2014-02-13 13:14:08,127 Memtable.java (line 400)
>> Writing Memtable-product_update@1067619242(31239028/213625108 serialized/
>> live bytes, 222393 ops)
>>  INFO [ScheduledTasks:1] 2014-02-13 13:14:08,696 GCInspector.java (line
>> 119) GC for ParNew: 214 ms for 1 collections, 2480175160 used; max is 445
>> 6448000
>> * INFO [FlushWriter:94] 2014-02-13 13:14:10,836 Memtable.java (line 438)
>> Completed flushing /cassandra1/data/comsdb/product_update/comsdb-product_*
>> *update-ic-416-Data.db (15707248 bytes) for commitlog position
>> ReplayPosition(segmentId=1391568233618, position=13712751)*
>> *ERROR [Thrift:13] 2014-02-13 13:15:45,694 CustomTThreadPoolServer.java
>> (line 213) Thrift error occurred during processing of message.*
>> *org.apache.thrift.TException: Negative length: -2147418111*
>>         at
>> org.apache.thrift.protocol.TBinaryProtocol.checkReadLength(TBinaryProtocol.java:388)
>>         at
>> org.apache.thrift.protocol.TBinaryProtocol.readBinary(TBinaryProtocol.java:363)
>>         at
>> org.apache.cassandra.thrift.Cassandra$batch_mutate_args.read(Cassandra.java:20304)
>>         at
>> org.apache.thrift.ProcessFunction.process(ProcessFunction.java:21)
>>         at
>> org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:34)
>>         at
>> org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:199)
>>         at
>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1146)
>>         at
>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>>         at java.lang.Thread.run(Thread.java:679)
>> ERROR [Thrift:103] 2014-02-13 13:21:25,719 CustomTThreadPoolServer.java
>> (line 213) Thrift error occurred during processing of message.
>> org.apache.thrift.TException: Negative length: -2147418111
>>
>>
>> Below is my cassandra version and hector client version, which is being
>> used currently.
>>
>> Cassandra-version: 1.2.11
>> Hector-client: 1.0-2
>>
>> Any lead would be appreciated though we are planning to move cassandra
>> 2.0 version with java-driver but it may take some time meanwhile need to
>> find the root cause and resolve this issue.
>>
>>
>> Regards,
>> Ankit Tyagi
>>
>
>

Re: Exception in cassandra logs while processing the message

Posted by ankit tyagi <an...@gmail.com>.
Hello,

anyone has the idea regarding this exception.

Regards,
Ankit Tyagi


On Fri, Feb 14, 2014 at 7:02 PM, ankit tyagi <an...@gmail.com>wrote:

> Hello,
>
> I am seeing below exception in my cassandra
> logs(/var/log/cassandra/system.log).
>
> INFO [ScheduledTasks:1] 2014-02-13 13:13:57,641 GCInspector.java (line
> 119) GC for ParNew: 273 ms for 1 collections, 2319121816 used; max is 445
> 6448000
>  INFO [ScheduledTasks:1] 2014-02-13 13:14:02,695 GCInspector.java (line
> 119) GC for ParNew: 214 ms for 1 collections, 2315368976 used; max is 445
> 6448000
>  INFO [OptionalTasks:1] 2014-02-13 13:14:08,093 MeteredFlusher.java (line
> 64) flushing high-traffic column family CFS(Keyspace='comsdb', ColumnFa
> mily='product_update') (estimated 213624220 bytes)
>  INFO [OptionalTasks:1] 2014-02-13 13:14:08,093 ColumnFamilyStore.java
> (line 626) Enqueuing flush of Memtable-product_update@1067619242(31239028/
> 213625108 serialized/live bytes, 222393 ops)
>  INFO [FlushWriter:94] 2014-02-13 13:14:08,127 Memtable.java (line 400)
> Writing Memtable-product_update@1067619242(31239028/213625108 serialized/
> live bytes, 222393 ops)
>  INFO [ScheduledTasks:1] 2014-02-13 13:14:08,696 GCInspector.java (line
> 119) GC for ParNew: 214 ms for 1 collections, 2480175160 used; max is 445
> 6448000
> * INFO [FlushWriter:94] 2014-02-13 13:14:10,836 Memtable.java (line 438)
> Completed flushing /cassandra1/data/comsdb/product_update/comsdb-product_*
> *update-ic-416-Data.db (15707248 bytes) for commitlog position
> ReplayPosition(segmentId=1391568233618, position=13712751)*
> *ERROR [Thrift:13] 2014-02-13 13:15:45,694 CustomTThreadPoolServer.java
> (line 213) Thrift error occurred during processing of message.*
> *org.apache.thrift.TException: Negative length: -2147418111*
>         at
> org.apache.thrift.protocol.TBinaryProtocol.checkReadLength(TBinaryProtocol.java:388)
>         at
> org.apache.thrift.protocol.TBinaryProtocol.readBinary(TBinaryProtocol.java:363)
>         at
> org.apache.cassandra.thrift.Cassandra$batch_mutate_args.read(Cassandra.java:20304)
>         at
> org.apache.thrift.ProcessFunction.process(ProcessFunction.java:21)
>         at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:34)
>         at
> org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:199)
>         at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1146)
>         at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>         at java.lang.Thread.run(Thread.java:679)
> ERROR [Thrift:103] 2014-02-13 13:21:25,719 CustomTThreadPoolServer.java
> (line 213) Thrift error occurred during processing of message.
> org.apache.thrift.TException: Negative length: -2147418111
>
>
> Below is my cassandra version and hector client version, which is being
> used currently.
>
> Cassandra-version: 1.2.11
> Hector-client: 1.0-2
>
> Any lead would be appreciated though we are planning to move cassandra 2.0
> version with java-driver but it may take some time meanwhile need to find
> the root cause and resolve this issue.
>
>
> Regards,
> Ankit Tyagi
>