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 2D1C09528 for ; Thu, 1 Mar 2012 11:26:06 +0000 (UTC) Received: (qmail 70898 invoked by uid 500); 1 Mar 2012 11:26:03 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 70868 invoked by uid 500); 1 Mar 2012 11:26:03 -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 70860 invoked by uid 99); 1 Mar 2012 11:26:03 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 01 Mar 2012 11:26:03 +0000 X-ASF-Spam-Status: No, hits=1.7 required=5.0 tests=FREEMAIL_ENVFROM_END_DIGIT,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of mccloud35@gmail.com designates 209.85.213.172 as permitted sender) Received: from [209.85.213.172] (HELO mail-yx0-f172.google.com) (209.85.213.172) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 01 Mar 2012 11:25:59 +0000 Received: by yenm5 with SMTP id m5so152313yen.31 for ; Thu, 01 Mar 2012 03:25:38 -0800 (PST) Received-SPF: pass (google.com: domain of mccloud35@gmail.com designates 10.236.186.98 as permitted sender) client-ip=10.236.186.98; Authentication-Results: mr.google.com; spf=pass (google.com: domain of mccloud35@gmail.com designates 10.236.186.98 as permitted sender) smtp.mail=mccloud35@gmail.com; dkim=pass header.i=mccloud35@gmail.com Received: from mr.google.com ([10.236.186.98]) by 10.236.186.98 with SMTP id v62mr6362832yhm.22.1330601138724 (num_hops = 1); Thu, 01 Mar 2012 03:25:38 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=PU7CUy2gaCQYkN3P+9uedul9w56E8kZnmzM44igr0mE=; b=ouXMXhOoRDuSsp5PIMwb/wQ/P7h8DTHmM8kjun97AKF2Lgs8txy4yyMc7Vl8fMQsdY bljBUPhbe0oi+UWABwu9n3R5sFgH3npTucksOpI+Uno8cdDZbqnD404AxVCxg3Oa/4Lm 18PX6BA2U4opxHXOndDcK0h74MJHW48aQc7es= MIME-Version: 1.0 Received: by 10.236.186.98 with SMTP id v62mr4945458yhm.22.1330601138652; Thu, 01 Mar 2012 03:25:38 -0800 (PST) Received: by 10.236.177.4 with HTTP; Thu, 1 Mar 2012 03:25:38 -0800 (PST) In-Reply-To: References: <05CEA178DD88EE4FA89EED77C245F84916414DAF@msex85.morningstar.com> Date: Thu, 1 Mar 2012 16:55:38 +0530 Message-ID: Subject: Re: Schema change causes exception when adding data From: Tharindu Mathew To: user@cassandra.apache.org Content-Type: multipart/alternative; boundary=20cf30549a2f35055b04ba2cb85d X-Virus-Checked: Checked by ClamAV on apache.org --20cf30549a2f35055b04ba2cb85d Content-Type: text/plain; charset=windows-1252 Content-Transfer-Encoding: quoted-printable On Thu, Mar 1, 2012 at 11:47 AM, Tharindu Mathew wrote= : > Jeremiah, > > Thanks for the reply. > > This is what we have been doing, but it's not reliable as we don't know a > definite time that the schema would get replicated. Is there any way I ca= n > know for sure that changes have propagated? > [Edit: corrected to a question] > > Then I can block the insertion of data until then. > > > On Thu, Mar 1, 2012 at 4:33 AM, Jeremiah Jordan < > JEREMIAH.JORDAN@morningstar.com> wrote: > >> The error is that the specified colum family doesn=92t exist. If you >> connect with the CLI and describe the keyspace does it show up? Also, >> after adding a new column family programmatically you can=92t use it >> immediately, you have to wait for it to propagate. You can use calls to >> describe schema to do so, keep calling it until every node is on the sam= e >> schema.**** >> >> ** ** >> >> -Jeremiah**** >> >> ** ** >> >> *From:* Tharindu Mathew [mailto:mccloud35@gmail.com] >> *Sent:* Wednesday, February 29, 2012 8:27 AM >> *To:* user >> *Subject:* Schema change causes exception when adding data**** >> >> ** ** >> >> Hi, >> >> I have a 3 node cluster and I'm dynamically updating a keyspace with a >> new column family. Then, when I try to write records to it I get the >> following exception shown at [1]. >> >> How do I avoid this. I'm using Hector and the default consistency level >> of QUORUM is used. Cassandra version 0.7.8. Replication Factor is 1. >> >> How can I solve my problem?**** >> >> [1] - >> me.prettyprint.hector.api.exceptions.HInvalidRequestException: >> InvalidRequestException(why:unconfigured columnfamily proxySummary)**** >> >> at >> me.prettyprint.cassandra.service.ExceptionsTranslatorImpl.translate(Exce= ptionsTranslatorImpl.java:42) >> **** >> >> at >> me.prettyprint.cassandra.service.KeyspaceServiceImpl$10.execute(Keyspace= ServiceImpl.java:397) >> **** >> >> at >> me.prettyprint.cassandra.service.KeyspaceServiceImpl$10.execute(Keyspace= ServiceImpl.java:383) >> **** >> >> at >> me.prettyprint.cassandra.service.Operation.executeAndSetResult(Operation= .java:101) >> **** >> >> at >> me.prettyprint.cassandra.connection.HConnectionManager.operateWithFailov= er(HConnectionManager.java:156) >> **** >> >> at >> me.prettyprint.cassandra.service.KeyspaceServiceImpl.operateWithFailover= (KeyspaceServiceImpl.java:129) >> **** >> >> at >> me.prettyprint.cassandra.service.KeyspaceServiceImpl.multigetSlice(Keysp= aceServiceImpl.java:401) >> **** >> >> at >> me.prettyprint.cassandra.model.thrift.ThriftMultigetSliceQuery$1.doInKey= space(ThriftMultigetSliceQuery.java:67) >> **** >> >> at >> me.prettyprint.cassandra.model.thrift.ThriftMultigetSliceQuery$1.doInKey= space(ThriftMultigetSliceQuery.java:59) >> **** >> >> at >> me.prettyprint.cassandra.model.KeyspaceOperationCallback.doInKeyspaceAnd= Measure(KeyspaceOperationCallback.java:20) >> **** >> >> at >> me.prettyprint.cassandra.model.ExecutingKeyspace.doExecute(ExecutingKeys= pace.java:72) >> **** >> >> at >> me.prettyprint.cassandra.model.thrift.ThriftMultigetSliceQuery.execute(T= hriftMultigetSliceQuery.java:58) >> **** >> >> >> >> -- >> Regards, >> >> Tharindu**** >> >> ** ** >> >> blog: http://mackiemathew.com/**** >> >> ** ** >> > > > > -- > Regards, > > Tharindu > > blog: http://mackiemathew.com/ > > --=20 Regards, Tharindu blog: http://mackiemathew.com/ --20cf30549a2f35055b04ba2cb85d Content-Type: text/html; charset=windows-1252 Content-Transfer-Encoding: quoted-printable

