Return-Path: 
 <commits-return-140486-apmail-cassandra-commits-archive=cassandra.apache.org@cassandra.apache.org>
X-Original-To: apmail-cassandra-commits-archive@www.apache.org
Delivered-To: apmail-cassandra-commits-archive@www.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id D6A421873E
	for <apmail-cassandra-commits-archive@www.apache.org>;
 Thu,  6 Aug 2015 16:35:09 +0000 (UTC)
Received: (qmail 10635 invoked by uid 500); 6 Aug 2015 16:35:04 -0000
Delivered-To: apmail-cassandra-commits-archive@cassandra.apache.org
Received: (qmail 10596 invoked by uid 500); 6 Aug 2015 16:35:04 -0000
Mailing-List: contact commits-help@cassandra.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:commits-help@cassandra.apache.org>
List-Unsubscribe: <mailto:commits-unsubscribe@cassandra.apache.org>
List-Post: <mailto:commits@cassandra.apache.org>
List-Id: <commits.cassandra.apache.org>
Reply-To: dev@cassandra.apache.org
Delivered-To: mailing list commits@cassandra.apache.org
Received: (qmail 10583 invoked by uid 99); 6 Aug 2015 16:35:04 -0000
Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28)
    by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 06 Aug 2015 16:35:04 +0000
Date: Thu, 6 Aug 2015 16:35:04 +0000 (UTC)
From: "Chris Moos (JIRA)" <jira@apache.org>
To: commits@cassandra.apache.org
Message-ID: <JIRA.12852620.1438878792000.390800.1438878904611@Atlassian.JIRA>
In-Reply-To: <JIRA.12852620.1438878792000@Atlassian.JIRA>
References: <JIRA.12852620.1438878792000@Atlassian.JIRA>
 <JIRA.12852620.1438878792329@arcas>
