Return-Path: X-Original-To: apmail-cassandra-user-archive@www.apache.org Delivered-To: apmail-cassandra-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 5D4E4108D3 for ; Fri, 7 Jun 2013 06:12:00 +0000 (UTC) Received: (qmail 90203 invoked by uid 500); 7 Jun 2013 06:11:55 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 90174 invoked by uid 500); 7 Jun 2013 06:11:52 -0000 Mailing-List: contact user-help@cassandra.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@cassandra.apache.org Delivered-To: mailing list user@cassandra.apache.org Received: (qmail 90166 invoked by uid 99); 7 Jun 2013 06:11:48 -0000 Received: from Unknown (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 07 Jun 2013 06:11:48 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of davide.anastasia@gmail.com designates 209.85.214.51 as permitted sender) Received: from [209.85.214.51] (HELO mail-bk0-f51.google.com) (209.85.214.51) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 07 Jun 2013 06:11:28 +0000 Received: by mail-bk0-f51.google.com with SMTP id ji1so1276576bkc.38 for ; Thu, 06 Jun 2013 23:11:07 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=RrPhVskxUnaIx9zKnm1EuXO7xMlljH8DJGB2CUU0KLc=; b=JRd85eqOI6u6hajo0w+Hx2hS8pUIeCRYPt0u/Xap0PB/OWQe1f+yhNpM6F9a8C1GBx 66x0ywq6DwxtYrwmbztkAWeF5xU7nbjaWePgTjHmyWyKUmQ0koGu+W62EnUXEmf5CyOt VdwaXdm848pDbqD0YHr3zJq6AS3ASpJmCd5nL1M9T66luLhJfG0bhujM/Lqng8sQDIw6 jQwehfaZ6CPV6TjYcjo0RO9g5pZWRUKT9/pDAgTJE0EdbqpOeCJiaJUpPJiabOceOBfn CjNAUbVAFW3x8FQaUAL8Uzw7WsQh3c0AWxi0ACQRtBt8sqXTWvlVva0tOq5NW5Cqvg9o EX3A== MIME-Version: 1.0 X-Received: by 10.204.52.137 with SMTP id i9mr12178761bkg.183.1370585467592; Thu, 06 Jun 2013 23:11:07 -0700 (PDT) Received: by 10.205.41.132 with HTTP; Thu, 6 Jun 2013 23:11:07 -0700 (PDT) In-Reply-To: <8hfbdl3gqxjmlyc1sh0dfpfr.1370559209572@email.android.com> References: <8hfbdl3gqxjmlyc1sh0dfpfr.1370559209572@email.android.com> Date: Fri, 7 Jun 2013 07:11:07 +0100 Message-ID: Subject: Re: Bulk loader with Cassandra 1.2.5 From: Davide Anastasia To: user@cassandra.apache.org Content-Type: multipart/alternative; boundary=001a11c37984ee65d204de8a4bd3 X-Virus-Checked: Checked by ClamAV on apache.org --001a11c37984ee65d204de8a4bd3 Content-Type: text/plain; charset=ISO-8859-1 Hi, I've just tried to change it to integer and I get exactly the same error. Thanks, Davide On 6 June 2013 23:53, Keith Wright wrote: > Could it be because you are writing age as a long but have it defined as an integer in the table definition? > > Davide Anastasia wrote: > > > Hi, > I am currently using Cassandra 1.2.5 on RHEL6 with Oracle JVM. > I want to try to build a bulk loader for stock prices that I have > available in CSV format. However, I have started exploring Cassandra from > something easier, focussing on the example available in the manual. > > I cannot manage to have the bulk loader working as expected: once I > create the sstables and I import them with sstableloader, I cannot perform > anymore "select * from users" in the CQL console, or I get a java debug > stack trace on the logfile and an rpc time out in the CQL console. > > java.lang.RuntimeException: java.lang.IllegalArgumentException > at > org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:1582) > at > java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) > at java.lang.Thread.run(Thread.java:680) > Caused by: java.lang.IllegalArgumentException > at java.nio.Buffer.limit(Buffer.java:247) > at > org.apache.cassandra.db.marshal.AbstractCompositeType.getBytes(AbstractCompositeType.java:51) > at > org.apache.cassandra.db.marshal.AbstractCompositeType.getWithShortLength(AbstractCompositeType.java:60) > at > org.apache.cassandra.db.marshal.AbstractCompositeType.compare(AbstractCompositeType.java:78) > at > org.apache.cassandra.db.marshal.AbstractCompositeType.compare(AbstractCompositeType.java:31) > at java.util.TreeMap.getEntryUsingComparator(TreeMap.java:351) > at java.util.TreeMap.getEntry(TreeMap.java:322) > at java.util.TreeMap.containsKey(TreeMap.java:209) > at java.util.TreeSet.contains(TreeSet.java:217) > at > org.apache.cassandra.db.columniterator.SSTableNamesIterator.readSimpleColumns(SSTableNamesIterator.java:188) > at > org.apache.cassandra.db.columniterator.SSTableNamesIterator.read(SSTableNamesIterator.java:156) > at > org.apache.cassandra.db.columniterator.SSTableNamesIterator.(SSTableNamesIterator.java:83) > at > org.apache.cassandra.db.filter.NamesQueryFilter.getSSTableColumnIterator(NamesQueryFilter.java:86) > at > org.apache.cassandra.db.filter.QueryFilter.getSSTableColumnIterator(QueryFilter.java:75) > at > org.apache.cassandra.io.sstable.SSTableScanner$FilteredKeyScanningIterator$1.create(SSTableScanner.java:248) > at > org.apache.cassandra.db.columniterator.LazyColumnIterator.getSubIterator(LazyColumnIterator.java:75) > at > org.apache.cassandra.db.columniterator.LazyColumnIterator.getColumnFamily(LazyColumnIterator.java:87) > at > org.apache.cassandra.db.RowIteratorFactory$2.reduce(RowIteratorFactory.java:95) > at > org.apache.cassandra.db.RowIteratorFactory$2.reduce(RowIteratorFactory.java:79) > at > org.apache.cassandra.utils.MergeIterator$ManyToOne.consume(MergeIterator.java:111) > at > org.apache.cassandra.utils.MergeIterator$ManyToOne.computeNext(MergeIterator.java:97) > at > com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:143) > at > com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:138) > at > org.apache.cassandra.db.ColumnFamilyStore$3.computeNext(ColumnFamilyStore.java:1399) > at > org.apache.cassandra.db.ColumnFamilyStore$3.computeNext(ColumnFamilyStore.java:1395) > at > com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:143) > at > com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:138) > at > org.apache.cassandra.db.ColumnFamilyStore.filter(ColumnFamilyStore.java:1466) > at > org.apache.cassandra.db.ColumnFamilyStore.getRangeSlice(ColumnFamilyStore.java:1443) > at > org.apache.cassandra.service.RangeSliceVerbHandler.executeLocally(RangeSliceVerbHandler.java:46) > at > org.apache.cassandra.service.StorageProxy$LocalRangeSliceRunnable.runMayThrow(StorageProxy.java:1076) > at > org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:1578) > ... 3 more > > The code I am using is currently stored here: > https://gist.github.com/davideanastasia/5720903 > > What am I doing wrong? > > Thanks, > Davide > --001a11c37984ee65d204de8a4bd3 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable
Hi,
I've just tried to change it to integer = and I get exactly the same error.

Than= ks,
Davide


On 6 June 2013 23:53, Keith Wright <kwright@nanigans.com>= wrote:
Cou=
ld it be because you are writing age as a long but have it defined as an in=
teger in the table definition?

Davide Anastasia <davide.anastasia@gmail.com> wrote:
Hi,
I am currently using Cassandra 1.2.5 on RHEL6 with Oracle JVM.
I want to try to build a bulk loader for stock prices that I have avai= lable in CSV format. However, I have started exploring Cassandra from somet= hing easier, focussing on the example available in the manual.

I cannot manage to have the bulk loader working as expected: once I cr= eate the sstables and I import them with sstableloader, I cannot perform an= ymore "select * from users" in the CQL console, or I get a java d= ebug stack trace on the logfile and an rpc time out in the CQL console.

java.lang.RuntimeException: java.lang.IllegalArgumentException
at org.apache.cassandra.se= rvice.StorageProxy$DroppableRunnable.run(StorageProxy.java:1582)
at java.util.concurrent.Th= readPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.Th= readPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Th= read.java:680)
Caused by: java.lang.IllegalArgumentException
at java.nio.Buffer.limit(B= uffer.java:247)
at org.apache.cassandra.db= .marshal.AbstractCompositeType.getBytes(AbstractCompositeType.java:51)
at org.apache.cassandra.db= .marshal.AbstractCompositeType.getWithShortLength(AbstractCompositeType.jav= a:60)
at org.apache.cassandra.db= .marshal.AbstractCompositeType.compare(AbstractCompositeType.java:78)
at org.apache.cassandra.db= .marshal.AbstractCompositeType.compare(AbstractCompositeType.java:31)
at java.util.TreeMap.getEn= tryUsingComparator(TreeMap.java:351)
at java.util.TreeMap.getEn= try(TreeMap.java:322)
at java.util.TreeMap.conta= insKey(TreeMap.java:209)
at java.util.TreeSet.conta= ins(TreeSet.java:217)
at org.apache.cassandra.db= .columniterator.SSTableNamesIterator.readSimpleColumns(SSTableNamesIterator= .java:188)
at org.apache.cassandra.db= .columniterator.SSTableNamesIterator.read(SSTableNamesIterator.java:156)
at org.apache.cassandra.db= .columniterator.SSTableNamesIterator.<init>(SSTableNamesIterator.java= :83)
at org.apache.cassandra.db= .filter.NamesQueryFilter.getSSTableColumnIterator(NamesQueryFilter.java:86)=
at org.apache.cassandra.db= .filter.QueryFilter.getSSTableColumnIterator(QueryFilter.java:75)
at org.apache.cassandra.io= .sstable.SSTableScanner$FilteredKeyScanningIterator$1.create(SSTableScanner= .java:248)
at org.apache.cassandra.db= .columniterator.LazyColumnIterator.getSubIterator(LazyColumnIterator.java:7= 5)
at org.apache.cassandra.db= .columniterator.LazyColumnIterator.getColumnFamily(LazyColumnIterator.java:= 87)
at org.apache.cassandra.db= .RowIteratorFactory$2.reduce(RowIteratorFactory.java:95)
at org.apache.cassandra.db= .RowIteratorFactory$2.reduce(RowIteratorFactory.java:79)
at org.apache.cassandra.ut= ils.MergeIterator$ManyToOne.consume(MergeIterator.java:111)
at org.apache.cassandra.ut= ils.MergeIterator$ManyToOne.computeNext(MergeIterator.java:97)
at com.google.common.colle= ct.AbstractIterator.tryToComputeNext(AbstractIterator.java:143)
at com.google.common.colle= ct.AbstractIterator.hasNext(AbstractIterator.java:138)
at org.apache.cassandra.db= .ColumnFamilyStore$3.computeNext(ColumnFamilyStore.java:1399)
at org.apache.cassandra.db= .ColumnFamilyStore$3.computeNext(ColumnFamilyStore.java:1395)
at com.google.common.colle= ct.AbstractIterator.tryToComputeNext(AbstractIterator.java:143)
at com.google.common.colle= ct.AbstractIterator.hasNext(AbstractIterator.java:138)
at org.apache.cassandra.db= .ColumnFamilyStore.filter(ColumnFamilyStore.java:1466)
at org.apache.cassandra.db= .ColumnFamilyStore.getRangeSlice(ColumnFamilyStore.java:1443)
at org.apache.cassandra.se= rvice.RangeSliceVerbHandler.executeLocally(RangeSliceVerbHandler.java:46)
at org.apache.cassandra.se= rvice.StorageProxy$LocalRangeSliceRunnable.runMayThrow(StorageProxy.java:10= 76)
at org.apache.cassandra.se= rvice.StorageProxy$DroppableRunnable.run(StorageProxy.java:1578)
... 3 more

The code I am using is currently stored here:=A0https://gist.github= .com/davideanastasia/5720903

What am I doing wrong?

Thanks,
Davide

--001a11c37984ee65d204de8a4bd3--