You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by "Brandon Williams (JIRA)" <ji...@apache.org> on 2015/02/06 19:35:35 UTC
[jira] [Updated] (CASSANDRA-8448) "Comparison method violates its
general contract" in AbstractEndpointSnitch
[ https://issues.apache.org/jira/browse/CASSANDRA-8448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Brandon Williams updated CASSANDRA-8448:
----------------------------------------
Attachment: 8448-v2.txt
bq. The current patch is a no-op...?
Whoops, that was silly :)
I think creating a new DES within DES just to sort is going to get very hairy very quickly. Instead, v2 locks the update and reset tasks so they can't modify scores while we're sorting. This shouldn't be a big problem if they're blocked for a while during the sort.
> "Comparison method violates its general contract" in AbstractEndpointSnitch
> ---------------------------------------------------------------------------
>
> Key: CASSANDRA-8448
> URL: https://issues.apache.org/jira/browse/CASSANDRA-8448
> Project: Cassandra
> Issue Type: Bug
> Reporter: J.B. Langston
> Assignee: Brandon Williams
> Fix For: 2.1.3, 2.0.13
>
> Attachments: 8448-v2.txt, 8448.txt
>
>
> Seen in both 1.2 and 2.0. The error is occurring here: https://github.com/apache/cassandra/blob/cassandra-2.0/src/java/org/apache/cassandra/locator/AbstractEndpointSnitch.java#L49
> {code}
> ERROR [Thrift:9] 2014-12-04 20:12:28,732 CustomTThreadPoolServer.java (line 219) Error occurred during processing of message.
> com.google.common.util.concurrent.UncheckedExecutionException: java.lang.IllegalArgumentException: Comparison method violates its general contract!
> at com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2199)
> at com.google.common.cache.LocalCache.get(LocalCache.java:3932)
> at com.google.common.cache.LocalCache.getOrLoad(LocalCache.java:3936)
> at com.google.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4806)
> at org.apache.cassandra.service.ClientState.authorize(ClientState.java:352)
> at org.apache.cassandra.service.ClientState.ensureHasPermission(ClientState.java:224)
> at org.apache.cassandra.service.ClientState.hasAccess(ClientState.java:218)
> at org.apache.cassandra.service.ClientState.hasColumnFamilyAccess(ClientState.java:202)
> at org.apache.cassandra.thrift.CassandraServer.createMutationList(CassandraServer.java:822)
> at org.apache.cassandra.thrift.CassandraServer.batch_mutate(CassandraServer.java:954)
> at com.datastax.bdp.server.DseServer.batch_mutate(DseServer.java:576)
> at org.apache.cassandra.thrift.Cassandra$Processor$batch_mutate.getResult(Cassandra.java:3922)
> at org.apache.cassandra.thrift.Cassandra$Processor$batch_mutate.getResult(Cassandra.java:3906)
> at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:39)
> at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:39)
> at org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:201)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: java.lang.IllegalArgumentException: Comparison method violates its general contract!
> at java.util.TimSort.mergeHi(TimSort.java:868)
> at java.util.TimSort.mergeAt(TimSort.java:485)
> at java.util.TimSort.mergeCollapse(TimSort.java:410)
> at java.util.TimSort.sort(TimSort.java:214)
> at java.util.TimSort.sort(TimSort.java:173)
> at java.util.Arrays.sort(Arrays.java:659)
> at java.util.Collections.sort(Collections.java:217)
> at org.apache.cassandra.locator.AbstractEndpointSnitch.sortByProximity(AbstractEndpointSnitch.java:49)
> at org.apache.cassandra.locator.DynamicEndpointSnitch.sortByProximityWithScore(DynamicEndpointSnitch.java:157)
> at org.apache.cassandra.locator.DynamicEndpointSnitch.sortByProximityWithBadness(DynamicEndpointSnitch.java:186)
> at org.apache.cassandra.locator.DynamicEndpointSnitch.sortByProximity(DynamicEndpointSnitch.java:151)
> at org.apache.cassandra.service.StorageProxy.getLiveSortedEndpoints(StorageProxy.java:1408)
> at org.apache.cassandra.service.StorageProxy.getLiveSortedEndpoints(StorageProxy.java:1402)
> at org.apache.cassandra.service.AbstractReadExecutor.getReadExecutor(AbstractReadExecutor.java:148)
> at org.apache.cassandra.service.StorageProxy.fetchRows(StorageProxy.java:1223)
> at org.apache.cassandra.service.StorageProxy.read(StorageProxy.java:1165)
> at org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:255)
> at org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:225)
> at org.apache.cassandra.auth.Auth.selectUser(Auth.java:243)
> at org.apache.cassandra.auth.Auth.isSuperuser(Auth.java:84)
> at org.apache.cassandra.auth.AuthenticatedUser.isSuper(AuthenticatedUser.java:50)
> at org.apache.cassandra.auth.CassandraAuthorizer.authorize(CassandraAuthorizer.java:69)
> at org.apache.cassandra.service.ClientState$1.load(ClientState.java:338)
> at org.apache.cassandra.service.ClientState$1.load(ClientState.java:335)
> at com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3522)
> at com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2315)
> at com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2278)
> at com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2193)
> ... 18 more
> {code}
> Workaround: Setting -Djava.util.Arrays.useLegacyMergeSort=true causes the error to go away.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)