Mailing-List: contact commits-help@cassandra.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@cassandra.apache.org
Date: Fri, 24 Aug 2012 14:36:42 +1100 (NCT)
From: "Jonathan Ellis (JIRA)" <jira@apache.org>
To: commits@cassandra.apache.org
Message-ID: <1228707630.9177.1345779402783.JavaMail.jiratomcat@arcas>
In-Reply-To: <1179221668.1402.1345657422621.JavaMail.jiratomcat@arcas>
Subject: [jira] [Commented] (CASSANDRA-4567) Error in log related to
 Murmur3Partitioner
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit


    [ https://issues.apache.org/jira/browse/CASSANDRA-4567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13440907#comment-13440907 ] 

Jonathan Ellis commented on CASSANDRA-4567:
-------------------------------------------

Should we just ignore the partitioner after first startup, the way we do with initial_token?
                
> Error in log related to Murmur3Partitioner
> ------------------------------------------
>
>                 Key: CASSANDRA-4567
>                 URL: https://issues.apache.org/jira/browse/CASSANDRA-4567
>             Project: Cassandra
>          Issue Type: Bug
>          Components: Core
>    Affects Versions: 1.2.0
>         Environment: Using ccm on ubuntu
>            Reporter: Tyler Patterson
>            Assignee: Pavel Yaskevich
>             Fix For: 1.2.0
>
>
> Start a 2-node cluster on cassandra-1.1. Bring down one node, upgrade it to trunk, start it back up. The following error shows up in the log:
> {code}
> ...
>  INFO [main] 2012-08-22 10:44:40,012 CacheService.java (line 170) Scheduling row cache save to each 0 seconds (going to save all keys).
>  INFO [SSTableBatchOpen:1] 2012-08-22 10:44:40,106 SSTableReader.java (line 164) Opening /tmp/dtest-IYHWfV/test/node1/data/system/LocationInfo/system-LocationInfo-he-2 (148 bytes)
>  INFO [SSTableBatchOpen:2] 2012-08-22 10:44:40,106 SSTableReader.java (line 164) Opening /tmp/dtest-IYHWfV/test/node1/data/system/LocationInfo/system-LocationInfo-he-1 (226 bytes)
>  INFO [SSTableBatchOpen:3] 2012-08-22 10:44:40,106 SSTableReader.java (line 164) Opening /tmp/dtest-IYHWfV/test/node1/data/system/LocationInfo/system-LocationInfo-he-3 (89 bytes)
> ERROR [SSTableBatchOpen:3] 2012-08-22 10:44:40,114 CassandraDaemon.java (line 131) Exception in thread Thread[SSTableBatchOpen:3,5,main]
> java.lang.RuntimeException: Cannot open /tmp/dtest-IYHWfV/test/node1/data/system/LocationInfo/system-LocationInfo-he-3 because partitioner does not match org.apache.cassandra.dht.Murmur3Partitioner
>         at org.apache.cassandra.io.sstable.SSTableReader.open(SSTableReader.java:175)
>         at org.apache.cassandra.io.sstable.SSTableReader.open(SSTableReader.java:149)
>         at org.apache.cassandra.io.sstable.SSTableReader$1.run(SSTableReader.java:236)
>         at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
>         at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
>         at java.util.concurrent.FutureTask.run(FutureTask.java:138)
>         at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
>         at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
>         at java.lang.Thread.run(Thread.java:662)
> ERROR [SSTableBatchOpen:2] 2012-08-22 10:44:40,114 CassandraDaemon.java (line 131) Exception in thread Thread[SSTableBatchOpen:2,5,main]
> java.lang.RuntimeException: Cannot open /tmp/dtest-IYHWfV/test/node1/data/system/LocationInfo/system-LocationInfo-he-1 because partitioner does not match org.apache.cassandra.dht.Murmur3Partitioner
>         at org.apache.cassandra.io.sstable.SSTableReader.open(SSTableReader.java:175)
>         at org.apache.cassandra.io.sstable.SSTableReader.open(SSTableReader.java:149)
>         at org.apache.cassandra.io.sstable.SSTableReader$1.run(SSTableReader.java:236)
>         at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
>         at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
>         at java.util.concurrent.FutureTask.run(FutureTask.java:138)
>         at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
>         at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
>         at java.lang.Thread.run(Thread.java:662)
> ERROR [SSTableBatchOpen:1] 2012-08-22 10:44:40,114 CassandraDaemon.java (line 131) Exception in thread Thread[SSTableBatchOpen:1,5,main]
> java.lang.RuntimeException: Cannot open /tmp/dtest-IYHWfV/test/node1/data/system/LocationInfo/system-LocationInfo-he-2 because partitioner does not match org.apache.cassandra.dht.Murmur3Partitioner
>         at org.apache.cassandra.io.sstable.SSTableReader.open(SSTableReader.java:175)
>         at org.apache.cassandra.io.sstable.SSTableReader.open(SSTableReader.java:149)
>         at org.apache.cassandra.io.sstable.SSTableReader$1.run(SSTableReader.java:236)
>         at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
>         at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
>         at java.util.concurrent.FutureTask.run(FutureTask.java:138)
>         at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
>         at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
>         at java.lang.Thread.run(Thread.java:662)
>  INFO [main] 2012-08-22 10:44:40,486 DatabaseDescriptor.java (line 522) Couldn't detect any schema definitions in local storage.
>  INFO [main] 2012-08-22 10:44:40,487 DatabaseDescriptor.java (line 525) Found table data in data directories. Consider using the CLI to define your schema.
> ...
> {code}
> Note that the error does not happen when upgrading from cassandra-1.0 to cassandra-1.1, or when "upgrading" from trunk to trunk.
> This is the exact dtest I used:
> {code}
> from dtest import Tester, debug
> FROM_VERSION = 'git:cassandra-1.1'
> TO_VERSION = 'git:trunk'
> class TestUpgradeOneNode(Tester):
>     def upgrade_test(self):
>         # Start a cluster
>         cluster = self.cluster
>         cluster.set_cassandra_dir(cassandra_version=FROM_VERSION)
>         cluster.populate(2).start()
>         node1 = cluster.nodelist()[0]
>         node1.watch_log_for('Listening for thrift clients...')
>         # Bring one node down and upgrade it.
>         node1.flush()
>         node1.stop(wait_other_notice=True)
>         node1.set_cassandra_dir(cassandra_version=TO_VERSION)
>         node1.start(wait_other_notice=True)
> {code}

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira