From user-return-34495-apmail-cassandra-user-archive=cassandra.apache.org@cassandra.apache.org Thu Jun 6 22:54:25 2013 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 4EAC81010E for ; Thu, 6 Jun 2013 22:54:25 +0000 (UTC) Received: (qmail 18630 invoked by uid 500); 6 Jun 2013 22:54:21 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 18594 invoked by uid 500); 6 Jun 2013 22:54:21 -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 18539 invoked by uid 99); 6 Jun 2013 22:54:21 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 06 Jun 2013 22:54:21 +0000 X-ASF-Spam-Status: No, hits=2.2 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_NONE,UNPARSEABLE_RELAY X-Spam-Check-By: apache.org Received-SPF: error (nike.apache.org: local policy) Received: from [216.82.243.196] (HELO mail1.bemta8.messagelabs.com) (216.82.243.196) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 06 Jun 2013 22:54:14 +0000 Received: from [216.82.242.115:42457] by server-4.bemta-8.messagelabs.com id 91/6E-09999-DE211B15; Thu, 06 Jun 2013 22:53:33 +0000 X-Env-Sender: kwright@nanigans.com X-Msg-Ref: server-2.tower-132.messagelabs.com!1370559211!12253331!2 X-Originating-IP: [216.166.12.98] X-StarScan-Received: X-StarScan-Version: 6.9.6; banners=-,-,- X-VirusChecked: Checked Received: (qmail 7285 invoked from network); 6 Jun 2013 22:53:32 -0000 Received: from out001.collaborationhost.net (HELO out001.collaborationhost.net) (216.166.12.98) by server-2.tower-132.messagelabs.com with RC4-SHA encrypted SMTP; 6 Jun 2013 22:53:32 -0000 Received: from AUSP01VMBX28.collaborationhost.net ([192.168.20.73]) by AUSP01MHUB07.collaborationhost.net ([10.2.8.242]) with mapi; Thu, 6 Jun 2013 17:53:31 -0500 From: Keith Wright To: "user@cassandra.apache.org" Date: Thu, 6 Jun 2013 17:53:31 -0500 Subject: Re: Bulk loader with Cassandra 1.2.5 Thread-Topic: Bulk loader with Cassandra 1.2.5 Thread-Index: Ac5jB7MDZvdvWz0iSIuSVVBkkm0vOgAAPd/m Message-ID: <8hfbdl3gqxjmlyc1sh0dfpfr.1370559209572@email.android.com> Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: acceptlanguage: en-US Content-Type: multipart/alternative; boundary="_000_8hfbdl3gqxjmlyc1sh0dfpfr1370559209572emailandroidcom_" MIME-Version: 1.0 X-Virus-Checked: Checked by ClamAV on apache.org --_000_8hfbdl3gqxjmlyc1sh0dfpfr1370559209572emailandroidcom_ Content-Type: text/plain; charset="iso-8859-1" Content-Transfer-Encoding: quoted-printable 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 trac= e 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(StorageP= roxy.java:1582) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecuto= r.java:895) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.ja= va: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(AbstractC= ompositeType.java:51) at org.apache.cassandra.db.marshal.AbstractCompositeType.getWithShortLength= (AbstractCompositeType.java:60) at org.apache.cassandra.db.marshal.AbstractCompositeType.compare(AbstractCo= mpositeType.java:78) at org.apache.cassandra.db.marshal.AbstractCompositeType.compare(AbstractCo= mpositeType.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.readSimpleCo= lumns(SSTableNamesIterator.java:188) at org.apache.cassandra.db.columniterator.SSTableNamesIterator.read(SSTable= NamesIterator.java:156) at org.apache.cassandra.db.columniterator.SSTableNamesIterator.(SSTab= leNamesIterator.java:83) at org.apache.cassandra.db.filter.NamesQueryFilter.getSSTableColumnIterator= (NamesQueryFilter.java:86) at org.apache.cassandra.db.filter.QueryFilter.getSSTableColumnIterator(Quer= yFilter.java:75) at org.apache.cassandra.io.sstable.SSTableScanner$FilteredKeyScanningIterat= or$1.create(SSTableScanner.java:248) at org.apache.cassandra.db.columniterator.LazyColumnIterator.getSubIterator= (LazyColumnIterator.java:75) at org.apache.cassandra.db.columniterator.LazyColumnIterator.getColumnFamil= y(LazyColumnIterator.java:87) at org.apache.cassandra.db.RowIteratorFactory$2.reduce(RowIteratorFactory.j= ava:95) at org.apache.cassandra.db.RowIteratorFactory$2.reduce(RowIteratorFactory.j= ava:79) at org.apache.cassandra.utils.MergeIterator$ManyToOne.consume(MergeIterator= .java:111) at org.apache.cassandra.utils.MergeIterator$ManyToOne.computeNext(MergeIter= ator.java:97) at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIter= ator.java:143) at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java= :138) at org.apache.cassandra.db.ColumnFamilyStore$3.computeNext(ColumnFamilyStor= e.java:1399) at org.apache.cassandra.db.ColumnFamilyStore$3.computeNext(ColumnFamilyStor= e.java:1395) at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIter= ator.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(ColumnFamilyStor= e.java:1443) at org.apache.cassandra.service.RangeSliceVerbHandler.executeLocally(RangeS= liceVerbHandler.java:46) at org.apache.cassandra.service.StorageProxy$LocalRangeSliceRunnable.runMay= Throw(StorageProxy.java:1076) at org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageP= roxy.java:1578) ... 3 more The code I am using is currently stored here: https://gist.github.com/david= eanastasia/5720903 What am I doing wrong? Thanks, Davide --_000_8hfbdl3gqxjmlyc1sh0dfpfr1370559209572emailandroidcom_ Content-Type: text/html; charset="iso-8859-1" Content-Transfer-Encoding: quoted-printable
Could it be because you are writing age as a long but have it d=
efined as an integer in the table definition?=0A=
=0A=
Davide Anastasia <davide.anastasia@gmail.com> wrote:=0A=
=0A=
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.cassan= dra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:1582)
at java.util.concurr= ent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurr= ent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.= run(Thread.java:680)
Caused by: java.lang.IllegalArgumentException
at java.nio.Buffer.l= imit(Buffer.java:247)
at org.apache.cassan= dra.db.marshal.AbstractCompositeType.getBytes(AbstractCompositeType.java:51= )
at org.apache.cassan= dra.db.marshal.AbstractCompositeType.getWithShortLength(AbstractCompositeTy= pe.java:60)
at org.apache.cassan= dra.db.marshal.AbstractCompositeType.compare(AbstractCompositeType.java:78)=
at org.apache.cassan= dra.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.cassan= dra.db.columniterator.SSTableNamesIterator.readSimpleColumns(SSTableNamesIt= erator.java:188)
at org.apache.cassan= dra.db.columniterator.SSTableNamesIterator.read(SSTableNamesIterator.java:1= 56)
at org.apache.cassan= dra.db.columniterator.SSTableNamesIterator.<init>(SSTableNamesIterato= r.java:83)
at org.apache.cassan= dra.db.filter.NamesQueryFilter.getSSTableColumnIterator(NamesQueryFilter.ja= va:86)
at org.apache.cassan= dra.db.filter.QueryFilter.getSSTableColumnIterator(QueryFilter.java:75)
at org.apache.cassan= dra.io.sstable.SSTableScanner$FilteredKeyScanningIterator$1.create(SSTableS= canner.java:248)
at org.apache.cassan= dra.db.columniterator.LazyColumnIterator.getSubIterator(LazyColumnIterator.= java:75)
at org.apache.cassan= dra.db.columniterator.LazyColumnIterator.getColumnFamily(LazyColumnIterator= .java:87)
at org.apache.cassan= dra.db.RowIteratorFactory$2.reduce(RowIteratorFactory.java:95)
at org.apache.cassan= dra.db.RowIteratorFactory$2.reduce(RowIteratorFactory.java:79)
at org.apache.cassan= dra.utils.MergeIterator$ManyToOne.consume(MergeIterator.java:111)
at org.apache.cassan= dra.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.cassan= dra.db.ColumnFamilyStore$3.computeNext(ColumnFamilyStore.java:1399)
at org.apache.cassan= dra.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.cassan= dra.db.ColumnFamilyStore.filter(ColumnFamilyStore.java:1466)
at org.apache.cassan= dra.db.ColumnFamilyStore.getRangeSlice(ColumnFamilyStore.java:1443)
at org.apache.cassan= dra.service.RangeSliceVerbHandler.executeLocally(RangeSliceVerbHandler.java= :46)
at org.apache.cassan= dra.service.StorageProxy$LocalRangeSliceRunnable.runMayThrow(StorageProxy.j= ava:1076)
at org.apache.cassan= dra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:1578)
... 3 more

The code I am using is currently stored here: https://gist.git= hub.com/davideanastasia/5720903

What am I doing wrong?

Thanks,
Davide
--_000_8hfbdl3gqxjmlyc1sh0dfpfr1370559209572emailandroidcom_--