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 07A7665DD for ; Thu, 21 Jul 2011 08:29:55 +0000 (UTC) Received: (qmail 44200 invoked by uid 500); 21 Jul 2011 08:29:51 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 44025 invoked by uid 500); 21 Jul 2011 08:29:41 -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 44016 invoked by uid 99); 21 Jul 2011 08:29:38 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 21 Jul 2011 08:29:38 +0000 X-ASF-Spam-Status: No, hits=-0.7 required=5.0 tests=RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of sylvain@datastax.com designates 209.85.218.44 as permitted sender) Received: from [209.85.218.44] (HELO mail-yi0-f44.google.com) (209.85.218.44) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 21 Jul 2011 08:29:31 +0000 Received: by yie30 with SMTP id 30so594625yie.31 for ; Thu, 21 Jul 2011 01:29:10 -0700 (PDT) Received: by 10.236.185.134 with SMTP id u6mr13357937yhm.76.1311236950102; Thu, 21 Jul 2011 01:29:10 -0700 (PDT) MIME-Version: 1.0 Received: by 10.236.108.177 with HTTP; Thu, 21 Jul 2011 01:28:50 -0700 (PDT) X-Originating-IP: [88.183.33.171] In-Reply-To: References: From: Sylvain Lebresne Date: Thu, 21 Jul 2011 10:28:50 +0200 Message-ID: Subject: Re: What is the nodeId for? To: user@cassandra.apache.org Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable That looks very much the same, yes. -- Sylvain On Thu, Jul 21, 2011 at 3:15 AM, Boris Yen wrote: > Not sure if this is the same. I saw exceptions like this: > =A0INFO 15:33:49,336 Finished reading > /root/commitlog_tmp/CommitLog-1311135088656.log > ERROR 15:33:49,336 Exception encountered during startup. > java.lang.RuntimeException: java.util.concurrent.ExecutionException: > java.lang.AssertionError > =A0 =A0 =A0 =A0 at > org.apache.cassandra.utils.FBUtilities.waitOnFutures(FBUtilities.java:509= ) > =A0 =A0 =A0 =A0 at > org.apache.cassandra.db.commitlog.CommitLog.recover(CommitLog.java:332) > =A0 =A0 =A0 =A0 at > org.apache.cassandra.db.commitlog.CommitLog.recover(CommitLog.java:158) > =A0 =A0 =A0 =A0 at > org.apache.cassandra.service.AbstractCassandraDaemon.setup(AbstractCassan= draDaemon.java:174) > =A0 =A0 =A0 =A0 at > org.apache.cassandra.service.AbstractCassandraDaemon.activate(AbstractCas= sandraDaemon.java:315) > =A0 =A0 =A0 =A0 at > org.apache.cassandra.thrift.CassandraDaemon.main(CassandraDaemon.java:80) > Caused by: java.util.concurrent.ExecutionException: java.lang.AssertionEr= ror > =A0 =A0 =A0 =A0 at > java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:252) > =A0 =A0 =A0 =A0 at java.util.concurrent.FutureTask.get(FutureTask.java:11= 1) > =A0 =A0 =A0 =A0 at > org.apache.cassandra.utils.FBUtilities.waitOnFutures(FBUtilities.java:505= ) > =A0 =A0 =A0 =A0 ... 5 more > Caused by: java.lang.AssertionError > =A0 =A0 =A0 =A0 at > org.apache.cassandra.db.SystemTable.getCurrentLocalNodeId(SystemTable.jav= a:383) > =A0 =A0 =A0 =A0 at > org.apache.cassandra.utils.NodeId$LocalNodeIdHistory.(NodeId.java:1= 79) > =A0 =A0 =A0 =A0 at org.apache.cassandra.utils.NodeId.(NodeId.java= :38) > =A0 =A0 =A0 =A0 at > org.apache.cassandra.db.context.CounterContext$ContextState.getNodeId(Cou= nterContext.java:722) > =A0 =A0 =A0 =A0 at > org.apache.cassandra.db.context.CounterContext.merge(CounterContext.java:= 333) > =A0 =A0 =A0 =A0 at > org.apache.cassandra.db.CounterColumn.reconcile(CounterColumn.java:159) > =A0 =A0 =A0 =A0 at > org.apache.cassandra.db.SuperColumn.addColumn(SuperColumn.java:185) > =A0 =A0 =A0 =A0 at > org.apache.cassandra.db.SuperColumn.putColumn(SuperColumn.java:204) > =A0 =A0 =A0 =A0 at > org.apache.cassandra.db.ColumnFamily.addColumn(ColumnFamily.java:228) > =A0 =A0 =A0 =A0 at > org.apache.cassandra.db.ColumnFamily.addAll(ColumnFamily.java:131) > =A0 =A0 =A0 =A0 at > org.apache.cassandra.db.ColumnFamily.resolve(ColumnFamily.java:414) > =A0 =A0 =A0 =A0 at org.apache.cassandra.db.Memtable.resolve(Memtable.java= :218) > =A0 =A0 =A0 =A0 at org.apache.cassandra.db.Memtable.put(Memtable.java:148= ) > =A0 =A0 =A0 =A0 at > org.apache.cassandra.db.ColumnFamilyStore.apply(ColumnFamilyStore.java:77= 4) > =A0 =A0 =A0 =A0 at org.apache.cassandra.db.Table.apply(Table.java:451) > =A0 =A0 =A0 =A0 at > org.apache.cassandra.db.commitlog.CommitLog$2.runMayThrow(CommitLog.java:= 324) > =A0 =A0 =A0 =A0 at > org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:30) > =A0 =A0 =A0 =A0 at > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) > =A0 =A0 =A0 =A0 at > java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334) > =A0 =A0 =A0 =A0 at java.util.concurrent.FutureTask.run(FutureTask.java:16= 6) > =A0 =A0 =A0 =A0 at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java= :1110) > =A0 =A0 =A0 =A0 at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.jav= a:603) > =A0 =A0 =A0 =A0 at java.lang.Thread.run(Thread.java:636) > On Wed, Jul 20, 2011 at 11:42 PM, Sylvain Lebresne > wrote: >> >> Possibly, you've hitted this: >> https://issues.apache.org/jira/browse/CASSANDRA-2824 >> Should be fixed in next minor release. >> >> In the meantime, you "fix" should be alright. >> >> -- >> Sylvain >> >> >> On Wed, Jul 20, 2011 at 3:47 PM, Boris Yen wrote: >> > Hi Sam, >> > Thanks for the explanation. >> > The NodeIds do appear in the Local row of NodeIdInfo, and after manual= ly >> > deleting two (I got three before I deleted them) of them from >> > CurrentLocal >> > row, the cassandra can be restarted now. I was just thinking what coul= d >> > be >> > the possible cause for this? and wondering if anyone has any idea abou= t >> > this? >> > Boris >> > >> > On Wed, Jul 20, 2011 at 8:00 PM, Sam Overton wrot= e: >> >> >> >> The NodeId is used in counter replication. Counters are stored on eac= h >> >> replica as a set of "shards," where each shard corresponds to the loc= al >> >> count of one of the replicas for that counter, as identified by the >> >> NodeId. >> >> A NodeId is generated the first time cassandra starts, and might be >> >> renewed during cleanup, or if you explicitly tell cassandra to genera= te >> >> a >> >> new one by starting it with -Dcassandra.renew_counter_id >> >> Do either of the NodeIds in the CurrentLocal row also appear in the >> >> Local >> >> row of the NodeIdInfo CF? the Local row is a history of previous >> >> NodeIds >> >> belonging to this node. If one appears in the history and the other >> >> does >> >> not, it is probably safe to assume that the old NodeId was not delete= d >> >> from >> >> the CurrentLocal row correctly, and so you could try removing it from >> >> there >> >> manually. >> >> >> >> Sam >> >> -- >> >> Sam Overton >> >> Acunu |=A0http://www.acunu.com=A0| @acunu >> >> On 20 July 2011 12:25, Boris Yen wrote: >> >>> >> >>> Hi, >> >>> I think we might have screwed our data up. I saw multiple columns >> >>> inside >> >>> record: System.NodeIdInfo.CurrentLocal. It makes our cassandra dead >> >>> forever. >> >>> I was wondering if anyone could tell me what the NodeId is for? so >> >>> that I >> >>> might be able to duplicate this. >> >>> Thanks in advance >> >>> Boris >> > >> > > >