Return-Path: Delivered-To: apmail-cassandra-user-archive@www.apache.org Received: (qmail 40288 invoked from network); 8 Apr 2010 18:57:15 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 8 Apr 2010 18:57:15 -0000 Received: (qmail 16501 invoked by uid 500); 8 Apr 2010 18:57:13 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 16444 invoked by uid 500); 8 Apr 2010 18:57:13 -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 16426 invoked by uid 99); 8 Apr 2010 18:57:11 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 08 Apr 2010 18:57:11 +0000 X-ASF-Spam-Status: No, hits=0.0 required=10.0 tests=FREEMAIL_FROM,RCVD_IN_DNSWL_NONE,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of sonnyheer@gmail.com designates 209.85.160.44 as permitted sender) Received: from [209.85.160.44] (HELO mail-pw0-f44.google.com) (209.85.160.44) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 08 Apr 2010 18:57:06 +0000 Received: by pwj2 with SMTP id 2so2232047pwj.31 for ; Thu, 08 Apr 2010 11:56:46 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:mime-version:received:in-reply-to:references :date:received:message-id:subject:from:to:content-type :content-transfer-encoding; bh=Em3bDuIpVENCTOBP2cYlEtrkEeQcnz83HqoSZS3rKZA=; b=jJlpWXx0QtBITUqnYyguwz2SlCVIxtFaiJnh3QHLHOuZIOz8I+xqYMRz4mtSrpyKxN gY5O1I/n9K7jTLyTxGLwhPM0jboQWWziMPoG/0K77o9YwoaM0BaWTUd4a5ADyRGgyu5J XGhFl3hGfMnKjc5QGN9RhNYVyEhZ4ADQTMK4I= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type:content-transfer-encoding; b=Yh5MeW/+AR4RvCpVP+t1rRT/PJXvC9zBdCQCHLoMX+Kq98ynunjYT/ZfZiNH8iDUBN aAenA1+Q7PRULn8cePs8bPc4sDmBSSD0CuAKq6+CDUth8pRwsb1dGLUEa268lxiMQMHC 3bc90DYGECpBjqnQohwo6ULhAbbthD5vfonoM= MIME-Version: 1.0 Received: by 10.231.16.134 with HTTP; Thu, 8 Apr 2010 11:56:45 -0700 (PDT) In-Reply-To: References: <1270688863.48342873@192.168.2.229> Date: Thu, 8 Apr 2010 11:56:45 -0700 Received: by 10.115.114.34 with SMTP id r34mr979540wam.64.1270753005594; Thu, 08 Apr 2010 11:56:45 -0700 (PDT) Message-ID: Subject: Re: Iterate through entire data set From: Sonny Heer To: user@cassandra.apache.org Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable Yeah I agree it's strange, Windows is just my local box, and I'm testing before setting up actual boxes :) the thrift address is 'localhost' on the windows box. On Thu, Apr 8, 2010 at 11:53 AM, Benjamin Black wrote: > Strange setup, but, ok. =A0What is your setting on the > Windows machine? > > On Thu, Apr 8, 2010 at 11:44 AM, Sonny Heer wrote: >> I have two boxes. =A0One is a windows box running Cassandra .6, and the >> other is an ubuntu box from which I'm trying to run the word count >> program as in the readme. >> >> The windows box seed is set to 127.0.0.1, and listen address to localhos= t. >> >> The ubuntu box seed & listen is point to IP of the windows box. >> >> from contrib/word_count: >> >> ~/dev/cassandra-0.6.0-rc1/contrib/word_count$ ant >> Unable to locate tools.jar. Expected to find it in >> /usr/lib/jvm/java-6-openjdk/lib/tools.jar >> Buildfile: build.xml >> >> init: >> >> build: >> >> jar: >> =A0 =A0 =A0[jar] Building jar: >> /home/psheer/dev/cassandra-0.6.0-rc1/contrib/word_count/build/word_count= .jar >> >> BUILD SUCCESSFUL >> Total time: 2 seconds >> >> =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D >> >> ~/dev/cassandra-0.6.0-rc1/contrib/word_count$ bin/word_count_setup >> 10/04/08 10:33:18 INFO config.DatabaseDescriptor: Auto DiskAccessMode >> determined to be standard >> 10/04/08 10:33:18 WARN config.DatabaseDescriptor: KeysCachedFraction >> is deprecated: use KeysCached instead. >> 10/04/08 10:33:18 WARN config.DatabaseDescriptor: KeysCachedFraction >> is deprecated: use KeysCached instead. >> 10/04/08 10:33:18 INFO service.StorageService: Starting up client gossip >> Exception in thread "main" java.net.BindException: Cannot assign >> requested address >> =A0 =A0 =A0 =A0at sun.nio.ch.Net.bind(Native Method) >> =A0 =A0 =A0 =A0at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketCh= annelImpl.java:137) >> =A0 =A0 =A0 =A0at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdapto= r.java:77) >> =A0 =A0 =A0 =A0at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdapto= r.java:70) >> =A0 =A0 =A0 =A0at org.apache.cassandra.net.MessagingService.listen(Messa= gingService.java:138) >> =A0 =A0 =A0 =A0at org.apache.cassandra.service.StorageService.initClient= (StorageService.java:289) >> =A0 =A0 =A0 =A0at WordCountSetup.main(Unknown Source) >> >> >> Sorry, I'm a bit new to this... help? >> >> >> On Wed, Apr 7, 2010 at 6:07 PM, Stu Hood wrote: >>> Please read the README in the contrib/word_count directory. >>> >>> -----Original Message----- >>> From: "Sonny Heer" >>> Sent: Wednesday, April 7, 2010 6:33pm >>> To: user@cassandra.apache.org >>> Subject: Re: Iterate through entire data set >>> >>> Jon, >>> I've got the word_count.jar and a Hadoop cluster. =A0How do you usually >>> run this sample? >>> >>> >>> On Wed, Apr 7, 2010 at 3:04 PM, Jonathan Ellis wrot= e: >>>> Yes >>>> >>>> On Wed, Apr 7, 2010 at 5:01 PM, Sonny Heer wrote= : >>>>> These examples work on Cassandra .06 and Hadoop .20.2? >>>>> >>>>> On Wed, Apr 7, 2010 at 2:49 PM, Jonathan Ellis wr= ote: >>>>>> Look at the READMEs for contrib/word_count and contrib/pig. >>>>>> >>>>>> On Wed, Apr 7, 2010 at 4:47 PM, Sonny Heer wro= te: >>>>>>> I need a way to process all of my data set. >>>>>>> >>>>>>> A way to process every keyspace, CF, row, column, and perform some >>>>>>> operation based on that mapped combination. >>>>>>> >>>>>>> The map bucket would collect down to column name. >>>>>>> >>>>>>> Is there a map/reduce program which shows how to go about doing thi= s? >>>>>>> >>>>>> >>>>> >>>> >>> >>> >>> >> >