Subject: [jira] [Updated] (CASSANDRA-10005) Streaming fails with not enough
 bytes error
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394


     [ https://issues.apache.org/jira/browse/CASSANDRA-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Chris Moos updated CASSANDRA-10005:
-----------------------------------
    Description: 
I'm adding a new node to the cluster and I'm seeing a bunch of the errors below. The node never joins the cluster. Does anyone know anything about this error?

{code}
WARN  [STREAM-IN-/10.220.0.160] 2015-08-06 16:16:42,640 StreamSession.java:638 - [Stream #4be6d7c0-3c53-11e5-b5bc-dbbae7f19873] Retrying for following error
java.lang.IllegalArgumentException: Not enough bytes
        at org.apache.cassandra.db.composites.AbstractCType.checkRemaining(AbstractCType.java:362) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.db.composites.AbstractCompoundCellNameType.fromByteBuffer(AbstractCompoundCellNameType.java:98) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.db.composites.AbstractCType$Serializer.deserialize(AbstractCType.java:381) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.db.composites.AbstractCType$Serializer.deserialize(AbstractCType.java:365) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.db.OnDiskAtom$Serializer.deserializeFromSSTable(OnDiskAtom.java:75) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.db.AbstractCell$1.computeNext(AbstractCell.java:52) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.db.AbstractCell$1.computeNext(AbstractCell.java:46) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:143) ~[guava-16.0.jar:na]
        at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:138) ~[guava-16.0.jar:na]
        at org.apache.cassandra.io.sstable.format.big.BigTableWriter.appendFromStream(BigTableWriter.java:243) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.streaming.StreamReader.writeRow(StreamReader.java:162) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.streaming.compress.CompressedStreamReader.read(CompressedStreamReader.java:95) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.streaming.messages.IncomingFileMessage$1.deserialize(IncomingFileMessage.java:49) [apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.streaming.messages.IncomingFileMessage$1.deserialize(IncomingFileMessage.java:38) [apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.streaming.messages.StreamMessage.deserialize(StreamMessage.java:56) [apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.streaming.ConnectionHandler$IncomingMessageHandler.run(ConnectionHandler.java:261) [apache-cassandra-2.2.0.jar:2.2.0]
        at java.lang.Thread.run(Thread.java:745) [na:1.7.0_79]
{code}

{code}
ERROR 06:28:26 [Stream #059b7cc0-3c04-11e5-8c56-dbbae7f19873] Streaming error occurred
java.lang.IllegalArgumentException: Unknown type 0
        at org.apache.cassandra.streaming.messages.StreamMessage$Type.get(StreamMessage.java:90) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.streaming.messages.StreamMessage.deserialize(StreamMessage.java:55) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.streaming.ConnectionHandler$IncomingMessageHandler.run(ConnectionHandler.java:261) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at java.lang.Thread.run(Thread.java:745) [na:1.7.0_79]
{code}

  was:
I'm adding a new node to the cluster and I'm seeing a bunch of the errors below. The node never joins the cluster. Does anyone know anything about this error?

{code}
WARN  [STREAM-IN-/10.220.0.160] 2015-08-06 16:16:42,640 StreamSession.java:638 - [Stream #4be6d7c0-3c53-11e5-b5bc-dbbae7f19873] Retrying for following error
java.lang.IllegalArgumentException: Not enough bytes
        at org.apache.cassandra.db.composites.AbstractCType.checkRemaining(AbstractCType.java:362) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.db.composites.AbstractCompoundCellNameType.fromByteBuffer(AbstractCompoundCellNameType.java:98) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.db.composites.AbstractCType$Serializer.deserialize(AbstractCType.java:381) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.db.composites.AbstractCType$Serializer.deserialize(AbstractCType.java:365) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.db.OnDiskAtom$Serializer.deserializeFromSSTable(OnDiskAtom.java:75) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.db.AbstractCell$1.computeNext(AbstractCell.java:52) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.db.AbstractCell$1.computeNext(AbstractCell.java:46) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:143) ~[guava-16.0.jar:na]
        at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:138) ~[guava-16.0.jar:na]
        at org.apache.cassandra.io.sstable.format.big.BigTableWriter.appendFromStream(BigTableWriter.java:243) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.streaming.StreamReader.writeRow(StreamReader.java:162) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.streaming.compress.CompressedStreamReader.read(CompressedStreamReader.java:95) ~[apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.streaming.messages.IncomingFileMessage$1.deserialize(IncomingFileMessage.java:49) [apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.streaming.messages.IncomingFileMessage$1.deserialize(IncomingFileMessage.java:38) [apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.streaming.messages.StreamMessage.deserialize(StreamMessage.java:56) [apache-cassandra-2.2.0.jar:2.2.0]
        at org.apache.cassandra.streaming.ConnectionHandler$IncomingMessageHandler.run(ConnectionHandler.java:261) [apache-cassandra-2.2.0.jar:2.2.0]
        at java.lang.Thread.run(Thread.java:745) [na:1.7.0_79]
{code}


> Streaming fails with not enough bytes error
> -------------------------------------------
>
>                 Key: CASSANDRA-10005
>                 URL: https://issues.apache.org/jira/browse/CASSANDRA-10005
>             Project: Cassandra
>          Issue Type: Bug
>          Components: Core
>            Reporter: Chris Moos
>            Priority: Minor
>
> I'm adding a new node to the cluster and I'm seeing a bunch of the errors below. The node never joins the cluster. Does anyone know anything about this error?
> {code}
> WARN  [STREAM-IN-/10.220.0.160] 2015-08-06 16:16:42,640 StreamSession.java:638 - [Stream #4be6d7c0-3c53-11e5-b5bc-dbbae7f19873] Retrying for following error
> java.lang.IllegalArgumentException: Not enough bytes
>         at org.apache.cassandra.db.composites.AbstractCType.checkRemaining(AbstractCType.java:362) ~[apache-cassandra-2.2.0.jar:2.2.0]
>         at org.apache.cassandra.db.composites.AbstractCompoundCellNameType.fromByteBuffer(AbstractCompoundCellNameType.java:98) ~[apache-cassandra-2.2.0.jar:2.2.0]
>         at org.apache.cassandra.db.composites.AbstractCType$Serializer.deserialize(AbstractCType.java:381) ~[apache-cassandra-2.2.0.jar:2.2.0]
>         at org.apache.cassandra.db.composites.AbstractCType$Serializer.deserialize(AbstractCType.java:365) ~[apache-cassandra-2.2.0.jar:2.2.0]
>         at org.apache.cassandra.db.OnDiskAtom$Serializer.deserializeFromSSTable(OnDiskAtom.java:75) ~[apache-cassandra-2.2.0.jar:2.2.0]
>         at org.apache.cassandra.db.AbstractCell$1.computeNext(AbstractCell.java:52) ~[apache-cassandra-2.2.0.jar:2.2.0]
>         at org.apache.cassandra.db.AbstractCell$1.computeNext(AbstractCell.java:46) ~[apache-cassandra-2.2.0.jar:2.2.0]
>         at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:143) ~[guava-16.0.jar:na]
>         at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:138) ~[guava-16.0.jar:na]
>         at org.apache.cassandra.io.sstable.format.big.BigTableWriter.appendFromStream(BigTableWriter.java:243) ~[apache-cassandra-2.2.0.jar:2.2.0]
>         at org.apache.cassandra.streaming.StreamReader.writeRow(StreamReader.java:162) ~[apache-cassandra-2.2.0.jar:2.2.0]
>         at org.apache.cassandra.streaming.compress.CompressedStreamReader.read(CompressedStreamReader.java:95) ~[apache-cassandra-2.2.0.jar:2.2.0]
>         at org.apache.cassandra.streaming.messages.IncomingFileMessage$1.deserialize(IncomingFileMessage.java:49) [apache-cassandra-2.2.0.jar:2.2.0]
>         at org.apache.cassandra.streaming.messages.IncomingFileMessage$1.deserialize(IncomingFileMessage.java:38) [apache-cassandra-2.2.0.jar:2.2.0]
>         at org.apache.cassandra.streaming.messages.StreamMessage.deserialize(StreamMessage.java:56) [apache-cassandra-2.2.0.jar:2.2.0]
>         at org.apache.cassandra.streaming.ConnectionHandler$IncomingMessageHandler.run(ConnectionHandler.java:261) [apache-cassandra-2.2.0.jar:2.2.0]
>         at java.lang.Thread.run(Thread.java:745) [na:1.7.0_79]
> {code}
> {code}
> ERROR 06:28:26 [Stream #059b7cc0-3c04-11e5-8c56-dbbae7f19873] Streaming error occurred
> java.lang.IllegalArgumentException: Unknown type 0
>         at org.apache.cassandra.streaming.messages.StreamMessage$Type.get(StreamMessage.java:90) ~[apache-cassandra-2.2.0.jar:2.2.0]
>         at org.apache.cassandra.streaming.messages.StreamMessage.deserialize(StreamMessage.java:55) ~[apache-cassandra-2.2.0.jar:2.2.0]
>         at org.apache.cassandra.streaming.ConnectionHandler$IncomingMessageHandler.run(ConnectionHandler.java:261) ~[apache-cassandra-2.2.0.jar:2.2.0]
>         at java.lang.Thread.run(Thread.java:745) [na:1.7.0_79]
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)