On Thu, Mar 1, 2012 at 11:47 AM, Tharind= u Mathew <mcclo= ud35@gmail.com> wrote:
Jeremiah,

Thanks for the reply.

This is what we have been doi= ng, but it's not reliable as we don't know a definite time that the= schema would get replicated. Is there any way I can know for sure that cha= nges have propagated?
[Edit: corrected to a question]

Then I can block the insertion of data until then.


On Thu, Mar 1, 2012 a= t 4:33 AM, Jeremiah Jordan <JEREMIAH.JORDAN@morningstar.com<= /a>> wrote:

The error is that the spe= cified colum family doesn=92t exist.=A0 If you connect with the CLI and describe the keyspace does it show up?=A0 Also= , after adding a new column family programmatically you can=92t use it immediately,= you have to wait for it to propagate.=A0 You can use calls to describe schema t= o do so, keep calling it until every node is on the same schema.

=A0<= /p>

-Jeremiah

=A0<= /p>

From: Tharindu= Mathew [mailto:mccloud35@= gmail.com]
Sent: Wednesday, February 29, 2012 8:27 AM
To: user
Subject: Schema change causes exception when adding data

=A0

Hi,

I have a 3 node cluster and I'm dynamically updating a keyspace with a = new column family. Then, when I try to write records to it I get the following exception shown at [1].

How do I avoid this. I'm using Hector and the default consistency level= of QUORUM is used. Cassandra version 0.7.8. Replication Factor is 1.

How can I solve my problem?

[1] -
me.prettyprint.hector.api.exceptions.HInvalidRequestException: InvalidRequestException(why:unconfigured columnfamily proxySummary)<= u>

at me.prettyprint.cassandra.service.ExceptionsTranslatorImpl.translate(Excepti= onsTranslatorImpl.java:42)

at me.prettyprint.cassandra.service.KeyspaceServiceI= mpl$10.execute(KeyspaceServiceImpl.java:397)

at me.prettyprint.cassandra.service.KeyspaceServiceImpl$10.execute(KeyspaceSer= viceImpl.java:383)

at me.prettyprint.cassandra.service.Operation.executeAndSetResult(Operation.ja= va:101)

at me.prettyprint.cassandra.connection.HConnectionManager.operateWithFailover(= HConnectionManager.java:156)

at me.prettyprint.cassandra.service.KeyspaceServiceImpl.operateWithFailover(Ke= yspaceServiceImpl.java:129)

at me.prettyprint.cassandra.service.KeyspaceServiceI= mpl.multigetSlice(KeyspaceServiceImpl.java:401)

at me.prettyprint.cassandra.model.thrift.ThriftMultigetSliceQuery$1.doInKeyspa= ce(ThriftMultigetSliceQuery.java:67)

at me.prettyprint.cassandra.model.thrift.ThriftMultigetSliceQuery$1.doInKeyspa= ce(ThriftMultigetSliceQuery.java:59)

at me.prettyprint.cassandra.model.KeyspaceOperationCallback.doInKeyspaceAndMea= sure(KeyspaceOperationCallback.java:20)

at me.prettyprint.cassandra.model.ExecutingKeyspace.doExecute(ExecutingKeyspac= e.java:72)

at me.prettyprint.cassandra.model.thrift.ThriftMulti= getSliceQuery.execute(ThriftMultigetSliceQuery.java:58)



--
Regards,

Tharindu

=A0

=A0




--
Regards,

Tharind= u





--
Regards,
Tharindu


--20cf30549a2f35055b04ba2cb85d--