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 0852CF1DF for ; Wed, 10 Apr 2013 04:22:51 +0000 (UTC) Received: (qmail 51338 invoked by uid 500); 10 Apr 2013 04:22:48 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 51086 invoked by uid 500); 10 Apr 2013 04:22:43 -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 51068 invoked by uid 99); 10 Apr 2013 04:22:43 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 10 Apr 2013 04:22:43 +0000 X-ASF-Spam-Status: No, hits=2.7 required=5.0 tests=FORGED_HOTMAIL_RCVD2,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of genx7up@gmail.com designates 209.85.220.53 as permitted sender) Received: from [209.85.220.53] (HELO mail-pa0-f53.google.com) (209.85.220.53) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 10 Apr 2013 04:22:36 +0000 Received: by mail-pa0-f53.google.com with SMTP id bh4so84128pad.40 for ; Tue, 09 Apr 2013 21:22:15 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:x-received:sender:date:x-google-sender-auth:message-id :subject:from:to:content-type; bh=Z4Ma9z+/+ievGL2uHwShzFnGDcrvKiaRR9lJ7MUn75g=; b=KQkLF/u6gmNrjvcV5HTFROE4FvGIDx9c3QbP5KLW4NH+A4X/sUAEKJbcW4Ec2Ga1JW /r+wGWHUMoZHxhfQOqVSIr6uQen1qg7c9Sm5jn7SqEezWXXyxNYkeXhhixBUjdlIRKR0 tAgm4sNtFokU/K7r0zsR1PB97Zt7JcKJdppMsyL+NXFcvGOEFBtWVa6krrK/Y7pZhPg2 +mbbhEfh5jKIXPujRjv3mY1B4gPGwmBHkKTrqSbqKzhsW6Xtix14wPQdqI4mLKc/MX4N ZZuoNGgTFYYZ5bs9xg4b/gSc9mCpv0qi6svLjfGW9xrJIJelqbdZyHpbwuaoDdjFwc9Q NEKQ== MIME-Version: 1.0 X-Received: by 10.69.3.4 with SMTP id bs4mr698926pbd.5.1365567735214; Tue, 09 Apr 2013 21:22:15 -0700 (PDT) Sender: genx7up@gmail.com Received: by 10.70.50.166 with HTTP; Tue, 9 Apr 2013 21:22:15 -0700 (PDT) Date: Tue, 9 Apr 2013 21:22:15 -0700 X-Google-Sender-Auth: 9pc_rcmwQqt8Y2r7Gbml5PiAa5A Message-ID: Subject: CDH4 + Cassandra 1.2 Integration Issue From: Gurminder Gill To: user@cassandra.apache.org Content-Type: multipart/alternative; boundary=047d7b5d57b2c638fe04d9fa0346 X-Virus-Checked: Checked by ClamAV on apache.org --047d7b5d57b2c638fe04d9fa0346 Content-Type: text/plain; charset=ISO-8859-1 I was able to start a MR job after patching Cassandra.Hadoop as per CASSANDRA-5201 . But then, ColumnFamilyRecordReader pukes within the MapTask. It is unable to read CF definition in the sample keyspace. The CF "user" does exist. *How can "cf_defs" below be possibly empty? Any pointers?* *KsDef.toString() during Read Operation from within the MapTask :-* * * KsDef(name:wordcount, strategy_class:org.apache.cassandra.locator.SimpleStrategy, strategy_options:{replication_factor=1}, *cf_defs:[]*, durable_writes:true) *Output from cqlsh :- * cqlsh> describe keyspace wordcount; CREATE KEYSPACE wordcount WITH replication = { 'class': 'SimpleStrategy', 'replication_factor': '1' }; USE wordcount; CREATE TABLE user ( id int PRIMARY KEY, age int, fname text, lname text ) WITH bloom_filter_fp_chance=0.010000 AND caching='KEYS_ONLY' AND comment='' AND dclocal_read_repair_chance=0.000000 AND gc_grace_seconds=864000 AND read_repair_chance=0.100000 AND replicate_on_write='true' AND compaction={'class': 'SizeTieredCompactionStrategy'} AND compression={'sstable_compression': 'SnappyCompressor'}; --047d7b5d57b2c638fe04d9fa0346 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable
I was able to start a MR job after patching Cas= sandra.Hadoop as per=A0CASSANDRA-5201.

But then, ColumnFamilyRecordReader pukes within the Ma= pTask. It is unable to read CF=A0definition=A0in the sample keyspace. The C= F "user" does exist.

How can "cf= _defs" below be possibly empty? Any pointers?

KsDef.toString()=A0during Read Oper= ation from within the MapTask :-

KsDef(= name:wordcount, strategy_class:org.apache.cassandra.locator.SimpleStrategy,= strategy_options:{replication_factor=3D1}, cf_defs:[], durable_writ= es:true)

Output from cqlsh :-

cqlsh> describe keyspace wordcount;

CREA= TE KEYSPACE wordcount WITH replication =3D {
=A0 'class':= 'SimpleStrategy',
=A0 'replication_factor': '1'
};
<= br>
USE wordcount;

CREATE TABLE user (
=A0 id int PRIMARY KEY,
=A0 age int,
=A0 fname= text,
=A0 lname text
) WITH
=A0 bloom_filter_fp_chance= =3D0.010000 AND
=A0 caching=3D'KEYS_ONLY' AND
= =A0 comment=3D'' AND
=A0 dclocal_read_repair_chance=3D0.0= 00000 AND
=A0 gc_grace_seconds=3D864000 AND
=A0 read_repair_chance=3D0.1000= 00 AND
=A0 replicate_on_write=3D'true' AND
=A0 = compaction=3D{'class': 'SizeTieredCompactionStrategy'} AND<= /div>
=A0 compression=3D{'sstable_compression': 'SnappyComp= ressor'};



--047d7b5d57b2c638fe04d9fa0346--