[jira] [Created] (CASSANDRA-6329) example pig script doesn't run
Jeremy Hanna created CASSANDRA-6329: --- Summary: example pig script doesn't run Key: CASSANDRA-6329 URL: https://issues.apache.org/jira/browse/CASSANDRA-6329 Project: Cassandra Issue Type: Bug Components: Hadoop Reporter: Jeremy Hanna Priority: Trivial The following line in the examples/pig/example-script.pig will not run (using Pig 0.9.2): {code} state_footage = FOREACH state_grouped GENERATE GROUP AS State, SUM(state_flat.SquareFeet) AS TotalFeet:int; {code} It needs to have a lowercase 'group' because that's the variable name after doing the GROUP operation in the previous line: {code} state_footage = FOREACH state_grouped GENERATE group AS State, SUM(state_flat.SquareFeet) AS TotalFeet:int; {code} Also, I wonder if it would be good to separate the CassandraStorage and CqlStorage into two different scripts, just so you can run the CqlStorage example out of the box without having to comment out the CassandraStorage example. -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Commented] (CASSANDRA-6316) json2sstable breaks on RangeTombstone
[ https://issues.apache.org/jira/browse/CASSANDRA-6316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819032#comment-13819032 ] Lyuben Todorov commented on CASSANDRA-6316: --- When SSTableImport#JsonColumn tries to find the comparator for the tombstoned range it fails and defaults to a BytesType comparator. I special-cased the tombstoned columns to get their comparator from the 1st component of the cf. [Gist of the schemas used for verification|https://gist.github.com/lyubent/7415048]. json2sstable breaks on RangeTombstone - Key: CASSANDRA-6316 URL: https://issues.apache.org/jira/browse/CASSANDRA-6316 Project: Cassandra Issue Type: Bug Environment: 1.2.10 Reporter: Matt Jurik Assignee: Lyuben Todorov Priority: Minor It seems that sstable2json writes out json which json2sstable has trouble reading. {code} java.lang.NumberFormatException: An hex string representing bytes must have an even length at org.apache.cassandra.utils.Hex.hexToBytes(Hex.java:52) at org.apache.cassandra.utils.ByteBufferUtil.hexToBytes(ByteBufferUtil.java:503) at org.apache.cassandra.tools.SSTableImport.stringAsType(SSTableImport.java:572) at org.apache.cassandra.tools.SSTableImport.access$000(SSTableImport.java:66) at org.apache.cassandra.tools.SSTableImport$JsonColumn.init(SSTableImport.java:158) at org.apache.cassandra.tools.SSTableImport.addColumnsToCF(SSTableImport.java:229) at org.apache.cassandra.tools.SSTableImport.addToStandardCF(SSTableImport.java:212) at org.apache.cassandra.tools.SSTableImport.importUnsorted(SSTableImport.java:361) at org.apache.cassandra.tools.SSTableImport.importJson(SSTableImport.java:318) at org.apache.cassandra.tools.SSTableImport.main(SSTableImport.java:537) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:606) at com.intellij.rt.execution.application.AppMain.main(AppMain.java:120) ERROR: An hex string representing bytes must have an even length 12345:2:! {code} -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Updated] (CASSANDRA-6316) json2sstable breaks on RangeTombstone
[ https://issues.apache.org/jira/browse/CASSANDRA-6316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyuben Todorov updated CASSANDRA-6316: -- Attachment: 6316.diff json2sstable breaks on RangeTombstone - Key: CASSANDRA-6316 URL: https://issues.apache.org/jira/browse/CASSANDRA-6316 Project: Cassandra Issue Type: Bug Environment: 1.2.10 Reporter: Matt Jurik Assignee: Lyuben Todorov Priority: Minor Attachments: 6316.diff It seems that sstable2json writes out json which json2sstable has trouble reading. {code} java.lang.NumberFormatException: An hex string representing bytes must have an even length at org.apache.cassandra.utils.Hex.hexToBytes(Hex.java:52) at org.apache.cassandra.utils.ByteBufferUtil.hexToBytes(ByteBufferUtil.java:503) at org.apache.cassandra.tools.SSTableImport.stringAsType(SSTableImport.java:572) at org.apache.cassandra.tools.SSTableImport.access$000(SSTableImport.java:66) at org.apache.cassandra.tools.SSTableImport$JsonColumn.init(SSTableImport.java:158) at org.apache.cassandra.tools.SSTableImport.addColumnsToCF(SSTableImport.java:229) at org.apache.cassandra.tools.SSTableImport.addToStandardCF(SSTableImport.java:212) at org.apache.cassandra.tools.SSTableImport.importUnsorted(SSTableImport.java:361) at org.apache.cassandra.tools.SSTableImport.importJson(SSTableImport.java:318) at org.apache.cassandra.tools.SSTableImport.main(SSTableImport.java:537) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:606) at com.intellij.rt.execution.application.AppMain.main(AppMain.java:120) ERROR: An hex string representing bytes must have an even length 12345:2:! {code} -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Updated] (CASSANDRA-6316) json2sstable breaks on RangeTombstone
[ https://issues.apache.org/jira/browse/CASSANDRA-6316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis updated CASSANDRA-6316: -- Reviewer: Aleksey Yeschenko Reproduced In: 2.0.2, 1.2.11 (was: 1.2.11, 2.0.2) json2sstable breaks on RangeTombstone - Key: CASSANDRA-6316 URL: https://issues.apache.org/jira/browse/CASSANDRA-6316 Project: Cassandra Issue Type: Bug Environment: 1.2.10 Reporter: Matt Jurik Assignee: Lyuben Todorov Priority: Minor Attachments: 6316.diff It seems that sstable2json writes out json which json2sstable has trouble reading. {code} java.lang.NumberFormatException: An hex string representing bytes must have an even length at org.apache.cassandra.utils.Hex.hexToBytes(Hex.java:52) at org.apache.cassandra.utils.ByteBufferUtil.hexToBytes(ByteBufferUtil.java:503) at org.apache.cassandra.tools.SSTableImport.stringAsType(SSTableImport.java:572) at org.apache.cassandra.tools.SSTableImport.access$000(SSTableImport.java:66) at org.apache.cassandra.tools.SSTableImport$JsonColumn.init(SSTableImport.java:158) at org.apache.cassandra.tools.SSTableImport.addColumnsToCF(SSTableImport.java:229) at org.apache.cassandra.tools.SSTableImport.addToStandardCF(SSTableImport.java:212) at org.apache.cassandra.tools.SSTableImport.importUnsorted(SSTableImport.java:361) at org.apache.cassandra.tools.SSTableImport.importJson(SSTableImport.java:318) at org.apache.cassandra.tools.SSTableImport.main(SSTableImport.java:537) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:606) at com.intellij.rt.execution.application.AppMain.main(AppMain.java:120) ERROR: An hex string representing bytes must have an even length 12345:2:! {code} -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Commented] (CASSANDRA-6268) Poor performance of Hadoop if any DC is using VNodes
[ https://issues.apache.org/jira/browse/CASSANDRA-6268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819043#comment-13819043 ] Jonathan Ellis commented on CASSANDRA-6268: --- So I'm back to bumping to 19.36.2 and 19.39.0 as the best option. Poor performance of Hadoop if any DC is using VNodes Key: CASSANDRA-6268 URL: https://issues.apache.org/jira/browse/CASSANDRA-6268 Project: Cassandra Issue Type: Improvement Components: Hadoop Reporter: Piotr Kołaczkowski Assignee: Piotr Kołaczkowski Attachments: 6268-src-1.2.txt, 6268-src-2.0.txt, 6268-thrift-1.2.txt, 6268-thrift-2.0.txt Some customers are complaining about huge number of splits in Hadoop caused by VNodes. Disabling vnodes only in Hadoop DC does not fix it. Splits are generated from the results of describe_ring, which returns a huge number of ranges anyways, and doesn't take into account that there will be huge number of consecutive ranges residing on the nodes we'd like the M/R job to be run. The proposed fix: 1. allows for specifying the DC(s) the Hadoop job should be run in (in DSE - defaults to all Hadoop DCs) 2. merges consecutive ranges before generating Hadoop splits, so we don't have artificial range splitting caused by vnodes in the other DCs For non-DSE users this feature is turned off by default and doesn't change the old behaviour. -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Commented] (CASSANDRA-6268) Poor performance of Hadoop if any DC is using VNodes
[ https://issues.apache.org/jira/browse/CASSANDRA-6268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819049#comment-13819049 ] Jeremiah Jordan commented on CASSANDRA-6268: bq. So I'm back to bumping to 19.36.2 and 19.39.0 as the best option. +1 to those. I think those are the least likely to cause issues. And if we change something for 2.1, we should bump the version by 3 or something, to leave some extra numbers for 2.0. Poor performance of Hadoop if any DC is using VNodes Key: CASSANDRA-6268 URL: https://issues.apache.org/jira/browse/CASSANDRA-6268 Project: Cassandra Issue Type: Improvement Components: Hadoop Reporter: Piotr Kołaczkowski Assignee: Piotr Kołaczkowski Attachments: 6268-src-1.2.txt, 6268-src-2.0.txt, 6268-thrift-1.2.txt, 6268-thrift-2.0.txt Some customers are complaining about huge number of splits in Hadoop caused by VNodes. Disabling vnodes only in Hadoop DC does not fix it. Splits are generated from the results of describe_ring, which returns a huge number of ranges anyways, and doesn't take into account that there will be huge number of consecutive ranges residing on the nodes we'd like the M/R job to be run. The proposed fix: 1. allows for specifying the DC(s) the Hadoop job should be run in (in DSE - defaults to all Hadoop DCs) 2. merges consecutive ranges before generating Hadoop splits, so we don't have artificial range splitting caused by vnodes in the other DCs For non-DSE users this feature is turned off by default and doesn't change the old behaviour. -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Resolved] (CASSANDRA-6296) Bootstrapping a new node should not require much compaction when leveled compaction is used
[ https://issues.apache.org/jira/browse/CASSANDRA-6296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis resolved CASSANDRA-6296. --- Resolution: Won't Fix Fix Version/s: (was: 2.1) Hmm, right. Well, I can't think of any other special cases that would help outside of 6323, so closing this one. Bootstrapping a new node should not require much compaction when leveled compaction is used --- Key: CASSANDRA-6296 URL: https://issues.apache.org/jira/browse/CASSANDRA-6296 Project: Cassandra Issue Type: Improvement Reporter: T Jake Luciani Priority: Minor boostrapping a new node currently requires recompacting all data. In the case of leveled compaction we already have the data in non-overlapping levels. Since we stream from a single host for a single range this shouldn't require any compaction if the sstable is level 0 -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Updated] (CASSANDRA-6325) AssertionError on startup reading saved Serializing row cache
[ https://issues.apache.org/jira/browse/CASSANDRA-6325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis updated CASSANDRA-6325: -- Attachment: 6325-v2.txt Hmm, that would work but since we're already using serialize() == null to mean out of memory I'd rather avoid using it to mean you passed a null value as well. v2 attached to avoid passing a null value instead. AssertionError on startup reading saved Serializing row cache - Key: CASSANDRA-6325 URL: https://issues.apache.org/jira/browse/CASSANDRA-6325 Project: Cassandra Issue Type: Bug Components: Core Environment: upgrade from 1.2.9ish to 1.2.11ish Reporter: Chris Burroughs Assignee: Mikhail Stepura Priority: Minor Fix For: 1.2.12 Attachments: 6325-v2.txt, CASSANDRA-1.2-6325.patch I don't see any reason what this could have to do with the upgrade, but don't have a large enough non-prod cluster to just keep restarting on. Occurred on roughly 2 out of 100 restarted nodes. {noformat} ERROR [main] 2013-11-08 14:40:13,535 CassandraDaemon.java (line 482) Exception encountered during startup java.lang.AssertionError at org.apache.cassandra.cache.SerializingCacheProvider$RowCacheSerializer.serialize(SerializingCacheProvider.java:41) at org.apache.cassandra.cache.SerializingCacheProvider$RowCacheSerializer.serialize(SerializingCacheProvider.java:37) at org.apache.cassandra.cache.SerializingCache.serialize(SerializingCache.java:118) at org.apache.cassandra.cache.SerializingCache.put(SerializingCache.java:176) at org.apache.cassandra.cache.InstrumentingCache.put(InstrumentingCache.java:44) at org.apache.cassandra.cache.AutoSavingCache.loadSaved(AutoSavingCache.java:156) at org.apache.cassandra.db.ColumnFamilyStore.initRowCache(ColumnFamilyStore.java:444) at org.apache.cassandra.db.Table.open(Table.java:114) at org.apache.cassandra.db.Table.open(Table.java:87) at org.apache.cassandra.service.CassandraDaemon.setup(CassandraDaemon.java:278) at org.apache.cassandra.service.CassandraDaemon.activate(CassandraDaemon.java:465) {noformat} I have the files if there is any useful analysis that can be run. Looked 'normal' to a cursory `less` inspection. Possibly related: CASSANDRA-4463 -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Updated] (CASSANDRA-6322) Classcast Exception thrown when under load
[ https://issues.apache.org/jira/browse/CASSANDRA-6322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis updated CASSANDRA-6322: -- Attachment: 6322.txt Fix attached. Classcast Exception thrown when under load -- Key: CASSANDRA-6322 URL: https://issues.apache.org/jira/browse/CASSANDRA-6322 Project: Cassandra Issue Type: Bug Components: Core Environment: Linux Centos 64 bit, Sun JDK 1.7 Reporter: Jinder Aujla Fix For: 2.0.3 Attachments: 6322.txt Saw this in the logs when running a load test: ERROR [EXPIRING-MAP-REAPER:1] 2013-11-08 21:52:56,389 CassandraDaemon.java (line 187) Exception in thread Thread[EXPIRING-MAP-REAPER:1,5,main] java.lang.ClassCastException: org.apache.cassandra.db.CounterMutation cannot be cast to org.apache.cassandra.db.RowMutation at org.apache.cassandra.net.MessagingService$5.apply(MessagingService.java:350) at org.apache.cassandra.net.MessagingService$5.apply(MessagingService.java:340) at org.apache.cassandra.utils.ExpiringMap$1.run(ExpiringMap.java:97) at org.apache.cassandra.concurrent.DebuggableScheduledThreadPoolExecutor$UncomplainingRunnable.run(DebuggableScheduledThreadPoolExecutor.java:75) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) at java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:351) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) 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:722) -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Commented] (CASSANDRA-6329) example pig script doesn't run
[ https://issues.apache.org/jira/browse/CASSANDRA-6329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819123#comment-13819123 ] Brandon Williams commented on CASSANDRA-6329: - Care to submit a patch? example pig script doesn't run -- Key: CASSANDRA-6329 URL: https://issues.apache.org/jira/browse/CASSANDRA-6329 Project: Cassandra Issue Type: Bug Components: Hadoop Reporter: Jeremy Hanna Priority: Trivial Labels: pig The following line in the examples/pig/example-script.pig will not run (using Pig 0.9.2): {code} state_footage = FOREACH state_grouped GENERATE GROUP AS State, SUM(state_flat.SquareFeet) AS TotalFeet:int; {code} It needs to have a lowercase 'group' because that's the variable name after doing the GROUP operation in the previous line: {code} state_footage = FOREACH state_grouped GENERATE group AS State, SUM(state_flat.SquareFeet) AS TotalFeet:int; {code} Also, I wonder if it would be good to separate the CassandraStorage and CqlStorage into two different scripts, just so you can run the CqlStorage example out of the box without having to comment out the CassandraStorage example. -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Commented] (CASSANDRA-6322) Classcast Exception thrown when under load
[ https://issues.apache.org/jira/browse/CASSANDRA-6322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819118#comment-13819118 ] Aleksey Yeschenko commented on CASSANDRA-6322: -- +1 Classcast Exception thrown when under load -- Key: CASSANDRA-6322 URL: https://issues.apache.org/jira/browse/CASSANDRA-6322 Project: Cassandra Issue Type: Bug Components: Core Environment: Linux Centos 64 bit, Sun JDK 1.7 Reporter: Jinder Aujla Assignee: Jonathan Ellis Fix For: 2.0.3 Attachments: 6322.txt Saw this in the logs when running a load test: ERROR [EXPIRING-MAP-REAPER:1] 2013-11-08 21:52:56,389 CassandraDaemon.java (line 187) Exception in thread Thread[EXPIRING-MAP-REAPER:1,5,main] java.lang.ClassCastException: org.apache.cassandra.db.CounterMutation cannot be cast to org.apache.cassandra.db.RowMutation at org.apache.cassandra.net.MessagingService$5.apply(MessagingService.java:350) at org.apache.cassandra.net.MessagingService$5.apply(MessagingService.java:340) at org.apache.cassandra.utils.ExpiringMap$1.run(ExpiringMap.java:97) at org.apache.cassandra.concurrent.DebuggableScheduledThreadPoolExecutor$UncomplainingRunnable.run(DebuggableScheduledThreadPoolExecutor.java:75) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) at java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:351) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) 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:722) -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Updated] (CASSANDRA-6275) 2.0.x leaks file handles
[ https://issues.apache.org/jira/browse/CASSANDRA-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gianluca Borello updated CASSANDRA-6275: Attachment: leak.log We are experiencing a similar issue in 2.0.2. It started happening after we set a TTL for all our columns in a very limited datastore (just a few GBs). We can easily see the fd count rapidly increase to 10+, and the majority of fds are (from lsof): {noformat} java 13168 cassandra 267r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) java 13168 cassandra 268r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) java 13168 cassandra 269r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) java 13168 cassandra 270r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) java 13168 cassandra 271r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) java 13168 cassandra 272r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) java 13168 cassandra 273r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) {noformat} I'm attaching the log of the exception. You can see the exceptions, and then Cassandra eventually shuts down. We had to temporarily downgrade to 1.2.11 2.0.x leaks file handles Key: CASSANDRA-6275 URL: https://issues.apache.org/jira/browse/CASSANDRA-6275 Project: Cassandra Issue Type: Bug Components: Core Environment: java version 1.7.0_25 Java(TM) SE Runtime Environment (build 1.7.0_25-b15) Java HotSpot(TM) 64-Bit Server VM (build 23.25-b01, mixed mode) Linux cassandra-test1 2.6.32-279.el6.x86_64 #1 SMP Thu Jun 21 15:00:18 EDT 2012 x86_64 x86_64 x86_64 GNU/Linux Reporter: Mikhail Mazursky Attachments: cassandra_jstack.txt, leak.log, slog.gz Looks like C* is leaking file descriptors when doing lots of CAS operations. {noformat} $ sudo cat /proc/15455/limits Limit Soft Limit Hard Limit Units Max cpu time unlimitedunlimitedseconds Max file size unlimitedunlimitedbytes Max data size unlimitedunlimitedbytes Max stack size10485760 unlimitedbytes Max core file size00bytes Max resident set unlimitedunlimitedbytes Max processes 1024 unlimitedprocesses Max open files4096 4096 files Max locked memory unlimitedunlimitedbytes Max address space unlimitedunlimitedbytes Max file locksunlimitedunlimitedlocks Max pending signals 1463314633signals Max msgqueue size 819200 819200 bytes Max nice priority 00 Max realtime priority 00 Max realtime timeout unlimitedunlimitedus {noformat} Looks like the problem is not in limits. Before load test: {noformat} cassandra-test0 ~]$ lsof -n | grep java | wc -l 166 cassandra-test1 ~]$ lsof -n | grep java | wc -l 164 cassandra-test2 ~]$ lsof -n | grep java | wc -l 180 {noformat} After load test: {noformat} cassandra-test0 ~]$ lsof -n | grep java | wc -l 967 cassandra-test1 ~]$ lsof -n | grep java | wc -l 1766 cassandra-test2 ~]$ lsof -n | grep java | wc -l 2578 {noformat} Most opened files have names like: {noformat} java 16890 cassandra 1636r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1637r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1638r REG
[jira] [Comment Edited] (CASSANDRA-6275) 2.0.x leaks file handles
[ https://issues.apache.org/jira/browse/CASSANDRA-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819144#comment-13819144 ] Gianluca Borello edited comment on CASSANDRA-6275 at 11/11/13 5:35 PM: --- We are experiencing a similar issue in 2.0.2. It started happening after we set a TTL for all our columns in a very limited datastore (just a few GBs). We can easily see the fd count rapidly increase to 10+, and the majority of fds are (from lsof): {noformat} java 13168 cassandra 267r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) java 13168 cassandra 268r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) java 13168 cassandra 269r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) java 13168 cassandra 270r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) java 13168 cassandra 271r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) java 13168 cassandra 272r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) java 13168 cassandra 273r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) {noformat} I'm attaching the log of the exception (leak.log). You can see the exceptions, and then Cassandra eventually shuts down. We had to temporarily downgrade to 1.2.11 was (Author: gianlucaborello): We are experiencing a similar issue in 2.0.2. It started happening after we set a TTL for all our columns in a very limited datastore (just a few GBs). We can easily see the fd count rapidly increase to 10+, and the majority of fds are (from lsof): {noformat} java 13168 cassandra 267r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) java 13168 cassandra 268r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) java 13168 cassandra 269r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) java 13168 cassandra 270r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) java 13168 cassandra 271r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) java 13168 cassandra 272r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) java 13168 cassandra 273r REG9,0 273129 671089723 /raid0/cassandra/data/draios/process_counters_by_exe/draios-process_counters_by_exe-jb-231-Data.db (deleted) {noformat} I'm attaching the log of the exception. You can see the exceptions, and then Cassandra eventually shuts down. We had to temporarily downgrade to 1.2.11 2.0.x leaks file handles Key: CASSANDRA-6275 URL: https://issues.apache.org/jira/browse/CASSANDRA-6275 Project: Cassandra Issue Type: Bug Components: Core Environment: java version 1.7.0_25 Java(TM) SE Runtime Environment (build 1.7.0_25-b15) Java HotSpot(TM) 64-Bit Server VM (build 23.25-b01, mixed mode) Linux cassandra-test1 2.6.32-279.el6.x86_64 #1 SMP Thu Jun 21 15:00:18 EDT 2012 x86_64 x86_64 x86_64 GNU/Linux Reporter: Mikhail Mazursky Attachments: cassandra_jstack.txt, leak.log, slog.gz Looks like C* is leaking file descriptors when doing lots of CAS operations. {noformat} $ sudo cat /proc/15455/limits Limit Soft Limit Hard Limit Units Max cpu time unlimitedunlimitedseconds Max file size unlimitedunlimitedbytes
[2/3] git commit: Fix trying to hint timed out counter writes patch by jbellis; reviewed by aleksey for CASSANDRA-6322
Fix trying to hint timed out counter writes patch by jbellis; reviewed by aleksey for CASSANDRA-6322 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/3af19c4d Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/3af19c4d Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/3af19c4d Branch: refs/heads/trunk Commit: 3af19c4dd17000635e8f6116ff8c0f67db81ae77 Parents: 5522a18 Author: Jonathan Ellis jbel...@apache.org Authored: Mon Nov 11 11:39:21 2013 -0600 Committer: Jonathan Ellis jbel...@apache.org Committed: Mon Nov 11 11:40:45 2013 -0600 -- CHANGES.txt | 1 + src/java/org/apache/cassandra/net/WriteCallbackInfo.java | 4 +++- 2 files changed, 4 insertions(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/3af19c4d/CHANGES.txt -- diff --git a/CHANGES.txt b/CHANGES.txt index 6f28e88..fa0b7cff 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 2.0.3 + * Fix trying to hint timed out counter writes (CASSANDRA-6322) * Allow restoring specific columnfamilies from archived CL (CASSANDRA-4809) * Avoid flushing compaction_history after each operation (CASSANDRA-6287) * Fix repair assertion error when tombstones expire (CASSANDRA-6277) http://git-wip-us.apache.org/repos/asf/cassandra/blob/3af19c4d/src/java/org/apache/cassandra/net/WriteCallbackInfo.java -- diff --git a/src/java/org/apache/cassandra/net/WriteCallbackInfo.java b/src/java/org/apache/cassandra/net/WriteCallbackInfo.java index 38e4b5a..be7b668 100644 --- a/src/java/org/apache/cassandra/net/WriteCallbackInfo.java +++ b/src/java/org/apache/cassandra/net/WriteCallbackInfo.java @@ -39,6 +39,8 @@ public class WriteCallbackInfo extends CallbackInfo public boolean shouldHint() { -return consistencyLevel != ConsistencyLevel.ANY StorageProxy.shouldHint(target); +return sentMessage.verb != MessagingService.Verb.COUNTER_MUTATION +consistencyLevel != ConsistencyLevel.ANY +StorageProxy.shouldHint(target); } }
[3/3] git commit: Merge branch 'cassandra-2.0' into trunk
Merge branch 'cassandra-2.0' into trunk Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/e9c595b5 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/e9c595b5 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/e9c595b5 Branch: refs/heads/trunk Commit: e9c595b5ef9af942eb76414f5a62df2907d3315f Parents: d37696c 3af19c4 Author: Jonathan Ellis jbel...@apache.org Authored: Mon Nov 11 11:41:25 2013 -0600 Committer: Jonathan Ellis jbel...@apache.org Committed: Mon Nov 11 11:41:25 2013 -0600 -- CHANGES.txt | 1 + src/java/org/apache/cassandra/net/WriteCallbackInfo.java | 4 +++- 2 files changed, 4 insertions(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/e9c595b5/CHANGES.txt -- diff --cc CHANGES.txt index 6e1a91b,fa0b7cff..f78f1e8 --- a/CHANGES.txt +++ b/CHANGES.txt @@@ -1,17 -1,5 +1,18 @@@ +2.1 + * Parallelize fetching rows for low-cardinality indexes (CASSANDRA-1337) + * change logging from log4j to logback (CASSANDRA-5883) + * switch to LZ4 compression for internode communication (CASSANDRA-5887) + * Stop using Thrift-generated Index* classes internally (CASSANDRA-5971) + * Remove 1.2 network compatibility code (CASSANDRA-5960) + * Remove leveled json manifest migration code (CASSANDRA-5996) + * Remove CFDefinition (CASSANDRA-6253) + * Use AtomicIntegerFieldUpdater in RefCountedMemory (CASSANDRA-6278) + * User-defined types for CQL3 (CASSANDRA-5590) + * Use of o.a.c.metrics in nodetool (CASSANDRA-5871) + + 2.0.3 + * Fix trying to hint timed out counter writes (CASSANDRA-6322) * Allow restoring specific columnfamilies from archived CL (CASSANDRA-4809) * Avoid flushing compaction_history after each operation (CASSANDRA-6287) * Fix repair assertion error when tombstones expire (CASSANDRA-6277)
[1/3] git commit: Fix trying to hint timed out counter writes patch by jbellis; reviewed by aleksey for CASSANDRA-6322
Updated Branches: refs/heads/cassandra-2.0 5522a18a7 - 3af19c4dd refs/heads/trunk d37696ca7 - e9c595b5e Fix trying to hint timed out counter writes patch by jbellis; reviewed by aleksey for CASSANDRA-6322 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/3af19c4d Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/3af19c4d Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/3af19c4d Branch: refs/heads/cassandra-2.0 Commit: 3af19c4dd17000635e8f6116ff8c0f67db81ae77 Parents: 5522a18 Author: Jonathan Ellis jbel...@apache.org Authored: Mon Nov 11 11:39:21 2013 -0600 Committer: Jonathan Ellis jbel...@apache.org Committed: Mon Nov 11 11:40:45 2013 -0600 -- CHANGES.txt | 1 + src/java/org/apache/cassandra/net/WriteCallbackInfo.java | 4 +++- 2 files changed, 4 insertions(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/3af19c4d/CHANGES.txt -- diff --git a/CHANGES.txt b/CHANGES.txt index 6f28e88..fa0b7cff 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 2.0.3 + * Fix trying to hint timed out counter writes (CASSANDRA-6322) * Allow restoring specific columnfamilies from archived CL (CASSANDRA-4809) * Avoid flushing compaction_history after each operation (CASSANDRA-6287) * Fix repair assertion error when tombstones expire (CASSANDRA-6277) http://git-wip-us.apache.org/repos/asf/cassandra/blob/3af19c4d/src/java/org/apache/cassandra/net/WriteCallbackInfo.java -- diff --git a/src/java/org/apache/cassandra/net/WriteCallbackInfo.java b/src/java/org/apache/cassandra/net/WriteCallbackInfo.java index 38e4b5a..be7b668 100644 --- a/src/java/org/apache/cassandra/net/WriteCallbackInfo.java +++ b/src/java/org/apache/cassandra/net/WriteCallbackInfo.java @@ -39,6 +39,8 @@ public class WriteCallbackInfo extends CallbackInfo public boolean shouldHint() { -return consistencyLevel != ConsistencyLevel.ANY StorageProxy.shouldHint(target); +return sentMessage.verb != MessagingService.Verb.COUNTER_MUTATION +consistencyLevel != ConsistencyLevel.ANY +StorageProxy.shouldHint(target); } }
[4/6] git commit: Merge branch 'cassandra-1.2' into cassandra-2.0
Merge branch 'cassandra-1.2' into cassandra-2.0 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/2d1085dd Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/2d1085dd Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/2d1085dd Branch: refs/heads/trunk Commit: 2d1085dde65e94dece6ec131de6da9f501edd125 Parents: 3af19c4 85b6574 Author: Jonathan Ellis jbel...@apache.org Authored: Mon Nov 11 11:43:38 2013 -0600 Committer: Jonathan Ellis jbel...@apache.org Committed: Mon Nov 11 11:43:38 2013 -0600 -- CHANGES.txt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/2d1085dd/CHANGES.txt --
[2/6] git commit: typo
typo Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/85b65749 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/85b65749 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/85b65749 Branch: refs/heads/cassandra-2.0 Commit: 85b6574943c0b2a9ba1626e4deed55a550ec3120 Parents: 3102765 Author: Jonathan Ellis jbel...@apache.org Authored: Mon Nov 11 11:43:32 2013 -0600 Committer: Jonathan Ellis jbel...@apache.org Committed: Mon Nov 11 11:43:32 2013 -0600 -- CHANGES.txt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/85b65749/CHANGES.txt -- diff --git a/CHANGES.txt b/CHANGES.txt index 0532a45..bc0d65b 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -12,7 +12,7 @@ * make calculatePendingRanges asynchronous (CASSANDRA-6244) * Remove blocking flushes in gossip thread (CASSANDRA-6297) * Fix potential socket leak in connectionpool creation (CASSANDRA-6308) - * Allow LOCAL_ONE/LOCAL_QUORUM to work with SimpleSrrategy (CASSANDRA-6238) + * Allow LOCAL_ONE/LOCAL_QUORUM to work with SimpleStrategy (CASSANDRA-6238) * cqlsh: handle 'null' as session duration (CASSANDRA-6317)
[5/6] git commit: Merge branch 'cassandra-1.2' into cassandra-2.0
Merge branch 'cassandra-1.2' into cassandra-2.0 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/2d1085dd Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/2d1085dd Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/2d1085dd Branch: refs/heads/cassandra-2.0 Commit: 2d1085dde65e94dece6ec131de6da9f501edd125 Parents: 3af19c4 85b6574 Author: Jonathan Ellis jbel...@apache.org Authored: Mon Nov 11 11:43:38 2013 -0600 Committer: Jonathan Ellis jbel...@apache.org Committed: Mon Nov 11 11:43:38 2013 -0600 -- CHANGES.txt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/2d1085dd/CHANGES.txt --
[6/6] git commit: Merge branch 'cassandra-2.0' into trunk
Merge branch 'cassandra-2.0' into trunk Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/16cf7f3e Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/16cf7f3e Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/16cf7f3e Branch: refs/heads/trunk Commit: 16cf7f3e876674bdd398ad09b9d1a801f432c03d Parents: e9c595b 2d1085d Author: Jonathan Ellis jbel...@apache.org Authored: Mon Nov 11 11:43:43 2013 -0600 Committer: Jonathan Ellis jbel...@apache.org Committed: Mon Nov 11 11:43:43 2013 -0600 -- CHANGES.txt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/16cf7f3e/CHANGES.txt --
[3/6] git commit: typo
typo Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/85b65749 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/85b65749 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/85b65749 Branch: refs/heads/trunk Commit: 85b6574943c0b2a9ba1626e4deed55a550ec3120 Parents: 3102765 Author: Jonathan Ellis jbel...@apache.org Authored: Mon Nov 11 11:43:32 2013 -0600 Committer: Jonathan Ellis jbel...@apache.org Committed: Mon Nov 11 11:43:32 2013 -0600 -- CHANGES.txt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/85b65749/CHANGES.txt -- diff --git a/CHANGES.txt b/CHANGES.txt index 0532a45..bc0d65b 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -12,7 +12,7 @@ * make calculatePendingRanges asynchronous (CASSANDRA-6244) * Remove blocking flushes in gossip thread (CASSANDRA-6297) * Fix potential socket leak in connectionpool creation (CASSANDRA-6308) - * Allow LOCAL_ONE/LOCAL_QUORUM to work with SimpleSrrategy (CASSANDRA-6238) + * Allow LOCAL_ONE/LOCAL_QUORUM to work with SimpleStrategy (CASSANDRA-6238) * cqlsh: handle 'null' as session duration (CASSANDRA-6317)
[1/6] git commit: typo
Updated Branches: refs/heads/cassandra-1.2 310276555 - 85b657494 refs/heads/cassandra-2.0 3af19c4dd - 2d1085dde refs/heads/trunk e9c595b5e - 16cf7f3e8 typo Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/85b65749 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/85b65749 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/85b65749 Branch: refs/heads/cassandra-1.2 Commit: 85b6574943c0b2a9ba1626e4deed55a550ec3120 Parents: 3102765 Author: Jonathan Ellis jbel...@apache.org Authored: Mon Nov 11 11:43:32 2013 -0600 Committer: Jonathan Ellis jbel...@apache.org Committed: Mon Nov 11 11:43:32 2013 -0600 -- CHANGES.txt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/85b65749/CHANGES.txt -- diff --git a/CHANGES.txt b/CHANGES.txt index 0532a45..bc0d65b 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -12,7 +12,7 @@ * make calculatePendingRanges asynchronous (CASSANDRA-6244) * Remove blocking flushes in gossip thread (CASSANDRA-6297) * Fix potential socket leak in connectionpool creation (CASSANDRA-6308) - * Allow LOCAL_ONE/LOCAL_QUORUM to work with SimpleSrrategy (CASSANDRA-6238) + * Allow LOCAL_ONE/LOCAL_QUORUM to work with SimpleStrategy (CASSANDRA-6238) * cqlsh: handle 'null' as session duration (CASSANDRA-6317)
[3/6] git commit: Add echo off to cqlsh.bat Patch by Mikhail Stepura, reviewed by brandonwilliams for CASSANDRA-6324
Add echo off to cqlsh.bat Patch by Mikhail Stepura, reviewed by brandonwilliams for CASSANDRA-6324 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/512ea5a7 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/512ea5a7 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/512ea5a7 Branch: refs/heads/trunk Commit: 512ea5a768457d7136f5e77712609dea09df04f3 Parents: 85b6574 Author: Brandon Williams brandonwilli...@apache.org Authored: Mon Nov 11 11:52:58 2013 -0600 Committer: Brandon Williams brandonwilli...@apache.org Committed: Mon Nov 11 11:52:58 2013 -0600 -- bin/cqlsh.bat | 1 + 1 file changed, 1 insertion(+) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/512ea5a7/bin/cqlsh.bat -- diff --git a/bin/cqlsh.bat b/bin/cqlsh.bat index a61df21..ffa8e0b 100644 --- a/bin/cqlsh.bat +++ b/bin/cqlsh.bat @@ -1,3 +1,4 @@ +@ECHO OFF @REM @REM Licensed to the Apache Software Foundation (ASF) under one or more @REM contributor license agreements. See the NOTICE file distributed with
[5/6] git commit: Merge branch 'cassandra-1.2' into cassandra-2.0
Merge branch 'cassandra-1.2' into cassandra-2.0 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/2cc4670a Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/2cc4670a Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/2cc4670a Branch: refs/heads/cassandra-2.0 Commit: 2cc4670acd6598c2a31d895f7f1159e248a2c886 Parents: 2d1085d 512ea5a Author: Brandon Williams brandonwilli...@apache.org Authored: Mon Nov 11 11:54:04 2013 -0600 Committer: Brandon Williams brandonwilli...@apache.org Committed: Mon Nov 11 11:54:04 2013 -0600 -- bin/cqlsh.bat | 1 + 1 file changed, 1 insertion(+) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/2cc4670a/bin/cqlsh.bat -- diff --cc bin/cqlsh.bat index 79adcff,ffa8e0b..68235b6 --- a/bin/cqlsh.bat +++ b/bin/cqlsh.bat @@@ -1,20 -1,19 +1,21 @@@ + @ECHO OFF @REM -@REM Licensed to the Apache Software Foundation (ASF) under one or more -@REM contributor license agreements. See the NOTICE file distributed with -@REM this work for additional information regarding copyright ownership. -@REM The ASF licenses this file to You under the Apache License, Version 2.0 -@REM (the License); you may not use this file except in compliance with -@REM the License. You may obtain a copy of the License at +@REM Licensed to the Apache Software Foundation (ASF) under one or more +@REM contributor license agreements. See the NOTICE file distributed with +@REM this work for additional information regarding copyright ownership. +@REM The ASF licenses this file to You under the Apache License, Version 2.0 +@REM (the License); you may not use this file except in compliance with +@REM the License. You may obtain a copy of the License at @REM -@REM http://www.apache.org/licenses/LICENSE-2.0 +@REM http://www.apache.org/licenses/LICENSE-2.0 @REM -@REM Unless required by applicable law or agreed to in writing, software -@REM distributed under the License is distributed on an AS IS BASIS, -@REM WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -@REM See the License for the specific language governing permissions and -@REM limitations under the License. +@REM Unless required by applicable law or agreed to in writing, software +@REM distributed under the License is distributed on an AS IS BASIS, +@REM WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +@REM See the License for the specific language governing permissions and +@REM limitations under the License. + +@echo off if %OS% == Windows_NT setlocal
[2/6] git commit: Add echo off to cqlsh.bat Patch by Mikhail Stepura, reviewed by brandonwilliams for CASSANDRA-6324
Add echo off to cqlsh.bat Patch by Mikhail Stepura, reviewed by brandonwilliams for CASSANDRA-6324 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/512ea5a7 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/512ea5a7 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/512ea5a7 Branch: refs/heads/cassandra-2.0 Commit: 512ea5a768457d7136f5e77712609dea09df04f3 Parents: 85b6574 Author: Brandon Williams brandonwilli...@apache.org Authored: Mon Nov 11 11:52:58 2013 -0600 Committer: Brandon Williams brandonwilli...@apache.org Committed: Mon Nov 11 11:52:58 2013 -0600 -- bin/cqlsh.bat | 1 + 1 file changed, 1 insertion(+) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/512ea5a7/bin/cqlsh.bat -- diff --git a/bin/cqlsh.bat b/bin/cqlsh.bat index a61df21..ffa8e0b 100644 --- a/bin/cqlsh.bat +++ b/bin/cqlsh.bat @@ -1,3 +1,4 @@ +@ECHO OFF @REM @REM Licensed to the Apache Software Foundation (ASF) under one or more @REM contributor license agreements. See the NOTICE file distributed with
[6/6] git commit: Merge branch 'cassandra-2.0' into trunk
Merge branch 'cassandra-2.0' into trunk Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/9a59d250 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/9a59d250 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/9a59d250 Branch: refs/heads/trunk Commit: 9a59d250aca108d766f05b08d351df25910a2f9b Parents: 16cf7f3 2cc4670 Author: Brandon Williams brandonwilli...@apache.org Authored: Mon Nov 11 11:54:17 2013 -0600 Committer: Brandon Williams brandonwilli...@apache.org Committed: Mon Nov 11 11:54:17 2013 -0600 -- bin/cqlsh.bat | 1 + 1 file changed, 1 insertion(+) --
[1/6] git commit: Add echo off to cqlsh.bat Patch by Mikhail Stepura, reviewed by brandonwilliams for CASSANDRA-6324
Updated Branches: refs/heads/cassandra-1.2 85b657494 - 512ea5a76 refs/heads/cassandra-2.0 2d1085dde - 2cc4670ac refs/heads/trunk 16cf7f3e8 - 9a59d250a Add echo off to cqlsh.bat Patch by Mikhail Stepura, reviewed by brandonwilliams for CASSANDRA-6324 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/512ea5a7 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/512ea5a7 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/512ea5a7 Branch: refs/heads/cassandra-1.2 Commit: 512ea5a768457d7136f5e77712609dea09df04f3 Parents: 85b6574 Author: Brandon Williams brandonwilli...@apache.org Authored: Mon Nov 11 11:52:58 2013 -0600 Committer: Brandon Williams brandonwilli...@apache.org Committed: Mon Nov 11 11:52:58 2013 -0600 -- bin/cqlsh.bat | 1 + 1 file changed, 1 insertion(+) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/512ea5a7/bin/cqlsh.bat -- diff --git a/bin/cqlsh.bat b/bin/cqlsh.bat index a61df21..ffa8e0b 100644 --- a/bin/cqlsh.bat +++ b/bin/cqlsh.bat @@ -1,3 +1,4 @@ +@ECHO OFF @REM @REM Licensed to the Apache Software Foundation (ASF) under one or more @REM contributor license agreements. See the NOTICE file distributed with
[4/6] git commit: Merge branch 'cassandra-1.2' into cassandra-2.0
Merge branch 'cassandra-1.2' into cassandra-2.0 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/2cc4670a Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/2cc4670a Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/2cc4670a Branch: refs/heads/trunk Commit: 2cc4670acd6598c2a31d895f7f1159e248a2c886 Parents: 2d1085d 512ea5a Author: Brandon Williams brandonwilli...@apache.org Authored: Mon Nov 11 11:54:04 2013 -0600 Committer: Brandon Williams brandonwilli...@apache.org Committed: Mon Nov 11 11:54:04 2013 -0600 -- bin/cqlsh.bat | 1 + 1 file changed, 1 insertion(+) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/2cc4670a/bin/cqlsh.bat -- diff --cc bin/cqlsh.bat index 79adcff,ffa8e0b..68235b6 --- a/bin/cqlsh.bat +++ b/bin/cqlsh.bat @@@ -1,20 -1,19 +1,21 @@@ + @ECHO OFF @REM -@REM Licensed to the Apache Software Foundation (ASF) under one or more -@REM contributor license agreements. See the NOTICE file distributed with -@REM this work for additional information regarding copyright ownership. -@REM The ASF licenses this file to You under the Apache License, Version 2.0 -@REM (the License); you may not use this file except in compliance with -@REM the License. You may obtain a copy of the License at +@REM Licensed to the Apache Software Foundation (ASF) under one or more +@REM contributor license agreements. See the NOTICE file distributed with +@REM this work for additional information regarding copyright ownership. +@REM The ASF licenses this file to You under the Apache License, Version 2.0 +@REM (the License); you may not use this file except in compliance with +@REM the License. You may obtain a copy of the License at @REM -@REM http://www.apache.org/licenses/LICENSE-2.0 +@REM http://www.apache.org/licenses/LICENSE-2.0 @REM -@REM Unless required by applicable law or agreed to in writing, software -@REM distributed under the License is distributed on an AS IS BASIS, -@REM WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -@REM See the License for the specific language governing permissions and -@REM limitations under the License. +@REM Unless required by applicable law or agreed to in writing, software +@REM distributed under the License is distributed on an AS IS BASIS, +@REM WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +@REM See the License for the specific language governing permissions and +@REM limitations under the License. + +@echo off if %OS% == Windows_NT setlocal
[jira] [Commented] (CASSANDRA-6296) Bootstrapping a new node should not require much compaction when leveled compaction is used
[ https://issues.apache.org/jira/browse/CASSANDRA-6296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819153#comment-13819153 ] T Jake Luciani commented on CASSANDRA-6296: --- Oh streaming fails over now? Great. It would still seem like for first attempt it should try to use the same levels as the replica. If it sends random sstables from random levels 6323 would cause a lot of unnecessary compaction still. Perhaps we could put logic in 6323 that will prefer the hinted level when it picks and if that level is not available it will fall back to any open level? Bootstrapping a new node should not require much compaction when leveled compaction is used --- Key: CASSANDRA-6296 URL: https://issues.apache.org/jira/browse/CASSANDRA-6296 Project: Cassandra Issue Type: Improvement Reporter: T Jake Luciani Priority: Minor boostrapping a new node currently requires recompacting all data. In the case of leveled compaction we already have the data in non-overlapping levels. Since we stream from a single host for a single range this shouldn't require any compaction if the sstable is level 0 -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Commented] (CASSANDRA-6296) Bootstrapping a new node should not require much compaction when leveled compaction is used
[ https://issues.apache.org/jira/browse/CASSANDRA-6296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819159#comment-13819159 ] Jonathan Ellis commented on CASSANDRA-6296: --- I think that would work, but streaming from multiple replicas is the common case now with vnodes, so I'm not sure it's worth the trouble at this point. Bootstrapping a new node should not require much compaction when leveled compaction is used --- Key: CASSANDRA-6296 URL: https://issues.apache.org/jira/browse/CASSANDRA-6296 Project: Cassandra Issue Type: Improvement Reporter: T Jake Luciani Priority: Minor boostrapping a new node currently requires recompacting all data. In the case of leveled compaction we already have the data in non-overlapping levels. Since we stream from a single host for a single range this shouldn't require any compaction if the sstable is level 0 -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Commented] (CASSANDRA-6296) Bootstrapping a new node should not require much compaction when leveled compaction is used
[ https://issues.apache.org/jira/browse/CASSANDRA-6296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819165#comment-13819165 ] T Jake Luciani commented on CASSANDRA-6296: --- But does it stream the same range from multiple replicas? or does it fetch different ranges? If it's the former then this would still work with leveled, since there would be no overlap. Bootstrapping a new node should not require much compaction when leveled compaction is used --- Key: CASSANDRA-6296 URL: https://issues.apache.org/jira/browse/CASSANDRA-6296 Project: Cassandra Issue Type: Improvement Reporter: T Jake Luciani Priority: Minor boostrapping a new node currently requires recompacting all data. In the case of leveled compaction we already have the data in non-overlapping levels. Since we stream from a single host for a single range this shouldn't require any compaction if the sstable is level 0 -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Comment Edited] (CASSANDRA-6296) Bootstrapping a new node should not require much compaction when leveled compaction is used
[ https://issues.apache.org/jira/browse/CASSANDRA-6296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819165#comment-13819165 ] T Jake Luciani edited comment on CASSANDRA-6296 at 11/11/13 6:13 PM: - But does it stream the same range from multiple replicas? or does it fetch different ranges? If it's the latter then this would still work with leveled, since there would be no overlap. was (Author: tjake): But does it stream the same range from multiple replicas? or does it fetch different ranges? If it's the former then this would still work with leveled, since there would be no overlap. Bootstrapping a new node should not require much compaction when leveled compaction is used --- Key: CASSANDRA-6296 URL: https://issues.apache.org/jira/browse/CASSANDRA-6296 Project: Cassandra Issue Type: Improvement Reporter: T Jake Luciani Priority: Minor boostrapping a new node currently requires recompacting all data. In the case of leveled compaction we already have the data in non-overlapping levels. Since we stream from a single host for a single range this shouldn't require any compaction if the sstable is level 0 -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Created] (CASSANDRA-6330) LIMIT fetches one less than requested value
Branden Visser created CASSANDRA-6330: - Summary: LIMIT fetches one less than requested value Key: CASSANDRA-6330 URL: https://issues.apache.org/jira/browse/CASSANDRA-6330 Project: Cassandra Issue Type: Bug Components: Core Reporter: Branden Visser Using Cassandra 1.2.11, the following sequence demonstrates the issue: {code:sql} CREATE TABLE blah (key text, column text, value text, PRIMARY KEY (key, column)) WITH COMPACT STORAGE; INSERT INTO blah (key, column, value) VALUES ('a', 'a', 'a'); INSERT INTO blah (key, column, value) VALUES ('a', 'b', 'e'); INSERT INTO blah (key, column, value) VALUES ('a', 'c', 'e'); INSERT INTO blah (key, column, value) VALUES ('a', 'd', 'e'); INSERT INTO blah (key, column, value) VALUES ('a', 'e', 'e'); SELECT column FROM blah WHERE key = 'a' AND column 'c' ORDER BY column DESC LIMIT 2; column b {code} However I would expect columns b and a to both be returned. Only seems to be an issue if the range bound is an exact match, and only if ORDER BY column DESC is used. -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Assigned] (CASSANDRA-6330) LIMIT fetches one less than requested value
[ https://issues.apache.org/jira/browse/CASSANDRA-6330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis reassigned CASSANDRA-6330: - Assignee: Sylvain Lebresne LIMIT fetches one less than requested value --- Key: CASSANDRA-6330 URL: https://issues.apache.org/jira/browse/CASSANDRA-6330 Project: Cassandra Issue Type: Bug Components: Core Reporter: Branden Visser Assignee: Sylvain Lebresne Using Cassandra 1.2.11, the following sequence demonstrates the issue: {code:sql} CREATE TABLE blah (key text, column text, value text, PRIMARY KEY (key, column)) WITH COMPACT STORAGE; INSERT INTO blah (key, column, value) VALUES ('a', 'a', 'a'); INSERT INTO blah (key, column, value) VALUES ('a', 'b', 'e'); INSERT INTO blah (key, column, value) VALUES ('a', 'c', 'e'); INSERT INTO blah (key, column, value) VALUES ('a', 'd', 'e'); INSERT INTO blah (key, column, value) VALUES ('a', 'e', 'e'); SELECT column FROM blah WHERE key = 'a' AND column 'c' ORDER BY column DESC LIMIT 2; column b {code} However I would expect columns b and a to both be returned. Only seems to be an issue if the range bound is an exact match, and only if ORDER BY column DESC is used. -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Reopened] (CASSANDRA-6296) Bootstrapping a new node should not require much compaction when leveled compaction is used
[ https://issues.apache.org/jira/browse/CASSANDRA-6296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis reopened CASSANDRA-6296: --- You're right. Bootstrapping a new node should not require much compaction when leveled compaction is used --- Key: CASSANDRA-6296 URL: https://issues.apache.org/jira/browse/CASSANDRA-6296 Project: Cassandra Issue Type: Improvement Reporter: T Jake Luciani Priority: Minor boostrapping a new node currently requires recompacting all data. In the case of leveled compaction we already have the data in non-overlapping levels. Since we stream from a single host for a single range this shouldn't require any compaction if the sstable is level 0 -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Commented] (CASSANDRA-6330) LIMIT fetches one less than requested value
[ https://issues.apache.org/jira/browse/CASSANDRA-6330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819188#comment-13819188 ] Branden Visser commented on CASSANDRA-6330: --- Should clarify, version is 1.2.11-SNAPSHOT as of this weekend. LIMIT fetches one less than requested value --- Key: CASSANDRA-6330 URL: https://issues.apache.org/jira/browse/CASSANDRA-6330 Project: Cassandra Issue Type: Bug Components: Core Reporter: Branden Visser Assignee: Sylvain Lebresne Using Cassandra 1.2.11, the following sequence demonstrates the issue: {code:sql} CREATE TABLE blah (key text, column text, value text, PRIMARY KEY (key, column)) WITH COMPACT STORAGE; INSERT INTO blah (key, column, value) VALUES ('a', 'a', 'a'); INSERT INTO blah (key, column, value) VALUES ('a', 'b', 'e'); INSERT INTO blah (key, column, value) VALUES ('a', 'c', 'e'); INSERT INTO blah (key, column, value) VALUES ('a', 'd', 'e'); INSERT INTO blah (key, column, value) VALUES ('a', 'e', 'e'); SELECT column FROM blah WHERE key = 'a' AND column 'c' ORDER BY column DESC LIMIT 2; column b {code} However I would expect columns b and a to both be returned. Only seems to be an issue if the range bound is an exact match, and only if ORDER BY column DESC is used. -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Created] (CASSANDRA-6331) Add LZ4Compressor in CQL document
Ray Wu created CASSANDRA-6331: - Summary: Add LZ4Compressor in CQL document Key: CASSANDRA-6331 URL: https://issues.apache.org/jira/browse/CASSANDRA-6331 Project: Cassandra Issue Type: Improvement Reporter: Ray Wu Priority: Trivial LZ4Compressor should also be documented in sstable_compression option. http://cassandra.apache.org/doc/cql3/CQL.html -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Updated] (CASSANDRA-6331) Add LZ4Compressor in CQL document
[ https://issues.apache.org/jira/browse/CASSANDRA-6331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Wu updated CASSANDRA-6331: -- Component/s: Documentation website Add LZ4Compressor in CQL document - Key: CASSANDRA-6331 URL: https://issues.apache.org/jira/browse/CASSANDRA-6331 Project: Cassandra Issue Type: Improvement Components: Documentation website Reporter: Ray Wu Priority: Trivial Labels: cql3 LZ4Compressor should also be documented in sstable_compression option. http://cassandra.apache.org/doc/cql3/CQL.html -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Updated] (CASSANDRA-6331) Add LZ4Compressor in CQL document
[ https://issues.apache.org/jira/browse/CASSANDRA-6331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Wu updated CASSANDRA-6331: -- Labels: cql3 (was: ) Add LZ4Compressor in CQL document - Key: CASSANDRA-6331 URL: https://issues.apache.org/jira/browse/CASSANDRA-6331 Project: Cassandra Issue Type: Improvement Components: Documentation website Reporter: Ray Wu Priority: Trivial Labels: cql3 LZ4Compressor should also be documented in sstable_compression option. http://cassandra.apache.org/doc/cql3/CQL.html -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Updated] (CASSANDRA-6289) Murmur3Partitioner doesn't yield proper ownership calculation
[ https://issues.apache.org/jira/browse/CASSANDRA-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis updated CASSANDRA-6289: -- Component/s: Tools Priority: Minor (was: Major) Fix Version/s: 1.2.12 Murmur3Partitioner doesn't yield proper ownership calculation - Key: CASSANDRA-6289 URL: https://issues.apache.org/jira/browse/CASSANDRA-6289 Project: Cassandra Issue Type: Bug Components: Tools Reporter: Jackson Chung Assignee: Mikhail Stepura Priority: Minor Fix For: 1.2.12 In a new 1.2 install with Murmur3 as default, I setup a test cluster with N=RF=3 for the cluster size and RF for a keyspace but when I look at the ring output (with the keyspace name), to my surprise it shows RF=2. Further investigate shows the total replica is an addition of the float value from the effectiveOwnership. But that results in 1 for the setup: {panel} #bean is set to org.apache.cassandra.db:type=StorageService $run effectiveOwnership Keyspace1 #calling operation effectiveOwnership of mbean org.apache.cassandra.db:type=StorageService #operation returns: \{ /127.0.0.1 = 0.989; /127.0.0.2 = 0.989; /127.0.0.3 = 0.989; \} {panel} {panel} $ ./bin/nodetool -h 0 -p 7100 ring Keyspace1 Datacenter: datacenter1 == Replicas: 2 AddressRackStatus State LoadOwns Token 3074457345618258602 127.0.0.1 rack1 Up Normal 1.02 GB 100.00% -9223372036854775808 127.0.0.2 rack1 Up Normal 996.38 MB 100.00% -3074457345618258603 127.0.0.3 rack1 Up Normal 980.55 MB 100.00% 3074457345618258602 {panel} {panel} Keyspace: Keyspace1: Replication Strategy: org.apache.cassandra.locator.SimpleStrategy Durable Writes: true Options: [replication_factor:3] {panel} The println would simply class the float value to int, so i guess that's round down. When using RandomPartitioner, the effectiveOwnership will return 1.0 So I guess the real question is, is the Murmur3 calculation correct? Or is it losing precision? If it is correct, then I guess we need to force the float - int to round up? (is that even the right thing to do?) -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Assigned] (CASSANDRA-6289) Murmur3Partitioner doesn't yield proper ownership calculation
[ https://issues.apache.org/jira/browse/CASSANDRA-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis reassigned CASSANDRA-6289: - Assignee: Mikhail Stepura Murmur3Partitioner doesn't yield proper ownership calculation - Key: CASSANDRA-6289 URL: https://issues.apache.org/jira/browse/CASSANDRA-6289 Project: Cassandra Issue Type: Bug Components: Tools Reporter: Jackson Chung Assignee: Mikhail Stepura Fix For: 1.2.12 In a new 1.2 install with Murmur3 as default, I setup a test cluster with N=RF=3 for the cluster size and RF for a keyspace but when I look at the ring output (with the keyspace name), to my surprise it shows RF=2. Further investigate shows the total replica is an addition of the float value from the effectiveOwnership. But that results in 1 for the setup: {panel} #bean is set to org.apache.cassandra.db:type=StorageService $run effectiveOwnership Keyspace1 #calling operation effectiveOwnership of mbean org.apache.cassandra.db:type=StorageService #operation returns: \{ /127.0.0.1 = 0.989; /127.0.0.2 = 0.989; /127.0.0.3 = 0.989; \} {panel} {panel} $ ./bin/nodetool -h 0 -p 7100 ring Keyspace1 Datacenter: datacenter1 == Replicas: 2 AddressRackStatus State LoadOwns Token 3074457345618258602 127.0.0.1 rack1 Up Normal 1.02 GB 100.00% -9223372036854775808 127.0.0.2 rack1 Up Normal 996.38 MB 100.00% -3074457345618258603 127.0.0.3 rack1 Up Normal 980.55 MB 100.00% 3074457345618258602 {panel} {panel} Keyspace: Keyspace1: Replication Strategy: org.apache.cassandra.locator.SimpleStrategy Durable Writes: true Options: [replication_factor:3] {panel} The println would simply class the float value to int, so i guess that's round down. When using RandomPartitioner, the effectiveOwnership will return 1.0 So I guess the real question is, is the Murmur3 calculation correct? Or is it losing precision? If it is correct, then I guess we need to force the float - int to round up? (is that even the right thing to do?) -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Commented] (CASSANDRA-6296) Bootstrapping a new node should not require much compaction when leveled compaction is used
[ https://issues.apache.org/jira/browse/CASSANDRA-6296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819328#comment-13819328 ] Brandon Williams commented on CASSANDRA-6296: - Doesn't that assume the replicas are all at the same spot, compaction-wise? Bootstrapping a new node should not require much compaction when leveled compaction is used --- Key: CASSANDRA-6296 URL: https://issues.apache.org/jira/browse/CASSANDRA-6296 Project: Cassandra Issue Type: Improvement Reporter: T Jake Luciani Priority: Minor boostrapping a new node currently requires recompacting all data. In the case of leveled compaction we already have the data in non-overlapping levels. Since we stream from a single host for a single range this shouldn't require any compaction if the sstable is level 0 -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Commented] (CASSANDRA-6296) Bootstrapping a new node should not require much compaction when leveled compaction is used
[ https://issues.apache.org/jira/browse/CASSANDRA-6296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819340#comment-13819340 ] T Jake Luciani commented on CASSANDRA-6296: --- No, because leveled doesn't overlap ranges within a level, so it doesn't matter what state each range is in as long as its consistent with the replica for that range Bootstrapping a new node should not require much compaction when leveled compaction is used --- Key: CASSANDRA-6296 URL: https://issues.apache.org/jira/browse/CASSANDRA-6296 Project: Cassandra Issue Type: Improvement Reporter: T Jake Luciani Priority: Minor boostrapping a new node currently requires recompacting all data. In the case of leveled compaction we already have the data in non-overlapping levels. Since we stream from a single host for a single range this shouldn't require any compaction if the sstable is level 0 -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Commented] (CASSANDRA-6275) 2.0.x leaks file handles
[ https://issues.apache.org/jira/browse/CASSANDRA-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819357#comment-13819357 ] Jonathan Ellis commented on CASSANDRA-6275: --- [~ash2k] or others, can you verify if this is also a problem in 1.2.11? 2.0.x leaks file handles Key: CASSANDRA-6275 URL: https://issues.apache.org/jira/browse/CASSANDRA-6275 Project: Cassandra Issue Type: Bug Components: Core Environment: java version 1.7.0_25 Java(TM) SE Runtime Environment (build 1.7.0_25-b15) Java HotSpot(TM) 64-Bit Server VM (build 23.25-b01, mixed mode) Linux cassandra-test1 2.6.32-279.el6.x86_64 #1 SMP Thu Jun 21 15:00:18 EDT 2012 x86_64 x86_64 x86_64 GNU/Linux Reporter: Mikhail Mazursky Attachments: cassandra_jstack.txt, leak.log, slog.gz Looks like C* is leaking file descriptors when doing lots of CAS operations. {noformat} $ sudo cat /proc/15455/limits Limit Soft Limit Hard Limit Units Max cpu time unlimitedunlimitedseconds Max file size unlimitedunlimitedbytes Max data size unlimitedunlimitedbytes Max stack size10485760 unlimitedbytes Max core file size00bytes Max resident set unlimitedunlimitedbytes Max processes 1024 unlimitedprocesses Max open files4096 4096 files Max locked memory unlimitedunlimitedbytes Max address space unlimitedunlimitedbytes Max file locksunlimitedunlimitedlocks Max pending signals 1463314633signals Max msgqueue size 819200 819200 bytes Max nice priority 00 Max realtime priority 00 Max realtime timeout unlimitedunlimitedus {noformat} Looks like the problem is not in limits. Before load test: {noformat} cassandra-test0 ~]$ lsof -n | grep java | wc -l 166 cassandra-test1 ~]$ lsof -n | grep java | wc -l 164 cassandra-test2 ~]$ lsof -n | grep java | wc -l 180 {noformat} After load test: {noformat} cassandra-test0 ~]$ lsof -n | grep java | wc -l 967 cassandra-test1 ~]$ lsof -n | grep java | wc -l 1766 cassandra-test2 ~]$ lsof -n | grep java | wc -l 2578 {noformat} Most opened files have names like: {noformat} java 16890 cassandra 1636r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1637r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1638r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1639r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1640r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1641r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1642r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1643r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1644r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1645r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1646r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1647r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1648r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1649r REG 202,17 161158485 655420
[jira] [Commented] (CASSANDRA-6275) 2.0.x leaks file handles
[ https://issues.apache.org/jira/browse/CASSANDRA-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819363#comment-13819363 ] Gianluca Borello commented on CASSANDRA-6275: - [~jbellis], FWIW 1.2.11 is working fine for us (I have one week of uptime so far since the downgrade). 2.0.x leaks file handles Key: CASSANDRA-6275 URL: https://issues.apache.org/jira/browse/CASSANDRA-6275 Project: Cassandra Issue Type: Bug Components: Core Environment: java version 1.7.0_25 Java(TM) SE Runtime Environment (build 1.7.0_25-b15) Java HotSpot(TM) 64-Bit Server VM (build 23.25-b01, mixed mode) Linux cassandra-test1 2.6.32-279.el6.x86_64 #1 SMP Thu Jun 21 15:00:18 EDT 2012 x86_64 x86_64 x86_64 GNU/Linux Reporter: Mikhail Mazursky Attachments: cassandra_jstack.txt, leak.log, slog.gz Looks like C* is leaking file descriptors when doing lots of CAS operations. {noformat} $ sudo cat /proc/15455/limits Limit Soft Limit Hard Limit Units Max cpu time unlimitedunlimitedseconds Max file size unlimitedunlimitedbytes Max data size unlimitedunlimitedbytes Max stack size10485760 unlimitedbytes Max core file size00bytes Max resident set unlimitedunlimitedbytes Max processes 1024 unlimitedprocesses Max open files4096 4096 files Max locked memory unlimitedunlimitedbytes Max address space unlimitedunlimitedbytes Max file locksunlimitedunlimitedlocks Max pending signals 1463314633signals Max msgqueue size 819200 819200 bytes Max nice priority 00 Max realtime priority 00 Max realtime timeout unlimitedunlimitedus {noformat} Looks like the problem is not in limits. Before load test: {noformat} cassandra-test0 ~]$ lsof -n | grep java | wc -l 166 cassandra-test1 ~]$ lsof -n | grep java | wc -l 164 cassandra-test2 ~]$ lsof -n | grep java | wc -l 180 {noformat} After load test: {noformat} cassandra-test0 ~]$ lsof -n | grep java | wc -l 967 cassandra-test1 ~]$ lsof -n | grep java | wc -l 1766 cassandra-test2 ~]$ lsof -n | grep java | wc -l 2578 {noformat} Most opened files have names like: {noformat} java 16890 cassandra 1636r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1637r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1638r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1639r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1640r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1641r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1642r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1643r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1644r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1645r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1646r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1647r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1648r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1649r REG 202,17 161158485 655420
[jira] [Commented] (CASSANDRA-6275) 2.0.x leaks file handles
[ https://issues.apache.org/jira/browse/CASSANDRA-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819376#comment-13819376 ] Jonathan Ellis commented on CASSANDRA-6275: --- Can you have a look [~krummas] ? 2.0.x leaks file handles Key: CASSANDRA-6275 URL: https://issues.apache.org/jira/browse/CASSANDRA-6275 Project: Cassandra Issue Type: Bug Components: Core Environment: java version 1.7.0_25 Java(TM) SE Runtime Environment (build 1.7.0_25-b15) Java HotSpot(TM) 64-Bit Server VM (build 23.25-b01, mixed mode) Linux cassandra-test1 2.6.32-279.el6.x86_64 #1 SMP Thu Jun 21 15:00:18 EDT 2012 x86_64 x86_64 x86_64 GNU/Linux Reporter: Mikhail Mazursky Attachments: cassandra_jstack.txt, leak.log, slog.gz Looks like C* is leaking file descriptors when doing lots of CAS operations. {noformat} $ sudo cat /proc/15455/limits Limit Soft Limit Hard Limit Units Max cpu time unlimitedunlimitedseconds Max file size unlimitedunlimitedbytes Max data size unlimitedunlimitedbytes Max stack size10485760 unlimitedbytes Max core file size00bytes Max resident set unlimitedunlimitedbytes Max processes 1024 unlimitedprocesses Max open files4096 4096 files Max locked memory unlimitedunlimitedbytes Max address space unlimitedunlimitedbytes Max file locksunlimitedunlimitedlocks Max pending signals 1463314633signals Max msgqueue size 819200 819200 bytes Max nice priority 00 Max realtime priority 00 Max realtime timeout unlimitedunlimitedus {noformat} Looks like the problem is not in limits. Before load test: {noformat} cassandra-test0 ~]$ lsof -n | grep java | wc -l 166 cassandra-test1 ~]$ lsof -n | grep java | wc -l 164 cassandra-test2 ~]$ lsof -n | grep java | wc -l 180 {noformat} After load test: {noformat} cassandra-test0 ~]$ lsof -n | grep java | wc -l 967 cassandra-test1 ~]$ lsof -n | grep java | wc -l 1766 cassandra-test2 ~]$ lsof -n | grep java | wc -l 2578 {noformat} Most opened files have names like: {noformat} java 16890 cassandra 1636r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1637r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1638r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1639r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1640r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1641r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1642r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1643r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1644r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1645r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1646r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1647r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1648r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1649r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra
[jira] [Commented] (CASSANDRA-6311) Update CqlPagingRecordReader to use the latest Cql pagination
[ https://issues.apache.org/jira/browse/CASSANDRA-6311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819530#comment-13819530 ] Alex Liu commented on CASSANDRA-6311: - We need get LOCAL_ONE CL level in Java driver. Update CqlPagingRecordReader to use the latest Cql pagination - Key: CASSANDRA-6311 URL: https://issues.apache.org/jira/browse/CASSANDRA-6311 Project: Cassandra Issue Type: Improvement Components: Hadoop Reporter: Alex Liu Assignee: Alex Liu Fix For: 2.0.3 Since the latest Cql pagination is done and it should be more efficient, so we need update CqlPagingRecordReader to use it instead of the custom thrift paging. -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Created] (CASSANDRA-6332) Cassandra startup failure: java.util.concurrent.ExecutionException: java.lang.RuntimeException: 706167655f74616773 is not defined as a collection
Prateek created CASSANDRA-6332: -- Summary: Cassandra startup failure: java.util.concurrent.ExecutionException: java.lang.RuntimeException: 706167655f74616773 is not defined as a collection Key: CASSANDRA-6332 URL: https://issues.apache.org/jira/browse/CASSANDRA-6332 Project: Cassandra Issue Type: Bug Environment: Ubuntu 12.04 Cassandra 2.0.1 Reporter: Prateek Priority: Critical The cassandra node fails to startup with the following error message. This is currently impacting availability of our production cluster so your quick response is highly appreciated. ERROR 22:58:26,046 Exception encountered during startup java.lang.RuntimeException: java.util.concurrent.ExecutionException: java.lang.RuntimeException: 706167655f74616773 is not defined as a collection at org.apache.cassandra.utils.FBUtilities.waitOnFuture(FBUtilities.java:411) at org.apache.cassandra.utils.FBUtilities.waitOnFutures(FBUtilities.java:400) at org.apache.cassandra.db.commitlog.CommitLogReplayer.recover(CommitLogReplayer.java:273) at org.apache.cassandra.db.commitlog.CommitLogReplayer.recover(CommitLogReplayer.java:96) at org.apache.cassandra.db.commitlog.CommitLog.recover(CommitLog.java:146) at org.apache.cassandra.db.commitlog.CommitLog.recover(CommitLog.java:126) at org.apache.cassandra.service.CassandraDaemon.setup(CassandraDaemon.java:299) at org.apache.cassandra.service.CassandraDaemon.activate(CassandraDaemon.java:442) at org.apache.cassandra.service.CassandraDaemon.main(CassandraDaemon.java:485) Caused by: java.util.concurrent.ExecutionException: java.lang.RuntimeException: 706167655f74616773 is not defined as a collection at java.util.concurrent.FutureTask.report(FutureTask.java:122) at java.util.concurrent.FutureTask.get(FutureTask.java:188) at org.apache.cassandra.utils.FBUtilities.waitOnFuture(FBUtilities.java:407) ... 8 more Caused by: java.lang.RuntimeException: 706167655f74616773 is not defined as a collection at org.apache.cassandra.db.marshal.ColumnToCollectionType.compareCollectionMembers(ColumnToCollectionType.java:72) at org.apache.cassandra.db.marshal.AbstractCompositeType.compare(AbstractCompositeType.java:85) at org.apache.cassandra.db.marshal.AbstractCompositeType.compare(AbstractCompositeType.java:35) at edu.stanford.ppl.concurrent.SnapTreeMap$1.compareTo(SnapTreeMap.java:538) at edu.stanford.ppl.concurrent.SnapTreeMap.attemptUpdate(SnapTreeMap.java:1108) at edu.stanford.ppl.concurrent.SnapTreeMap.attemptUpdate(SnapTreeMap.java:1192) at edu.stanford.ppl.concurrent.SnapTreeMap.updateUnderRoot(SnapTreeMap.java:1059) at edu.stanford.ppl.concurrent.SnapTreeMap.update(SnapTreeMap.java:1023) at edu.stanford.ppl.concurrent.SnapTreeMap.putIfAbsent(SnapTreeMap.java:985) at org.apache.cassandra.db.AtomicSortedColumns$Holder.addColumn(AtomicSortedColumns.java:323) at org.apache.cassandra.db.AtomicSortedColumns.addAllWithSizeDelta(AtomicSortedColumns.java:195) at org.apache.cassandra.db.Memtable.resolve(Memtable.java:196) at org.apache.cassandra.db.Memtable.put(Memtable.java:160) at org.apache.cassandra.db.ColumnFamilyStore.apply(ColumnFamilyStore.java:842) at org.apache.cassandra.db.Keyspace.apply(Keyspace.java:373) at org.apache.cassandra.db.Keyspace.apply(Keyspace.java:338) at org.apache.cassandra.db.commitlog.CommitLogReplayer$1.runMayThrow(CommitLogReplayer.java:265) -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Updated] (CASSANDRA-6289) Murmur3Partitioner doesn't yield proper ownership calculation
[ https://issues.apache.org/jira/browse/CASSANDRA-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikhail Stepura updated CASSANDRA-6289: --- Attachment: cassandra-1.2-6289.patch Use {{Math.round}} instead of truncating Murmur3Partitioner doesn't yield proper ownership calculation - Key: CASSANDRA-6289 URL: https://issues.apache.org/jira/browse/CASSANDRA-6289 Project: Cassandra Issue Type: Bug Components: Tools Reporter: Jackson Chung Assignee: Mikhail Stepura Priority: Minor Fix For: 1.2.12 Attachments: cassandra-1.2-6289.patch In a new 1.2 install with Murmur3 as default, I setup a test cluster with N=RF=3 for the cluster size and RF for a keyspace but when I look at the ring output (with the keyspace name), to my surprise it shows RF=2. Further investigate shows the total replica is an addition of the float value from the effectiveOwnership. But that results in 1 for the setup: {panel} #bean is set to org.apache.cassandra.db:type=StorageService $run effectiveOwnership Keyspace1 #calling operation effectiveOwnership of mbean org.apache.cassandra.db:type=StorageService #operation returns: \{ /127.0.0.1 = 0.989; /127.0.0.2 = 0.989; /127.0.0.3 = 0.989; \} {panel} {panel} $ ./bin/nodetool -h 0 -p 7100 ring Keyspace1 Datacenter: datacenter1 == Replicas: 2 AddressRackStatus State LoadOwns Token 3074457345618258602 127.0.0.1 rack1 Up Normal 1.02 GB 100.00% -9223372036854775808 127.0.0.2 rack1 Up Normal 996.38 MB 100.00% -3074457345618258603 127.0.0.3 rack1 Up Normal 980.55 MB 100.00% 3074457345618258602 {panel} {panel} Keyspace: Keyspace1: Replication Strategy: org.apache.cassandra.locator.SimpleStrategy Durable Writes: true Options: [replication_factor:3] {panel} The println would simply class the float value to int, so i guess that's round down. When using RandomPartitioner, the effectiveOwnership will return 1.0 So I guess the real question is, is the Murmur3 calculation correct? Or is it losing precision? If it is correct, then I guess we need to force the float - int to round up? (is that even the right thing to do?) -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Commented] (CASSANDRA-6275) 2.0.x leaks file handles
[ https://issues.apache.org/jira/browse/CASSANDRA-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819884#comment-13819884 ] Duncan Sands commented on CASSANDRA-6275: - All our leaked fd's were for a large table that uses TTL. We also don't have any problems with 1.2.11 (which we had to downgrade to, just like Gianluca). 2.0.x leaks file handles Key: CASSANDRA-6275 URL: https://issues.apache.org/jira/browse/CASSANDRA-6275 Project: Cassandra Issue Type: Bug Components: Core Environment: java version 1.7.0_25 Java(TM) SE Runtime Environment (build 1.7.0_25-b15) Java HotSpot(TM) 64-Bit Server VM (build 23.25-b01, mixed mode) Linux cassandra-test1 2.6.32-279.el6.x86_64 #1 SMP Thu Jun 21 15:00:18 EDT 2012 x86_64 x86_64 x86_64 GNU/Linux Reporter: Mikhail Mazursky Attachments: cassandra_jstack.txt, leak.log, slog.gz Looks like C* is leaking file descriptors when doing lots of CAS operations. {noformat} $ sudo cat /proc/15455/limits Limit Soft Limit Hard Limit Units Max cpu time unlimitedunlimitedseconds Max file size unlimitedunlimitedbytes Max data size unlimitedunlimitedbytes Max stack size10485760 unlimitedbytes Max core file size00bytes Max resident set unlimitedunlimitedbytes Max processes 1024 unlimitedprocesses Max open files4096 4096 files Max locked memory unlimitedunlimitedbytes Max address space unlimitedunlimitedbytes Max file locksunlimitedunlimitedlocks Max pending signals 1463314633signals Max msgqueue size 819200 819200 bytes Max nice priority 00 Max realtime priority 00 Max realtime timeout unlimitedunlimitedus {noformat} Looks like the problem is not in limits. Before load test: {noformat} cassandra-test0 ~]$ lsof -n | grep java | wc -l 166 cassandra-test1 ~]$ lsof -n | grep java | wc -l 164 cassandra-test2 ~]$ lsof -n | grep java | wc -l 180 {noformat} After load test: {noformat} cassandra-test0 ~]$ lsof -n | grep java | wc -l 967 cassandra-test1 ~]$ lsof -n | grep java | wc -l 1766 cassandra-test2 ~]$ lsof -n | grep java | wc -l 2578 {noformat} Most opened files have names like: {noformat} java 16890 cassandra 1636r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1637r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1638r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1639r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1640r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1641r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1642r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1643r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1644r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1645r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1646r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1647r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1648r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1649r REG 202,17
[jira] [Commented] (CASSANDRA-6275) 2.0.x leaks file handles
[ https://issues.apache.org/jira/browse/CASSANDRA-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819890#comment-13819890 ] Mikhail Mazursky commented on CASSANDRA-6275: - [~jbellis] my test workload uses LWT so it cannot be run on 1.2.x. The written columns themself do not use TTL but AFAIK Paxos table uses TTL. And in my case I see a lot of open Paxos-related files. So, taking into account what others said above, looks like the problem is somehow connected to TTL. 2.0.x leaks file handles Key: CASSANDRA-6275 URL: https://issues.apache.org/jira/browse/CASSANDRA-6275 Project: Cassandra Issue Type: Bug Components: Core Environment: java version 1.7.0_25 Java(TM) SE Runtime Environment (build 1.7.0_25-b15) Java HotSpot(TM) 64-Bit Server VM (build 23.25-b01, mixed mode) Linux cassandra-test1 2.6.32-279.el6.x86_64 #1 SMP Thu Jun 21 15:00:18 EDT 2012 x86_64 x86_64 x86_64 GNU/Linux Reporter: Mikhail Mazursky Attachments: cassandra_jstack.txt, leak.log, slog.gz Looks like C* is leaking file descriptors when doing lots of CAS operations. {noformat} $ sudo cat /proc/15455/limits Limit Soft Limit Hard Limit Units Max cpu time unlimitedunlimitedseconds Max file size unlimitedunlimitedbytes Max data size unlimitedunlimitedbytes Max stack size10485760 unlimitedbytes Max core file size00bytes Max resident set unlimitedunlimitedbytes Max processes 1024 unlimitedprocesses Max open files4096 4096 files Max locked memory unlimitedunlimitedbytes Max address space unlimitedunlimitedbytes Max file locksunlimitedunlimitedlocks Max pending signals 1463314633signals Max msgqueue size 819200 819200 bytes Max nice priority 00 Max realtime priority 00 Max realtime timeout unlimitedunlimitedus {noformat} Looks like the problem is not in limits. Before load test: {noformat} cassandra-test0 ~]$ lsof -n | grep java | wc -l 166 cassandra-test1 ~]$ lsof -n | grep java | wc -l 164 cassandra-test2 ~]$ lsof -n | grep java | wc -l 180 {noformat} After load test: {noformat} cassandra-test0 ~]$ lsof -n | grep java | wc -l 967 cassandra-test1 ~]$ lsof -n | grep java | wc -l 1766 cassandra-test2 ~]$ lsof -n | grep java | wc -l 2578 {noformat} Most opened files have names like: {noformat} java 16890 cassandra 1636r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1637r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1638r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1639r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1640r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1641r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1642r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1643r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1644r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1645r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1646r REG 202,17 88724987 655520 /var/lib/cassandra/data/system/paxos/system-paxos-jb-644-Data.db java 16890 cassandra 1647r REG 202,17 161158485 655420 /var/lib/cassandra/data/system/paxos/system-paxos-jb-255-Data.db java 16890 cassandra 1648r REG
[jira] [Resolved] (CASSANDRA-6318) IN predicates on non-primary-key columns (%s) is not yet supported
[ https://issues.apache.org/jira/browse/CASSANDRA-6318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sylvain Lebresne resolved CASSANDRA-6318. - Resolution: Fixed If you're referring to 2ndary indexes then that's indeed CASSANDRA-4386 but otherwise that's a duplicate of CASSANDRA-4762. IN predicates on non-primary-key columns (%s) is not yet supported -- Key: CASSANDRA-6318 URL: https://issues.apache.org/jira/browse/CASSANDRA-6318 Project: Cassandra Issue Type: Bug Reporter: Sergey Nagaytsev Labels: cql3 Query: SELECT * FROM post WHERE blog IN (1,2) AND author=3 ALLOW FILTERING -- contrived Error: IN predicates on non-primary-key columns (blog) is not yet supported Please either implement, set milestone or say will never be implemented ! P.S. Did search, seemingly found no issue/plan related to it. Maybe CASSANDRA-6048 ? P.S.2 What is recommended workaround for this ? Manual index tables, what are design guidelines for them ? -- This message was sent by Atlassian JIRA (v6.1#6144)