[jira] [Updated] (CASSANDRA-2221) 'show create' commands on the CLI to export schema
[ https://issues.apache.org/jira/browse/CASSANDRA-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aaron Morton updated CASSANDRA-2221: Attachment: 0001-change-show-keyspace-to-create-cli-script.patch Attached patch 0001 is for 0.7 and modifies the show keyspace statement to create a cli script. The previous statement was show keyspaces changed to show keyspace keyspace? (dropped the s) to match describe keyspace keyspace? Also bug fix to unescape the default validation clause. 'show create' commands on the CLI to export schema -- Key: CASSANDRA-2221 URL: https://issues.apache.org/jira/browse/CASSANDRA-2221 Project: Cassandra Issue Type: Improvement Components: Tools Reporter: Jeremy Hanna Assignee: Aaron Morton Priority: Minor Labels: cli Fix For: 0.8.1 Attachments: 0001-change-show-keyspace-to-create-cli-script.patch It would be nice to have 'show create' type of commands on the command-line so that it would generate the DDL for the schema. A scenario that would make this useful is where a team works out a data model over time with a dev cluster. They want to use parts of that schema for new clusters that they create, like a staging/prod cluster. It would be very handy in this scenario to have some sort of export mechanism. Another use case is for testing purposes - you want to replicate a problem. We currently have schematool for import/export but that is deprecated and it exports into yaml. This new feature would just be able to 'show' - or export if they want the entire keyspace - into a script or commands that could be used in a cli script. It would need to be able to regenerate everything about the keyspace including indexes and metadata. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2221) 'show create' commands on the CLI to export schema
[ https://issues.apache.org/jira/browse/CASSANDRA-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aaron Morton updated CASSANDRA-2221: Attachment: 0001-change-show-keyspace-to-create-cli-script-v0.8.patch I created the attached 0001-change...v0.8 patch before I saw Jonathans last comment. It's like the 0.7 one but rebased against the 0.8 branch and includes the additional 0.8 attributes, and updates the 0.8 help. Also adds unescaping of the value for row cache provider. 'show create' commands on the CLI to export schema -- Key: CASSANDRA-2221 URL: https://issues.apache.org/jira/browse/CASSANDRA-2221 Project: Cassandra Issue Type: Improvement Components: Tools Reporter: Jeremy Hanna Assignee: Aaron Morton Priority: Minor Labels: cli Fix For: 0.8.1 Attachments: 0001-change-show-keyspace-to-create-cli-script-v0.8.patch, 0001-change-show-keyspace-to-create-cli-script.patch It would be nice to have 'show create' type of commands on the command-line so that it would generate the DDL for the schema. A scenario that would make this useful is where a team works out a data model over time with a dev cluster. They want to use parts of that schema for new clusters that they create, like a staging/prod cluster. It would be very handy in this scenario to have some sort of export mechanism. Another use case is for testing purposes - you want to replicate a problem. We currently have schematool for import/export but that is deprecated and it exports into yaml. This new feature would just be able to 'show' - or export if they want the entire keyspace - into a script or commands that could be used in a cli script. It would need to be able to regenerate everything about the keyspace including indexes and metadata. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2433) Failed Streams Break Repair
[ https://issues.apache.org/jira/browse/CASSANDRA-2433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sylvain Lebresne updated CASSANDRA-2433: Attachment: 0004-Reports-validation-compaction-errors-back-to-repair.patch 0003-Report-streaming-errors-back-to-repair.patch 0002-Register-in-gossip-to-handle-node-failures.patch 0001-Put-repair-session-on-a-Stage-and-add-a-method-to-re.patch Attached patches are against 0.8. This tries to catch what can go wrong with repair and reports it back to the user by making the full repair throw an exception. More precisely: * patch 0001: add a method to repair for reporting failure and propagate that up to the repair session. This puts repair session on a specific stage (instead of having RepairSession be a Thread) and use a future to allow waiting on completion. This allows a cleaner API to deal with errors (the Future.get() simply throw an ExecutionException) and this add the advantage of stage management to repair sessions. * patch 0002: Make repair session register through gossip to be informed of node dying and failing the session when that happens. * patch 0003: Reports errors during streaming to the repair session. This actually introduces a generic way to handle streaming failures and after that we should probably update the other user of streaming to deal correctly with failure too. * patch 004: Catch errors during validation compaction and push them up to repair (whether those happens on the coordinator of the repair or not). Note that this includes streaming failures and thus includes stuffs from the patch of Aaron Morton attached on CASSANDRA-2088, but contrarily to that patch, it takes the approach of failing fast. This means that if streaming fails on a file, it fails the streaming altogether (same for repair). I think this is simpler code-wise and more useful from the point of view of the user, since a failure means the use will have to retry anyway. Last but not least, this makes some modification to messages. So either this goes into 0.8.0 (which I think it should, because this really is a bug fix and fixes something that is a pain for users), or we should had a new messaging version for 0.8.0 and modify this to take it into account (we should probably add a 0.8.0 version to the messaging service anyway). Failed Streams Break Repair --- Key: CASSANDRA-2433 URL: https://issues.apache.org/jira/browse/CASSANDRA-2433 Project: Cassandra Issue Type: Bug Affects Versions: 0.7.4 Reporter: Benjamin Coverston Assignee: Sylvain Lebresne Labels: repair Fix For: 0.8.1 Attachments: 0001-Put-repair-session-on-a-Stage-and-add-a-method-to-re.patch, 0002-Register-in-gossip-to-handle-node-failures.patch, 0003-Report-streaming-errors-back-to-repair.patch, 0004-Reports-validation-compaction-errors-back-to-repair.patch Running repair in cases where a stream fails we are seeing multiple problems. 1. Although retry is initiated and completes, the old stream doesn't seem to clean itself up and repair hangs. 2. The temp files are left behind and multiple failures can end up filling up the data partition. These issues together are making repair very difficult for nearly everyone running repair on a non-trivial sized data set. This issue is also being worked on w.r.t CASSANDRA-2088, however that was moved to 0.8 for a few reasons. This ticket is to fix the immediate issues that we are seeing in 0.7. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2516) Allow LOCAL_QUORUM, EACH_QUORUM CLs to work w/ any Strategy class
[ https://issues.apache.org/jira/browse/CASSANDRA-2516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022732#comment-13022732 ] Sylvain Lebresne commented on CASSANDRA-2516: - +1 (but note that it's a 0.8 patch, so it should probably be rebased to 0.7 and applied there first) Allow LOCAL_QUORUM, EACH_QUORUM CLs to work w/ any Strategy class - Key: CASSANDRA-2516 URL: https://issues.apache.org/jira/browse/CASSANDRA-2516 Project: Cassandra Issue Type: Bug Components: Core Affects Versions: 0.7.0 Reporter: Jonathan Ellis Assignee: Jonathan Ellis Priority: Minor Fix For: 0.7.5 Attachments: 2516.txt -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-1941) Add distributed test doing reads during MovementTest
[ https://issues.apache.org/jira/browse/CASSANDRA-1941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pavel Yaskevich updated CASSANDRA-1941: --- Attachment: CASSANDRA-1941.patch DataStreamingTest added which does the following: 1). insert 100 rows to the cluster with RF=ringSize-1 2). decommission of the last node 3). stop/wipe-state on the last node 4). start reading data in the separate thread while last node is not fully started 5). start of the last node (clean after wipe-state) Add distributed test doing reads during MovementTest Key: CASSANDRA-1941 URL: https://issues.apache.org/jira/browse/CASSANDRA-1941 Project: Cassandra Issue Type: Test Components: Core Reporter: Jonathan Ellis Assignee: Pavel Yaskevich Priority: Minor Fix For: 0.8.1 Attachments: CASSANDRA-1941.patch Original Estimate: 8h Remaining Estimate: 8h Following introduction of the distributed test framework in CASSANDRA-1859, we should extend that to test reads while bootstrap happens (this is a scenario that has had regressions in the past). See test/distributed/README.txt for intro. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
svn commit: r1095696 - in /cassandra/branches/cassandra-0.7: src/java/org/apache/cassandra/config/ src/java/org/apache/cassandra/db/ src/java/org/apache/cassandra/service/ test/unit/org/apache/cassand
Author: slebresne Date: Thu Apr 21 13:25:36 2011 New Revision: 1095696 URL: http://svn.apache.org/viewvc?rev=1095696view=rev Log: Fix updating column metadata validation class patch by jbellis; reviewed by slebresne for CASSANDRA-2512 Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/config/CFMetaData.java cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/config/ColumnDefinition.java cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/ColumnFamilyStore.java cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageService.java cassandra/branches/cassandra-0.7/test/unit/org/apache/cassandra/db/ColumnFamilyStoreTest.java Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/config/CFMetaData.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/config/CFMetaData.java?rev=1095696r1=1095695r2=1095696view=diff == --- cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/config/CFMetaData.java (original) +++ cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/config/CFMetaData.java Thu Apr 21 13:25:36 2011 @@ -582,7 +582,7 @@ public final class CFMetaData AbstractType validator = defaultValidator; ColumnDefinition columnDefinition = column_metadata.get(column); if (columnDefinition != null) -validator = columnDefinition.validator; +validator = columnDefinition.getValidator(); return validator; } @@ -684,10 +684,12 @@ public final class CFMetaData // update the ones staying for (org.apache.cassandra.avro.ColumnDef def : cf_def.column_metadata) { -if (!column_metadata.containsKey(def.name)) +ColumnDefinition oldDef = column_metadata.get(def.name); +if (oldDef == null) continue; -column_metadata.get(def.name).setIndexType(def.index_type == null ? null : org.apache.cassandra.thrift.IndexType.valueOf(def.index_type.name())); -column_metadata.get(def.name).setIndexName(def.index_name == null ? null : def.index_name.toString()); + oldDef.setValidator(DatabaseDescriptor.getComparator(def.validation_class)); +oldDef.setIndexType(def.index_type == null ? null : org.apache.cassandra.thrift.IndexType.valueOf(def.index_type.name())); +oldDef.setIndexName(def.index_name == null ? null : def.index_name.toString()); } // add the new ones coming in. for (org.apache.cassandra.avro.ColumnDef def : toAdd) @@ -732,7 +734,7 @@ public final class CFMetaData tcd.setIndex_name(cd.getIndexName()); tcd.setIndex_type(cd.getIndexType()); tcd.setName(cd.name); -tcd.setValidation_class(cd.validator.getClass().getName()); +tcd.setValidation_class(cd.getValidator().getClass().getName()); column_meta.add(tcd); } def.setColumn_metadata(column_meta); @@ -773,7 +775,7 @@ public final class CFMetaData tcd.index_name = cd.getIndexName(); tcd.index_type = cd.getIndexType() == null ? null : org.apache.cassandra.avro.IndexType.valueOf(cd.getIndexType().name()); tcd.name = ByteBufferUtil.clone(cd.name); -tcd.validation_class = cd.validator.getClass().getName(); +tcd.validation_class = cd.getValidator().getClass().getName(); column_meta.add(tcd); } def.column_metadata = column_meta; Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/config/ColumnDefinition.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/config/ColumnDefinition.java?rev=1095696r1=1095695r2=1095696view=diff == --- cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/config/ColumnDefinition.java (original) +++ cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/config/ColumnDefinition.java Thu Apr 21 13:25:36 2011 @@ -36,7 +36,7 @@ import org.apache.cassandra.utils.ByteBu public class ColumnDefinition { public final ByteBuffer name; -public final AbstractType validator; +private AbstractType validator; private IndexType index_type; private String index_name; @@ -180,4 +180,14 @@ public class ColumnDefinition { this.index_type = index_type; } + +public AbstractType getValidator() +{ +return validator; +} + +public void setValidator(AbstractType validator) +{ +this.validator = validator; +} } Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/ColumnFamilyStore.java URL:
svn commit: r1095699 - in /cassandra/branches/cassandra-0.8: ./ contrib/ interface/thrift/gen-java/org/apache/cassandra/thrift/ src/java/org/apache/cassandra/config/ src/java/org/apache/cassandra/db/
Author: slebresne Date: Thu Apr 21 13:29:53 2011 New Revision: 1095699 URL: http://svn.apache.org/viewvc?rev=1095699view=rev Log: merge CASSANDRA-2512 from 0.7 Modified: cassandra/branches/cassandra-0.8/ (props changed) cassandra/branches/cassandra-0.8/contrib/ (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/InvalidRequestException.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/NotFoundException.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/SuperColumn.java (props changed) cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/config/CFMetaData.java cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/config/ColumnDefinition.java cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/db/ColumnFamilyStore.java cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java cassandra/branches/cassandra-0.8/test/unit/org/apache/cassandra/db/ColumnFamilyStoreTest.java Propchange: cassandra/branches/cassandra-0.8/ -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 13:29:53 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6:922689-1052356,1052358-1053452,1053454,1053456-1081914,1083000 -/cassandra/branches/cassandra-0.7:1026516-1094195,1094604,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473 +/cassandra/branches/cassandra-0.7:1026516-1094195,1094604,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696 /cassandra/branches/cassandra-0.7.0:1053690-1055654 /cassandra/tags/cassandra-0.7.0-rc3:1051699-1053689 /cassandra/trunk:1090978-1090979 Propchange: cassandra/branches/cassandra-0.8/contrib/ -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 13:29:53 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6/contrib:922689-1052356,1052358-1053452,1053454,1053456-1068009 -/cassandra/branches/cassandra-0.7/contrib:1026516-1094195,1094604,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473 +/cassandra/branches/cassandra-0.7/contrib:1026516-1094195,1094604,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696 /cassandra/branches/cassandra-0.7.0/contrib:1053690-1055654 /cassandra/tags/cassandra-0.7.0-rc3/contrib:1051699-1053689 /cassandra/trunk/contrib:1090978-1090979 Propchange: cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 13:29:53 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:922689-1052356,1052358-1053452,1053454,1053456-1081914,1083000 -/cassandra/branches/cassandra-0.7/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1026516-1094195,1094604,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473 +/cassandra/branches/cassandra-0.7/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1026516-1094195,1094604,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696 /cassandra/branches/cassandra-0.7.0/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1053690-1055654 /cassandra/tags/cassandra-0.7.0-rc3/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1051699-1053689 /cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1090978-1090979 Propchange: cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 13:29:53 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java:922689-1052356,1052358-1053452,1053454,1053456-1081914,1083000 -/cassandra/branches/cassandra-0.7/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java:1026516-1094195,1094604,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473 +/cassandra/branches/cassandra-0.7/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java:1026516-1094195,1094604,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696
svn commit: r1095701 - in /cassandra/trunk: ./ contrib/ interface/thrift/gen-java/org/apache/cassandra/thrift/ src/java/org/apache/cassandra/config/ src/java/org/apache/cassandra/db/ src/java/org/apac
Author: slebresne Date: Thu Apr 21 13:33:13 2011 New Revision: 1095701 URL: http://svn.apache.org/viewvc?rev=1095701view=rev Log: merge CASSANDRA-2512 from 0.8 Modified: cassandra/trunk/ (props changed) cassandra/trunk/contrib/ (props changed) cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java (props changed) cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java (props changed) cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/InvalidRequestException.java (props changed) cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/NotFoundException.java (props changed) cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/SuperColumn.java (props changed) cassandra/trunk/src/java/org/apache/cassandra/config/CFMetaData.java cassandra/trunk/src/java/org/apache/cassandra/config/ColumnDefinition.java cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java cassandra/trunk/test/unit/org/apache/cassandra/db/ColumnFamilyStoreTest.java Propchange: cassandra/trunk/ -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 13:33:13 2011 @@ -1,7 +1,7 @@ /cassandra/branches/cassandra-0.6:922689-1052356,1052358-1053452,1053454,1053456-1081914,1083000 -/cassandra/branches/cassandra-0.7:1026516-1094195,1094604,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473 +/cassandra/branches/cassandra-0.7:1026516-1094195,1094604,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696 /cassandra/branches/cassandra-0.7.0:1053690-1055654 -/cassandra/branches/cassandra-0.8:1090935-1095491 +/cassandra/branches/cassandra-0.8:1090935-1095491,1095699 /cassandra/tags/cassandra-0.7.0-rc3:1051699-1053689 /incubator/cassandra/branches/cassandra-0.3:774578-796573 /incubator/cassandra/branches/cassandra-0.4:810145-834239,834349-834350 Propchange: cassandra/trunk/contrib/ -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 13:33:13 2011 @@ -1,7 +1,7 @@ /cassandra/branches/cassandra-0.6/contrib:922689-1052356,1052358-1053452,1053454,1053456-1068009 -/cassandra/branches/cassandra-0.7/contrib:1026516-1094195,1094481,1094604,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473 +/cassandra/branches/cassandra-0.7/contrib:1026516-1094195,1094481,1094604,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696 /cassandra/branches/cassandra-0.7.0/contrib:1053690-1055654 -/cassandra/branches/cassandra-0.8/contrib:1090935-1095491 +/cassandra/branches/cassandra-0.8/contrib:1090935-1095491,1095699 /cassandra/tags/cassandra-0.7.0-rc3/contrib:1051699-1053689 /incubator/cassandra/branches/cassandra-0.3/contrib:774578-796573 /incubator/cassandra/branches/cassandra-0.4/contrib:810145-810987,810994-834239,834349-834350 Propchange: cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 13:33:13 2011 @@ -1,7 +1,7 @@ /cassandra/branches/cassandra-0.6/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:922689-1052356,1052358-1053452,1053454,1053456-1081914,1083000 -/cassandra/branches/cassandra-0.7/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1026516-1094195,1094481,1094604,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473 +/cassandra/branches/cassandra-0.7/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1026516-1094195,1094481,1094604,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696 /cassandra/branches/cassandra-0.7.0/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1053690-1055654 -/cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1090935-1095491 +/cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1090935-1095491,1095699 /cassandra/tags/cassandra-0.7.0-rc3/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1051699-1053689 /incubator/cassandra/branches/cassandra-0.3/interface/gen-java/org/apache/cassandra/service/Cassandra.java:774578-796573 /incubator/cassandra/branches/cassandra-0.4/interface/gen-java/org/apache/cassandra/service/Cassandra.java:810145-834239,834349-834350 Propchange: cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 13:33:13 2011 @@ -1,7 +1,7 @@
[jira] [Updated] (CASSANDRA-1941) Add distributed test doing reads during MovementTest
[ https://issues.apache.org/jira/browse/CASSANDRA-1941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis updated CASSANDRA-1941: -- Reviewer: mallen (was: jbellis) Add distributed test doing reads during MovementTest Key: CASSANDRA-1941 URL: https://issues.apache.org/jira/browse/CASSANDRA-1941 Project: Cassandra Issue Type: Test Components: Core Reporter: Jonathan Ellis Assignee: Pavel Yaskevich Priority: Minor Fix For: 0.8.1 Attachments: CASSANDRA-1941.patch Original Estimate: 8h Remaining Estimate: 8h Following introduction of the distributed test framework in CASSANDRA-1859, we should extend that to test reads while bootstrap happens (this is a scenario that has had regressions in the past). See test/distributed/README.txt for intro. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2525) CQL: create keyspace does not the replication factor argument and allows invalid sql to pass thru
[ https://issues.apache.org/jira/browse/CASSANDRA-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022763#comment-13022763 ] Jonathan Ellis commented on CASSANDRA-2525: --- opened CASSANDRA-2526 for doc generation CQL: create keyspace does not the replication factor argument and allows invalid sql to pass thru - Key: CASSANDRA-2525 URL: https://issues.apache.org/jira/browse/CASSANDRA-2525 Project: Cassandra Issue Type: Bug Affects Versions: 0.8 beta 1 Environment: Cluster: 3 node Rackspace cluster running Centos 5.5. Build: https://builds.apache.org/hudson/job/Cassandra/859/artifact/cassandra/build/apache-cassandra-2011-04-20_10-01-29-bin.tar.gz Reporter: Cathy Daw Assignee: Jonathan Ellis Priority: Critical Labels: cql Fix For: 0.8.0 Attachments: 2525.txt I ran the following SQL in cqlsh and immediately received a socket closed error. After that point, I couldn't run nodetool, and then got an exception starting up the cluster. Please Note: The following syntax is valid in 0.74 but invalid in 0.8. The 0.8 cassandra-cli errors on the following statement, so the resolution of the bug is to have cqlsh block this incorrect syntax. {code} create keyspace testcli with replication_factor=1 and placement_strategy = 'org.apache.cassandra.locator.SimpleStrategy'; {code} {code} CREATE KEYSPACE testcql with replication_factor = 1 and strategy_class = 'org.apache.cassandra.locator.SimpleStrategy'; {code} {code} ERROR 01:29:26,989 Exception encountered during startup. java.lang.RuntimeException: org.apache.cassandra.config.ConfigurationException: SimpleStrategy requires a replication_factor strategy option. at org.apache.cassandra.db.Table.init(Table.java:278) at org.apache.cassandra.db.Table.open(Table.java:110) at org.apache.cassandra.service.AbstractCassandraDaemon.setup(AbstractCassandraDaemon.java:160) at org.apache.cassandra.service.AbstractCassandraDaemon.activate(AbstractCassandraDaemon.java:314) at org.apache.cassandra.thrift.CassandraDaemon.main(CassandraDaemon.java:80) Caused by: org.apache.cassandra.config.ConfigurationException: SimpleStrategy requires a replication_factor strategy option. at org.apache.cassandra.locator.SimpleStrategy.validateOptions(SimpleStrategy.java:79) at org.apache.cassandra.locator.AbstractReplicationStrategy.createReplicationStrategy(AbstractReplicationStrategy.java:262) at org.apache.cassandra.db.Table.createReplicationStrategy(Table.java:328) at org.apache.cassandra.db.Table.init(Table.java:274) ... 4 more Exception encountered during startup. java.lang.RuntimeException: org.apache.cassandra.config.ConfigurationException: SimpleStrategy requires a replication_factor strategy option. at org.apache.cassandra.db.Table.init(Table.java:278) at org.apache.cassandra.db.Table.open(Table.java:110) at org.apache.cassandra.service.AbstractCassandraDaemon.setup(AbstractCassandraDaemon.java:160) at org.apache.cassandra.service.AbstractCassandraDaemon.activate(AbstractCassandraDaemon.java:314) at org.apache.cassandra.thrift.CassandraDaemon.main(CassandraDaemon.java:80) Caused by: org.apache.cassandra.config.ConfigurationException: SimpleStrategy requires a replication_factor strategy option. at org.apache.cassandra.locator.SimpleStrategy.validateOptions(SimpleStrategy.java:79) at org.apache.cassandra.locator.AbstractReplicationStrategy.createReplicationStrategy(AbstractReplicationStrategy.java:262) at org.apache.cassandra.db.Table.createReplicationStrategy(Table.java:328) at org.apache.cassandra.db.Table.init(Table.java:274) ... 4 more {code} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
svn commit: r1095747 - in /cassandra/branches/cassandra-0.7: CHANGES.txt src/java/org/apache/cassandra/locator/AbstractReplicationStrategy.java src/java/org/apache/cassandra/locator/NetworkTopologyStr
Author: jbellis Date: Thu Apr 21 15:18:30 2011 New Revision: 1095747 URL: http://svn.apache.org/viewvc?rev=1095747view=rev Log: support LOCAL_QUORUM, EACH_QUORUM CLs outside of NTS patch by jbellis; reviewed by slebresne for CASSANDRA-2516 Modified: cassandra/branches/cassandra-0.7/CHANGES.txt cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/locator/AbstractReplicationStrategy.java cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java Modified: cassandra/branches/cassandra-0.7/CHANGES.txt URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/CHANGES.txt?rev=1095747r1=1095746r2=1095747view=diff == --- cassandra/branches/cassandra-0.7/CHANGES.txt (original) +++ cassandra/branches/cassandra-0.7/CHANGES.txt Thu Apr 21 15:18:30 2011 @@ -36,6 +36,7 @@ (CASSANDRA-2519) * fixes for verifying destination availability under hinted conditions so UE can be thrown intead of timing out (CASSANDRA-2514) + * support LOCAL_QUORUM, EACH_QUORUM CLs outside of NTS (CASSANDRA-2516) 0.7.4 Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/locator/AbstractReplicationStrategy.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/locator/AbstractReplicationStrategy.java?rev=1095747r1=1095746r2=1095747view=diff == --- cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/locator/AbstractReplicationStrategy.java (original) +++ cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/locator/AbstractReplicationStrategy.java Thu Apr 21 15:18:30 2011 @@ -122,9 +122,18 @@ public abstract class AbstractReplicatio public IWriteResponseHandler getWriteResponseHandler(CollectionInetAddress writeEndpoints, MultimapInetAddress, InetAddress hintedEndpoints, - ConsistencyLevel consistencyLevel) + ConsistencyLevel consistency_level) { -return WriteResponseHandler.create(writeEndpoints, hintedEndpoints, consistencyLevel, table); +if (consistency_level == ConsistencyLevel.LOCAL_QUORUM) +{ +// block for in this context will be localnodes block. +return DatacenterWriteResponseHandler.create(writeEndpoints, hintedEndpoints, consistency_level, table); +} +else if (consistency_level == ConsistencyLevel.EACH_QUORUM) +{ +return DatacenterSyncWriteResponseHandler.create(writeEndpoints, hintedEndpoints, consistency_level, table); +} +return WriteResponseHandler.create(writeEndpoints, hintedEndpoints, consistency_level, table); } public int getReplicationFactor() Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java?rev=1095747r1=1095746r2=1095747view=diff == --- cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java (original) +++ cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java Thu Apr 21 15:18:30 2011 @@ -143,25 +143,4 @@ public class NetworkTopologyStrategy ext { return datacenters.keySet(); } - -/** - * This method will generate the QRH object and returns. If the Consistency - * level is LOCAL_QUORUM then it will return a DCQRH with a map of local rep - * factor alone. If the consistency level is EACH_QUORUM then it will - * return a DCQRH with a map of all the DC rep factor. - */ -@Override -public IWriteResponseHandler getWriteResponseHandler(CollectionInetAddress writeEndpoints, MultimapInetAddress, InetAddress hintedEndpoints, ConsistencyLevel consistency_level) -{ -if (consistency_level == ConsistencyLevel.LOCAL_QUORUM) -{ -// block for in this context will be localnodes block. -return DatacenterWriteResponseHandler.create(writeEndpoints, hintedEndpoints, consistency_level, table); -} -else if (consistency_level == ConsistencyLevel.EACH_QUORUM) -{ -return DatacenterSyncWriteResponseHandler.create(writeEndpoints, hintedEndpoints, consistency_level, table); -} -return super.getWriteResponseHandler(writeEndpoints, hintedEndpoints, consistency_level); -} }
svn commit: r1095748 - in /cassandra/branches/cassandra-0.8: CHANGES.txt src/java/org/apache/cassandra/locator/AbstractReplicationStrategy.java src/java/org/apache/cassandra/locator/NetworkTopologyStr
Author: jbellis Date: Thu Apr 21 15:19:51 2011 New Revision: 1095748 URL: http://svn.apache.org/viewvc?rev=1095748view=rev Log: merge from 0.7 Modified: cassandra/branches/cassandra-0.8/CHANGES.txt cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/locator/AbstractReplicationStrategy.java cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java Modified: cassandra/branches/cassandra-0.8/CHANGES.txt URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/CHANGES.txt?rev=1095748r1=1095747r2=1095748view=diff == --- cassandra/branches/cassandra-0.8/CHANGES.txt (original) +++ cassandra/branches/cassandra-0.8/CHANGES.txt Thu Apr 21 15:19:51 2011 @@ -61,6 +61,7 @@ (CASSANDRA-2519) * fixes for verifying destination availability under hinted conditions so UE can be thrown intead of timing out (CASSANDRA-2514) + * support LOCAL_QUORUM, EACH_QUORUM CLs outside of NTS (CASSANDRA-2516) 0.7.4 Modified: cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/locator/AbstractReplicationStrategy.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/locator/AbstractReplicationStrategy.java?rev=1095748r1=1095747r2=1095748view=diff == --- cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/locator/AbstractReplicationStrategy.java (original) +++ cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/locator/AbstractReplicationStrategy.java Thu Apr 21 15:19:51 2011 @@ -121,9 +121,18 @@ public abstract class AbstractReplicatio public IWriteResponseHandler getWriteResponseHandler(CollectionInetAddress writeEndpoints, MultimapInetAddress, InetAddress hintedEndpoints, - ConsistencyLevel consistencyLevel) + ConsistencyLevel consistency_level) { -return WriteResponseHandler.create(writeEndpoints, hintedEndpoints, consistencyLevel, table); +if (consistency_level == ConsistencyLevel.LOCAL_QUORUM) +{ +// block for in this context will be localnodes block. +return DatacenterWriteResponseHandler.create(writeEndpoints, hintedEndpoints, consistency_level, table); +} +else if (consistency_level == ConsistencyLevel.EACH_QUORUM) +{ +return DatacenterSyncWriteResponseHandler.create(writeEndpoints, hintedEndpoints, consistency_level, table); +} +return WriteResponseHandler.create(writeEndpoints, hintedEndpoints, consistency_level, table); } /** Modified: cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java?rev=1095748r1=1095747r2=1095748view=diff == --- cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java (original) +++ cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java Thu Apr 21 15:19:51 2011 @@ -144,27 +144,6 @@ public class NetworkTopologyStrategy ext return datacenters.keySet(); } -/** - * This method will generate the QRH object and returns. If the Consistency - * level is LOCAL_QUORUM then it will return a DCQRH with a map of local rep - * factor alone. If the consistency level is EACH_QUORUM then it will - * return a DCQRH with a map of all the DC rep factor. - */ -@Override -public IWriteResponseHandler getWriteResponseHandler(CollectionInetAddress writeEndpoints, MultimapInetAddress, InetAddress hintedEndpoints, ConsistencyLevel consistency_level) -{ -if (consistency_level == ConsistencyLevel.LOCAL_QUORUM) -{ -// block for in this context will be localnodes block. -return DatacenterWriteResponseHandler.create(writeEndpoints, hintedEndpoints, consistency_level, table); -} -else if (consistency_level == ConsistencyLevel.EACH_QUORUM) -{ -return DatacenterSyncWriteResponseHandler.create(writeEndpoints, hintedEndpoints, consistency_level, table); -} -return super.getWriteResponseHandler(writeEndpoints, hintedEndpoints, consistency_level); -} - public void validateOptions() throws ConfigurationException { for (EntryString,String e : this.configOptions.entrySet())
svn commit: r1095755 - in /cassandra/branches/cassandra-0.8: ./ contrib/ interface/thrift/gen-java/org/apache/cassandra/thrift/
Author: jbellis Date: Thu Apr 21 15:46:56 2011 New Revision: 1095755 URL: http://svn.apache.org/viewvc?rev=1095755view=rev Log: merge from 0.7 Modified: cassandra/branches/cassandra-0.8/ (props changed) cassandra/branches/cassandra-0.8/contrib/ (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/InvalidRequestException.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/NotFoundException.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/SuperColumn.java (props changed) Propchange: cassandra/branches/cassandra-0.8/ -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 15:46:56 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6:922689-1052356,1052358-1053452,1053454,1053456-1081914,1083000 -/cassandra/branches/cassandra-0.7:1026516-1094195,1094604,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696 +/cassandra/branches/cassandra-0.7:1026516-1094195,1094604,1094611,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747 /cassandra/branches/cassandra-0.7.0:1053690-1055654 /cassandra/tags/cassandra-0.7.0-rc3:1051699-1053689 /cassandra/trunk:1090978-1090979 Propchange: cassandra/branches/cassandra-0.8/contrib/ -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 15:46:56 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6/contrib:922689-1052356,1052358-1053452,1053454,1053456-1068009 -/cassandra/branches/cassandra-0.7/contrib:1026516-1094195,1094604,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696 +/cassandra/branches/cassandra-0.7/contrib:1026516-1094195,1094604,1094611,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747 /cassandra/branches/cassandra-0.7.0/contrib:1053690-1055654 /cassandra/tags/cassandra-0.7.0-rc3/contrib:1051699-1053689 /cassandra/trunk/contrib:1090978-1090979 Propchange: cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 15:46:56 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:922689-1052356,1052358-1053452,1053454,1053456-1081914,1083000 -/cassandra/branches/cassandra-0.7/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1026516-1094195,1094604,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696 +/cassandra/branches/cassandra-0.7/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1026516-1094195,1094604,1094611,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747 /cassandra/branches/cassandra-0.7.0/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1053690-1055654 /cassandra/tags/cassandra-0.7.0-rc3/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1051699-1053689 /cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1090978-1090979 Propchange: cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 15:46:56 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java:922689-1052356,1052358-1053452,1053454,1053456-1081914,1083000 -/cassandra/branches/cassandra-0.7/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java:1026516-1094195,1094604,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696 +/cassandra/branches/cassandra-0.7/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java:1026516-1094195,1094604,1094611,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747 /cassandra/branches/cassandra-0.7.0/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java:1053690-1055654 /cassandra/tags/cassandra-0.7.0-rc3/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java:1051699-1053689 /cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java:1090978-1090979 Propchange: cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/InvalidRequestException.java
[jira] [Created] (CASSANDRA-2527) Add ability to snapshot data as input to hadoop jobs
Add ability to snapshot data as input to hadoop jobs Key: CASSANDRA-2527 URL: https://issues.apache.org/jira/browse/CASSANDRA-2527 Project: Cassandra Issue Type: Improvement Reporter: Jeremy Hanna It is desirable to have immutable inputs to hadoop jobs for the duration of the job. That way re-execution of individual tasks do not alter the output. One way to accomplish this would be to snapshot the data that is used as input to a job. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
svn commit: r1095765 - in /cassandra/branches/cassandra-0.8: ./ contrib/ interface/thrift/gen-java/org/apache/cassandra/thrift/ src/java/org/apache/cassandra/db/ src/java/org/apache/cassandra/streamin
Author: jbellis Date: Thu Apr 21 16:13:11 2011 New Revision: 1095765 URL: http://svn.apache.org/viewvc?rev=1095765view=rev Log: merge from 0.7 Modified: cassandra/branches/cassandra-0.8/ (props changed) cassandra/branches/cassandra-0.8/CHANGES.txt cassandra/branches/cassandra-0.8/contrib/ (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/InvalidRequestException.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/NotFoundException.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/SuperColumn.java (props changed) cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/db/ColumnFamilyStore.java cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/streaming/StreamIn.java cassandra/branches/cassandra-0.8/test/unit/org/apache/cassandra/db/DefsTest.java cassandra/branches/cassandra-0.8/test/unit/org/apache/cassandra/streaming/BootstrapTest.java cassandra/branches/cassandra-0.8/test/unit/org/apache/cassandra/streaming/SerializationsTest.java Propchange: cassandra/branches/cassandra-0.8/ -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 16:13:11 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6:922689-1052356,1052358-1053452,1053454,1053456-1081914,1083000 -/cassandra/branches/cassandra-0.7:1026516-1094195,1094604,1094611,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747 +/cassandra/branches/cassandra-0.7:1026516-1094195,1094604,1094611,1094647,1094780,1094789,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747 /cassandra/branches/cassandra-0.7.0:1053690-1055654 /cassandra/tags/cassandra-0.7.0-rc3:1051699-1053689 /cassandra/trunk:1090978-1090979 Modified: cassandra/branches/cassandra-0.8/CHANGES.txt URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/CHANGES.txt?rev=1095765r1=1095764r2=1095765view=diff == --- cassandra/branches/cassandra-0.8/CHANGES.txt (original) +++ cassandra/branches/cassandra-0.8/CHANGES.txt Thu Apr 21 16:13:11 2011 @@ -57,11 +57,15 @@ * use 64KB flush buffer instead of in_memory_compaction_limit (CASSANDRA-2463) * fix duplicate results from CFS.scan (CASSANDRA-2406) * avoid caching token-only decoratedkeys (CASSANDRA-2416) + .working * count a row deletion as one operation towards memtable threshold (CASSANDRA-2519) * fixes for verifying destination availability under hinted conditions so UE can be thrown intead of timing out (CASSANDRA-2514) * support LOCAL_QUORUM, EACH_QUORUM CLs outside of NTS (CASSANDRA-2516) +=== + * preserve version when streaming data from old sstables (CASSANDRA-2283) + .merge-right.r1094789 0.7.4 Propchange: cassandra/branches/cassandra-0.8/contrib/ -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 16:13:11 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6/contrib:922689-1052356,1052358-1053452,1053454,1053456-1068009 -/cassandra/branches/cassandra-0.7/contrib:1026516-1094195,1094604,1094611,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747 +/cassandra/branches/cassandra-0.7/contrib:1026516-1094195,1094604,1094611,1094647,1094780,1094789,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747 /cassandra/branches/cassandra-0.7.0/contrib:1053690-1055654 /cassandra/tags/cassandra-0.7.0-rc3/contrib:1051699-1053689 /cassandra/trunk/contrib:1090978-1090979 Propchange: cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 16:13:11 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:922689-1052356,1052358-1053452,1053454,1053456-1081914,1083000 -/cassandra/branches/cassandra-0.7/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1026516-1094195,1094604,1094611,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747 +/cassandra/branches/cassandra-0.7/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1026516-1094195,1094604,1094611,1094647,1094780,1094789,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747
svn commit: r1095766 - in /cassandra/branches/cassandra-0.8: ./ contrib/ interface/thrift/gen-java/org/apache/cassandra/thrift/ src/java/org/apache/cassandra/gms/
Author: jbellis Date: Thu Apr 21 16:13:45 2011 New Revision: 1095766 URL: http://svn.apache.org/viewvc?rev=1095766view=rev Log: merge from 0.7 Modified: cassandra/branches/cassandra-0.8/ (props changed) cassandra/branches/cassandra-0.8/contrib/ (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/InvalidRequestException.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/NotFoundException.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/SuperColumn.java (props changed) cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/gms/Gossiper.java Propchange: cassandra/branches/cassandra-0.8/ -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 16:13:45 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6:922689-1052356,1052358-1053452,1053454,1053456-1081914,1083000 -/cassandra/branches/cassandra-0.7:1026516-1094195,1094604,1094611,1094647,1094780,1094789,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747 +/cassandra/branches/cassandra-0.7:1026516-1094195,1094604,1094611,1094647,1094694,1094780,1094789,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747 /cassandra/branches/cassandra-0.7.0:1053690-1055654 /cassandra/tags/cassandra-0.7.0-rc3:1051699-1053689 /cassandra/trunk:1090978-1090979 Propchange: cassandra/branches/cassandra-0.8/contrib/ -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 16:13:45 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6/contrib:922689-1052356,1052358-1053452,1053454,1053456-1068009 -/cassandra/branches/cassandra-0.7/contrib:1026516-1094195,1094604,1094611,1094647,1094780,1094789,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747 +/cassandra/branches/cassandra-0.7/contrib:1026516-1094195,1094604,1094611,1094647,1094694,1094780,1094789,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747 /cassandra/branches/cassandra-0.7.0/contrib:1053690-1055654 /cassandra/tags/cassandra-0.7.0-rc3/contrib:1051699-1053689 /cassandra/trunk/contrib:1090978-1090979 Propchange: cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 16:13:45 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:922689-1052356,1052358-1053452,1053454,1053456-1081914,1083000 -/cassandra/branches/cassandra-0.7/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1026516-1094195,1094604,1094611,1094647,1094780,1094789,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747 +/cassandra/branches/cassandra-0.7/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1026516-1094195,1094604,1094611,1094647,1094694,1094780,1094789,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747 /cassandra/branches/cassandra-0.7.0/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1053690-1055654 /cassandra/tags/cassandra-0.7.0-rc3/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1051699-1053689 /cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1090978-1090979 Propchange: cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 16:13:45 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java:922689-1052356,1052358-1053452,1053454,1053456-1081914,1083000 -/cassandra/branches/cassandra-0.7/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java:1026516-1094195,1094604,1094611,1094647,1094780,1094789,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747 +/cassandra/branches/cassandra-0.7/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java:1026516-1094195,1094604,1094611,1094647,1094694,1094780,1094789,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747 /cassandra/branches/cassandra-0.7.0/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java:1053690-1055654
svn commit: r1095767 - in /cassandra/branches/cassandra-0.8: ./ contrib/ interface/thrift/gen-java/org/apache/cassandra/thrift/ src/java/org/apache/cassandra/cli/ src/java/org/apache/cassandra/utils/
Author: jbellis Date: Thu Apr 21 16:17:08 2011 New Revision: 1095767 URL: http://svn.apache.org/viewvc?rev=1095767view=rev Log: merge from 0.7 Modified: cassandra/branches/cassandra-0.8/ (props changed) cassandra/branches/cassandra-0.8/CHANGES.txt cassandra/branches/cassandra-0.8/contrib/ (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/InvalidRequestException.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/NotFoundException.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/SuperColumn.java (props changed) cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/cli/CliUtils.java cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/utils/FBUtilities.java cassandra/branches/cassandra-0.8/test/unit/org/apache/cassandra/cli/CliTest.java cassandra/branches/cassandra-0.8/test/unit/org/apache/cassandra/service/AntiEntropyServiceTestAbstract.java Propchange: cassandra/branches/cassandra-0.8/ -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 16:17:08 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6:922689-1052356,1052358-1053452,1053454,1053456-1081914,1083000 -/cassandra/branches/cassandra-0.7:1026516-1094195,1094604,1094611,1094647,1094694,1094780,1094789,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747 +/cassandra/branches/cassandra-0.7:1026516-1095250,1095438,1095473,1095696,1095747 /cassandra/branches/cassandra-0.7.0:1053690-1055654 /cassandra/tags/cassandra-0.7.0-rc3:1051699-1053689 /cassandra/trunk:1090978-1090979 Modified: cassandra/branches/cassandra-0.8/CHANGES.txt URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/CHANGES.txt?rev=1095767r1=1095766r2=1095767view=diff == --- cassandra/branches/cassandra-0.8/CHANGES.txt (original) +++ cassandra/branches/cassandra-0.8/CHANGES.txt Thu Apr 21 16:17:08 2011 @@ -57,15 +57,13 @@ * use 64KB flush buffer instead of in_memory_compaction_limit (CASSANDRA-2463) * fix duplicate results from CFS.scan (CASSANDRA-2406) * avoid caching token-only decoratedkeys (CASSANDRA-2416) - .working * count a row deletion as one operation towards memtable threshold (CASSANDRA-2519) * fixes for verifying destination availability under hinted conditions so UE can be thrown intead of timing out (CASSANDRA-2514) * support LOCAL_QUORUM, EACH_QUORUM CLs outside of NTS (CASSANDRA-2516) -=== * preserve version when streaming data from old sstables (CASSANDRA-2283) - .merge-right.r1094789 + * fix backslash substitutions in CLI (CASSANDRA-2492) 0.7.4 Propchange: cassandra/branches/cassandra-0.8/contrib/ -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 16:17:08 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6/contrib:922689-1052356,1052358-1053452,1053454,1053456-1068009 -/cassandra/branches/cassandra-0.7/contrib:1026516-1094195,1094604,1094611,1094647,1094694,1094780,1094789,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747 +/cassandra/branches/cassandra-0.7/contrib:1026516-1095250,1095438,1095473,1095696,1095747 /cassandra/branches/cassandra-0.7.0/contrib:1053690-1055654 /cassandra/tags/cassandra-0.7.0-rc3/contrib:1051699-1053689 /cassandra/trunk/contrib:1090978-1090979 Propchange: cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 16:17:08 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:922689-1052356,1052358-1053452,1053454,1053456-1081914,1083000 -/cassandra/branches/cassandra-0.7/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1026516-1094195,1094604,1094611,1094647,1094694,1094780,1094789,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696,1095747 +/cassandra/branches/cassandra-0.7/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1026516-1095250,1095438,1095473,1095696,1095747 /cassandra/branches/cassandra-0.7.0/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1053690-1055654 /cassandra/tags/cassandra-0.7.0-rc3/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1051699-1053689
svn commit: r1095769 - in /cassandra/branches/cassandra-0.8: ./ contrib/ interface/thrift/gen-java/org/apache/cassandra/thrift/
Author: jbellis Date: Thu Apr 21 16:19:20 2011 New Revision: 1095769 URL: http://svn.apache.org/viewvc?rev=1095769view=rev Log: merge from 0.7 Modified: cassandra/branches/cassandra-0.8/ (props changed) cassandra/branches/cassandra-0.8/CHANGES.txt cassandra/branches/cassandra-0.8/contrib/ (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/InvalidRequestException.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/NotFoundException.java (props changed) cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/SuperColumn.java (props changed) Propchange: cassandra/branches/cassandra-0.8/ -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 16:19:20 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6:922689-1052356,1052358-1053452,1053454,1053456-1081914,1083000 -/cassandra/branches/cassandra-0.7:1026516-1095250,1095438,1095473,1095696,1095747 +/cassandra/branches/cassandra-0.7:1026516-1095767 /cassandra/branches/cassandra-0.7.0:1053690-1055654 /cassandra/tags/cassandra-0.7.0-rc3:1051699-1053689 /cassandra/trunk:1090978-1090979 Modified: cassandra/branches/cassandra-0.8/CHANGES.txt URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/CHANGES.txt?rev=1095769r1=1095768r2=1095769view=diff == --- cassandra/branches/cassandra-0.8/CHANGES.txt (original) +++ cassandra/branches/cassandra-0.8/CHANGES.txt Thu Apr 21 16:19:20 2011 @@ -57,13 +57,13 @@ * use 64KB flush buffer instead of in_memory_compaction_limit (CASSANDRA-2463) * fix duplicate results from CFS.scan (CASSANDRA-2406) * avoid caching token-only decoratedkeys (CASSANDRA-2416) + * preserve version when streaming data from old sstables (CASSANDRA-2283) + * fix backslash substitutions in CLI (CASSANDRA-2492) * count a row deletion as one operation towards memtable threshold (CASSANDRA-2519) * fixes for verifying destination availability under hinted conditions so UE can be thrown intead of timing out (CASSANDRA-2514) * support LOCAL_QUORUM, EACH_QUORUM CLs outside of NTS (CASSANDRA-2516) - * preserve version when streaming data from old sstables (CASSANDRA-2283) - * fix backslash substitutions in CLI (CASSANDRA-2492) 0.7.4 Propchange: cassandra/branches/cassandra-0.8/contrib/ -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 16:19:20 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6/contrib:922689-1052356,1052358-1053452,1053454,1053456-1068009 -/cassandra/branches/cassandra-0.7/contrib:1026516-1095250,1095438,1095473,1095696,1095747 +/cassandra/branches/cassandra-0.7/contrib:1026516-1095767 /cassandra/branches/cassandra-0.7.0/contrib:1053690-1055654 /cassandra/tags/cassandra-0.7.0-rc3/contrib:1051699-1053689 /cassandra/trunk/contrib:1090978-1090979 Propchange: cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 16:19:20 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:922689-1052356,1052358-1053452,1053454,1053456-1081914,1083000 -/cassandra/branches/cassandra-0.7/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1026516-1095250,1095438,1095473,1095696,1095747 +/cassandra/branches/cassandra-0.7/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1026516-1095767 /cassandra/branches/cassandra-0.7.0/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1053690-1055654 /cassandra/tags/cassandra-0.7.0-rc3/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1051699-1053689 /cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:1090978-1090979 Propchange: cassandra/branches/cassandra-0.8/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 16:19:20 2011 @@ -1,5 +1,5 @@ /cassandra/branches/cassandra-0.6/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java:922689-1052356,1052358-1053452,1053454,1053456-1081914,1083000
svn commit: r1095770 - in /cassandra/trunk: ./ contrib/ interface/thrift/gen-java/org/apache/cassandra/thrift/ src/java/org/apache/cassandra/cli/ src/java/org/apache/cassandra/db/ src/java/org/apache/
Author: jbellis Date: Thu Apr 21 16:20:47 2011 New Revision: 1095770 URL: http://svn.apache.org/viewvc?rev=1095770view=rev Log: merge from 0.8 Modified: cassandra/trunk/ (props changed) cassandra/trunk/CHANGES.txt cassandra/trunk/contrib/ (props changed) cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java (props changed) cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java (props changed) cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/InvalidRequestException.java (props changed) cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/NotFoundException.java (props changed) cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/SuperColumn.java (props changed) cassandra/trunk/src/java/org/apache/cassandra/cli/CliUtils.java cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java cassandra/trunk/src/java/org/apache/cassandra/gms/Gossiper.java cassandra/trunk/src/java/org/apache/cassandra/locator/AbstractReplicationStrategy.java cassandra/trunk/src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java cassandra/trunk/src/java/org/apache/cassandra/streaming/StreamIn.java cassandra/trunk/src/java/org/apache/cassandra/utils/FBUtilities.java cassandra/trunk/test/unit/org/apache/cassandra/cli/CliTest.java cassandra/trunk/test/unit/org/apache/cassandra/db/DefsTest.java cassandra/trunk/test/unit/org/apache/cassandra/service/AntiEntropyServiceTestAbstract.java cassandra/trunk/test/unit/org/apache/cassandra/streaming/BootstrapTest.java cassandra/trunk/test/unit/org/apache/cassandra/streaming/SerializationsTest.java Propchange: cassandra/trunk/ -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 16:20:47 2011 @@ -1,7 +1,7 @@ /cassandra/branches/cassandra-0.6:922689-1052356,1052358-1053452,1053454,1053456-1081914,1083000 -/cassandra/branches/cassandra-0.7:1026516-1094195,1094604,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696 +/cassandra/branches/cassandra-0.7:1026516-1095767 /cassandra/branches/cassandra-0.7.0:1053690-1055654 -/cassandra/branches/cassandra-0.8:1090935-1095491,1095699 +/cassandra/branches/cassandra-0.8:1090935-1095769 /cassandra/tags/cassandra-0.7.0-rc3:1051699-1053689 /incubator/cassandra/branches/cassandra-0.3:774578-796573 /incubator/cassandra/branches/cassandra-0.4:810145-834239,834349-834350 Modified: cassandra/trunk/CHANGES.txt URL: http://svn.apache.org/viewvc/cassandra/trunk/CHANGES.txt?rev=1095770r1=1095769r2=1095770view=diff == --- cassandra/trunk/CHANGES.txt (original) +++ cassandra/trunk/CHANGES.txt Thu Apr 21 16:20:47 2011 @@ -57,10 +57,13 @@ * use 64KB flush buffer instead of in_memory_compaction_limit (CASSANDRA-2463) * fix duplicate results from CFS.scan (CASSANDRA-2406) * avoid caching token-only decoratedkeys (CASSANDRA-2416) + * preserve version when streaming data from old sstables (CASSANDRA-2283) + * fix backslash substitutions in CLI (CASSANDRA-2492) * count a row deletion as one operation towards memtable threshold (CASSANDRA-2519) * fixes for verifying destination availability under hinted conditions so UE can be thrown intead of timing out (CASSANDRA-2514) + * support LOCAL_QUORUM, EACH_QUORUM CLs outside of NTS (CASSANDRA-2516) 0.7.4 Propchange: cassandra/trunk/contrib/ -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 16:20:47 2011 @@ -1,7 +1,7 @@ /cassandra/branches/cassandra-0.6/contrib:922689-1052356,1052358-1053452,1053454,1053456-1068009 -/cassandra/branches/cassandra-0.7/contrib:1026516-1094195,1094481,1094604,1094647,1094796,1094809,1094818,1094831,1095250,1095438,1095473,1095696 +/cassandra/branches/cassandra-0.7/contrib:1026516-1095767 /cassandra/branches/cassandra-0.7.0/contrib:1053690-1055654 -/cassandra/branches/cassandra-0.8/contrib:1090935-1095491,1095699 +/cassandra/branches/cassandra-0.8/contrib:1090935-1095769 /cassandra/tags/cassandra-0.7.0-rc3/contrib:1051699-1053689 /incubator/cassandra/branches/cassandra-0.3/contrib:774578-796573 /incubator/cassandra/branches/cassandra-0.4/contrib:810145-810987,810994-834239,834349-834350 Propchange: cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java -- --- svn:mergeinfo (original) +++ svn:mergeinfo Thu Apr 21 16:20:47 2011 @@ -1,7 +1,7 @@ /cassandra/branches/cassandra-0.6/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java:922689-1052356,1052358-1053452,1053454,1053456-1081914,1083000
[jira] [Commented] (CASSANDRA-2526) Add ant support to generate CQL documentation from textile source
[ https://issues.apache.org/jira/browse/CASSANDRA-2526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022847#comment-13022847 ] Nate McCall commented on CASSANDRA-2526: Looks like some folks were having the same initial frustrations I did. The fusesource folks have re-packaged this in github and gotten it included in maven central: http://repo2.maven.org/maven2/org/fusesource/wikitext/ GH project: https://github.com/fusesource/wikitext Add ant support to generate CQL documentation from textile source - Key: CASSANDRA-2526 URL: https://issues.apache.org/jira/browse/CASSANDRA-2526 Project: Cassandra Issue Type: Task Affects Versions: 0.8 beta 1 Reporter: Jonathan Ellis Assignee: Nate McCall Priority: Minor Fix For: 0.8.0 possibly useful links: - http://help.eclipse.org/helios/topic/org.eclipse.mylyn.wikitext.help.ui/help/Markup-Conversion.html#ConversionusingAntbuildscripts - http://www.mvnbrowser.com/artifact-details.html?groupId=org.eclipse.mylyn.wikitextartifactId=wikitext -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Created] (CASSANDRA-2528) NPE from PrecompactedRow
NPE from PrecompactedRow Key: CASSANDRA-2528 URL: https://issues.apache.org/jira/browse/CASSANDRA-2528 Project: Cassandra Issue Type: Bug Reporter: Jackson Chung received a NPE from trunk (0.8) on PrecompactedRow: ERROR [CompactionExecutor:2] 2011-04-21 17:21:31,610 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[CompactionExecutor:2,1,main] java.lang.NullPointerException at org.apache.cassandra.io.PrecompactedRow.init(PrecompactedRow.java:86) at org.apache.cassandra.io.CompactionIterator.getCompactedRow(CompactionIterator.java:167) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:124) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:44) at org.apache.cassandra.utils.ReducingIterator.computeNext(ReducingIterator.java:74) at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:140) at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:135) at org.apache.commons.collections.iterators.FilterIterator.setNextObject(FilterIterator.java:183) at org.apache.commons.collections.iterators.FilterIterator.hasNext(FilterIterator.java:94) at org.apache.cassandra.db.CompactionManager.doCompaction(CompactionManager.java:553) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:146) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:112) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) at java.util.concurrent.FutureTask.run(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:662) size of data in /var/lib/cassandra is 11G on this, but there is also report that 1.7G also see the same. data was previously populated from 0.7.4 cassandra added debug logging, not sure how much this help (this is logged before the exception.) INFO [CompactionExecutor:2] 2011-04-21 17:21:31,588 CompactionManager.java (line 534) Compacting Major: [SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-10-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-7-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-6-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-8-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-9-Data.db')] DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-10-Data.db : 256 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-7-Data.db : 512 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-6-Data.db : 768 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,589 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-8-Data.db : 1024 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,589 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-9-Data.db : 1280 INFO [CompactionExecutor:2] 2011-04-21 17:21:31,609 CompactionIterator.java (line 185) Major@1181554512(cfs, inode.path, 523/10895) now compacting at 16777 bytes/ms. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2528) NPE from PrecompactedRow
[ https://issues.apache.org/jira/browse/CASSANDRA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022863#comment-13022863 ] Patricio Echague commented on CASSANDRA-2528: - I'm seeing the same stacktrace when writing 1GB of data. NPE from PrecompactedRow Key: CASSANDRA-2528 URL: https://issues.apache.org/jira/browse/CASSANDRA-2528 Project: Cassandra Issue Type: Bug Reporter: Jackson Chung received a NPE from trunk (0.8) on PrecompactedRow: ERROR [CompactionExecutor:2] 2011-04-21 17:21:31,610 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[CompactionExecutor:2,1,main] java.lang.NullPointerException at org.apache.cassandra.io.PrecompactedRow.init(PrecompactedRow.java:86) at org.apache.cassandra.io.CompactionIterator.getCompactedRow(CompactionIterator.java:167) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:124) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:44) at org.apache.cassandra.utils.ReducingIterator.computeNext(ReducingIterator.java:74) at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:140) at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:135) at org.apache.commons.collections.iterators.FilterIterator.setNextObject(FilterIterator.java:183) at org.apache.commons.collections.iterators.FilterIterator.hasNext(FilterIterator.java:94) at org.apache.cassandra.db.CompactionManager.doCompaction(CompactionManager.java:553) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:146) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:112) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) at java.util.concurrent.FutureTask.run(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:662) size of data in /var/lib/cassandra is 11G on this, but there is also report that 1.7G also see the same. data was previously populated from 0.7.4 cassandra added debug logging, not sure how much this help (this is logged before the exception.) INFO [CompactionExecutor:2] 2011-04-21 17:21:31,588 CompactionManager.java (line 534) Compacting Major: [SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-10-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-7-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-6-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-8-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-9-Data.db')] DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-10-Data.db : 256 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-7-Data.db : 512 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-6-Data.db : 768 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,589 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-8-Data.db : 1024 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,589 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-9-Data.db : 1280 INFO [CompactionExecutor:2] 2011-04-21 17:21:31,609 CompactionIterator.java (line 185) Major@1181554512(cfs, inode.path, 523/10895) now compacting at 16777 bytes/ms. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2516) Allow LOCAL_QUORUM, EACH_QUORUM CLs to work w/ any Strategy class
[ https://issues.apache.org/jira/browse/CASSANDRA-2516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022869#comment-13022869 ] Hudson commented on CASSANDRA-2516: --- Integrated in Cassandra-0.7 #452 (See [https://builds.apache.org/hudson/job/Cassandra-0.7/452/]) support LOCAL_QUORUM, EACH_QUORUM CLs outside of NTS patch by jbellis; reviewed by slebresne for CASSANDRA-2516 Allow LOCAL_QUORUM, EACH_QUORUM CLs to work w/ any Strategy class - Key: CASSANDRA-2516 URL: https://issues.apache.org/jira/browse/CASSANDRA-2516 Project: Cassandra Issue Type: Bug Components: Core Affects Versions: 0.7.0 Reporter: Jonathan Ellis Assignee: Jonathan Ellis Priority: Minor Fix For: 0.7.5 Attachments: 2516.txt -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2512) Updating a column's validation class from AsciiType to UTF8Type does not actually work
[ https://issues.apache.org/jira/browse/CASSANDRA-2512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022870#comment-13022870 ] Hudson commented on CASSANDRA-2512: --- Integrated in Cassandra-0.7 #452 (See [https://builds.apache.org/hudson/job/Cassandra-0.7/452/]) Fix updating column metadata validation class patch by jbellis; reviewed by slebresne for CASSANDRA-2512 Updating a column's validation class from AsciiType to UTF8Type does not actually work -- Key: CASSANDRA-2512 URL: https://issues.apache.org/jira/browse/CASSANDRA-2512 Project: Cassandra Issue Type: Bug Affects Versions: 0.7.0 Environment: Single Node on MacOSX, installed from 0.7.4 binary .tar ball. Reporter: Cathy Daw Assignee: Jonathan Ellis Fix For: 0.7.5 Attachments: 2512.txt Please note this is reproducible on both Cassandra 0.74 and the April 18th trunk build. *Reproduction Steps* {code} create column family users with comparator = UTF8Type and column_metadata = [{column_name: password, validation_class: UTF8Type}, {column_name: gender, validation_class: AsciiType}]; update column family users with comparator = UTF8Type and column_metadata = [{column_name: password, validation_class: UTF8Type} {column_name: gender, validation_class: UTF8Type}]; {code} *Before After quitting cassandra-cli: Notice the validation class for the gender client still shows AsciiType* {code} [default@demo] describe keyspace demo; Keyspace: demo: Replication Strategy: org.apache.cassandra.locator.NetworkTopologyStrategy Options: [datacenter1:1] Column Families: ColumnFamily: users Key Validation Class: org.apache.cassandra.db.marshal.BytesType Default column value validator: org.apache.cassandra.db.marshal.BytesType Columns sorted by: org.apache.cassandra.db.marshal.UTF8Type Row cache size / save period in seconds: 0.0/0 Key cache size / save period in seconds: 20.0/14400 Memtable thresholds: 0.290624997/62/1440 (millions of ops/MB/minutes) GC grace seconds: 864000 Compaction min/max thresholds: 4/32 Read repair chance: 1.0 Replicate on write: false Built indexes: [] Column Metadata: Column Name: gender Validation Class: org.apache.cassandra.db.marshal.AsciiType Column Name: password Validation Class: org.apache.cassandra.db.marshal.UTF8Type {code} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2453) node.js cql driver
[ https://issues.apache.org/jira/browse/CASSANDRA-2453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022871#comment-13022871 ] Gary Dusbabek commented on CASSANDRA-2453: -- https://github.com/racker/node-cassandra-client FWIW, we're going to let people poke at it on github for a while before we submit it to the cassandra src tree. node.js cql driver -- Key: CASSANDRA-2453 URL: https://issues.apache.org/jira/browse/CASSANDRA-2453 Project: Cassandra Issue Type: New Feature Components: Core Reporter: Gary Dusbabek Assignee: Gary Dusbabek Priority: Minor Fix For: 0.8.1 -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2528) NPE from PrecompactedRow
[ https://issues.apache.org/jira/browse/CASSANDRA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis updated CASSANDRA-2528: -- Reviewer: cywjackson Affects Version/s: 0.8 beta 1 Fix Version/s: 0.8.0 Assignee: Jonathan Ellis NPE from PrecompactedRow Key: CASSANDRA-2528 URL: https://issues.apache.org/jira/browse/CASSANDRA-2528 Project: Cassandra Issue Type: Bug Affects Versions: 0.8 beta 1 Reporter: Jackson Chung Assignee: Jonathan Ellis Fix For: 0.8.0 Attachments: 2528.txt received a NPE from trunk (0.8) on PrecompactedRow: ERROR [CompactionExecutor:2] 2011-04-21 17:21:31,610 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[CompactionExecutor:2,1,main] java.lang.NullPointerException at org.apache.cassandra.io.PrecompactedRow.init(PrecompactedRow.java:86) at org.apache.cassandra.io.CompactionIterator.getCompactedRow(CompactionIterator.java:167) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:124) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:44) at org.apache.cassandra.utils.ReducingIterator.computeNext(ReducingIterator.java:74) at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:140) at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:135) at org.apache.commons.collections.iterators.FilterIterator.setNextObject(FilterIterator.java:183) at org.apache.commons.collections.iterators.FilterIterator.hasNext(FilterIterator.java:94) at org.apache.cassandra.db.CompactionManager.doCompaction(CompactionManager.java:553) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:146) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:112) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) at java.util.concurrent.FutureTask.run(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:662) size of data in /var/lib/cassandra is 11G on this, but there is also report that 1.7G also see the same. data was previously populated from 0.7.4 cassandra added debug logging, not sure how much this help (this is logged before the exception.) INFO [CompactionExecutor:2] 2011-04-21 17:21:31,588 CompactionManager.java (line 534) Compacting Major: [SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-10-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-7-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-6-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-8-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-9-Data.db')] DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-10-Data.db : 256 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-7-Data.db : 512 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-6-Data.db : 768 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,589 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-8-Data.db : 1024 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,589 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-9-Data.db : 1280 INFO [CompactionExecutor:2] 2011-04-21 17:21:31,609 CompactionIterator.java (line 185) Major@1181554512(cfs, inode.path, 523/10895) now compacting at 16777 bytes/ms. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2528) NPE from PrecompactedRow
[ https://issues.apache.org/jira/browse/CASSANDRA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis updated CASSANDRA-2528: -- Attachment: 2528.txt can you try w/ this patch? it adds additional asserts to narrow down where the error is NPE from PrecompactedRow Key: CASSANDRA-2528 URL: https://issues.apache.org/jira/browse/CASSANDRA-2528 Project: Cassandra Issue Type: Bug Affects Versions: 0.8 beta 1 Reporter: Jackson Chung Fix For: 0.8.0 Attachments: 2528.txt received a NPE from trunk (0.8) on PrecompactedRow: ERROR [CompactionExecutor:2] 2011-04-21 17:21:31,610 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[CompactionExecutor:2,1,main] java.lang.NullPointerException at org.apache.cassandra.io.PrecompactedRow.init(PrecompactedRow.java:86) at org.apache.cassandra.io.CompactionIterator.getCompactedRow(CompactionIterator.java:167) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:124) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:44) at org.apache.cassandra.utils.ReducingIterator.computeNext(ReducingIterator.java:74) at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:140) at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:135) at org.apache.commons.collections.iterators.FilterIterator.setNextObject(FilterIterator.java:183) at org.apache.commons.collections.iterators.FilterIterator.hasNext(FilterIterator.java:94) at org.apache.cassandra.db.CompactionManager.doCompaction(CompactionManager.java:553) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:146) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:112) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) at java.util.concurrent.FutureTask.run(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:662) size of data in /var/lib/cassandra is 11G on this, but there is also report that 1.7G also see the same. data was previously populated from 0.7.4 cassandra added debug logging, not sure how much this help (this is logged before the exception.) INFO [CompactionExecutor:2] 2011-04-21 17:21:31,588 CompactionManager.java (line 534) Compacting Major: [SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-10-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-7-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-6-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-8-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-9-Data.db')] DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-10-Data.db : 256 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-7-Data.db : 512 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-6-Data.db : 768 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,589 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-8-Data.db : 1024 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,589 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-9-Data.db : 1280 INFO [CompactionExecutor:2] 2011-04-21 17:21:31,609 CompactionIterator.java (line 185) Major@1181554512(cfs, inode.path, 523/10895) now compacting at 16777 bytes/ms. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2528) NPE from PrecompactedRow
[ https://issues.apache.org/jira/browse/CASSANDRA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022884#comment-13022884 ] Jackson Chung commented on CASSANDRA-2528: -- sure, here is the Assertion Error, the null is on metadata: NPE from PrecompactedRow Key: CASSANDRA-2528 URL: https://issues.apache.org/jira/browse/CASSANDRA-2528 Project: Cassandra Issue Type: Bug Affects Versions: 0.8 beta 1 Reporter: Jackson Chung Assignee: Jonathan Ellis Fix For: 0.8.0 Attachments: 2528.txt received a NPE from trunk (0.8) on PrecompactedRow: ERROR [CompactionExecutor:2] 2011-04-21 17:21:31,610 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[CompactionExecutor:2,1,main] java.lang.NullPointerException at org.apache.cassandra.io.PrecompactedRow.init(PrecompactedRow.java:86) at org.apache.cassandra.io.CompactionIterator.getCompactedRow(CompactionIterator.java:167) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:124) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:44) at org.apache.cassandra.utils.ReducingIterator.computeNext(ReducingIterator.java:74) at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:140) at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:135) at org.apache.commons.collections.iterators.FilterIterator.setNextObject(FilterIterator.java:183) at org.apache.commons.collections.iterators.FilterIterator.hasNext(FilterIterator.java:94) at org.apache.cassandra.db.CompactionManager.doCompaction(CompactionManager.java:553) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:146) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:112) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) at java.util.concurrent.FutureTask.run(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:662) size of data in /var/lib/cassandra is 11G on this, but there is also report that 1.7G also see the same. data was previously populated from 0.7.4 cassandra added debug logging, not sure how much this help (this is logged before the exception.) INFO [CompactionExecutor:2] 2011-04-21 17:21:31,588 CompactionManager.java (line 534) Compacting Major: [SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-10-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-7-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-6-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-8-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-9-Data.db')] DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-10-Data.db : 256 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-7-Data.db : 512 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-6-Data.db : 768 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,589 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-8-Data.db : 1024 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,589 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-9-Data.db : 1280 INFO [CompactionExecutor:2] 2011-04-21 17:21:31,609 CompactionIterator.java (line 185) Major@1181554512(cfs, inode.path, 523/10895) now compacting at 16777 bytes/ms. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2528) NPE from PrecompactedRow
[ https://issues.apache.org/jira/browse/CASSANDRA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022885#comment-13022885 ] Jackson Chung commented on CASSANDRA-2528: -- DEBUG [CompactionExecutor:2] 2011-04-21 19:31:46,797 PrecompactedRow.java (line 85) debugging controoler true DEBUG [CompactionExecutor:2] 2011-04-21 19:31:46,798 PrecompactedRow.java (line 87) debugging compactedCF: ColumnFamily(anonymous [3636363663643736663936393536343639653762653339643735306363376439:false:0@1303340825329,]) INFO [CompactionExecutor:2] 2011-04-21 19:31:46,799 CompactionIterator.java (line 185) Major@31583366(cfs, inode.path, 772/11720) now compacting at 8388 bytes/ms. ERROR [CompactionExecutor:2] 2011-04-21 19:31:46,850 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[CompactionExecutor:2,1,main] java.lang.AssertionError at org.apache.cassandra.io.PrecompactedRow.init(PrecompactedRow.java:91) at org.apache.cassandra.io.CompactionIterator.getCompactedRow(CompactionIterator.java:167) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:124) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:44) at org.apache.cassandra.utils.ReducingIterator.computeNext(ReducingIterator.java:74) at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:140) at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:135) at org.apache.commons.collections.iterators.FilterIterator.setNextObject(FilterIterator.java:183) at org.apache.commons.collections.iterators.FilterIterator.hasNext(FilterIterator.java:94) at org.apache.cassandra.db.CompactionManager.doCompaction(CompactionManager.java:553) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:146) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:112) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) at java.util.concurrent.FutureTask.run(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:662) NPE from PrecompactedRow Key: CASSANDRA-2528 URL: https://issues.apache.org/jira/browse/CASSANDRA-2528 Project: Cassandra Issue Type: Bug Affects Versions: 0.8 beta 1 Reporter: Jackson Chung Assignee: Jonathan Ellis Fix For: 0.8.0 Attachments: 2528.txt received a NPE from trunk (0.8) on PrecompactedRow: ERROR [CompactionExecutor:2] 2011-04-21 17:21:31,610 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[CompactionExecutor:2,1,main] java.lang.NullPointerException at org.apache.cassandra.io.PrecompactedRow.init(PrecompactedRow.java:86) at org.apache.cassandra.io.CompactionIterator.getCompactedRow(CompactionIterator.java:167) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:124) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:44) at org.apache.cassandra.utils.ReducingIterator.computeNext(ReducingIterator.java:74) at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:140) at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:135) at org.apache.commons.collections.iterators.FilterIterator.setNextObject(FilterIterator.java:183) at org.apache.commons.collections.iterators.FilterIterator.hasNext(FilterIterator.java:94) at org.apache.cassandra.db.CompactionManager.doCompaction(CompactionManager.java:553) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:146) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:112) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) at java.util.concurrent.FutureTask.run(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:662) size of data in /var/lib/cassandra is 11G on this, but there is also report that 1.7G also see the same. data was previously populated from 0.7.4 cassandra added debug logging, not sure how much this help (this is logged before the exception.) INFO [CompactionExecutor:2] 2011-04-21 17:21:31,588 CompactionManager.java (line 534) Compacting Major:
[jira] [Commented] (CASSANDRA-2528) NPE from PrecompactedRow
[ https://issues.apache.org/jira/browse/CASSANDRA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022886#comment-13022886 ] Jackson Chung commented on CASSANDRA-2528: -- {code:title=PrepcompactedRow.java} 85 logger.debug(String.format(debugging controoler %b, controller.shouldPurge(key))); 86 compactedCf = controller.shouldPurge(key) ? ColumnFamilyStore.removeDeleted(cf, controller.gcBefore) : cf; 87 logger.debug(String.format(debugging compactedCF: %s, compactedCf.toString())); 88 //if (compactedCf != null compactedCf.metadata().getDefaultValidator().isCommutative()) 89 if (compactedCf != null) 90 { 91 assert compactedCf.metadata() != null; 92 assert compactedCf.metadata().getDefaultValidator() != null; 93 if (compactedCf.metadata().getDefaultValidator().isCommutative()) 94 { 95 CounterColumn.removeOldShards(compactedCf, controller.gcBefore); 96 } {code} NPE from PrecompactedRow Key: CASSANDRA-2528 URL: https://issues.apache.org/jira/browse/CASSANDRA-2528 Project: Cassandra Issue Type: Bug Affects Versions: 0.8 beta 1 Reporter: Jackson Chung Assignee: Jonathan Ellis Fix For: 0.8.0 Attachments: 2528.txt received a NPE from trunk (0.8) on PrecompactedRow: ERROR [CompactionExecutor:2] 2011-04-21 17:21:31,610 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[CompactionExecutor:2,1,main] java.lang.NullPointerException at org.apache.cassandra.io.PrecompactedRow.init(PrecompactedRow.java:86) at org.apache.cassandra.io.CompactionIterator.getCompactedRow(CompactionIterator.java:167) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:124) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:44) at org.apache.cassandra.utils.ReducingIterator.computeNext(ReducingIterator.java:74) at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:140) at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:135) at org.apache.commons.collections.iterators.FilterIterator.setNextObject(FilterIterator.java:183) at org.apache.commons.collections.iterators.FilterIterator.hasNext(FilterIterator.java:94) at org.apache.cassandra.db.CompactionManager.doCompaction(CompactionManager.java:553) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:146) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:112) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) at java.util.concurrent.FutureTask.run(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:662) size of data in /var/lib/cassandra is 11G on this, but there is also report that 1.7G also see the same. data was previously populated from 0.7.4 cassandra added debug logging, not sure how much this help (this is logged before the exception.) INFO [CompactionExecutor:2] 2011-04-21 17:21:31,588 CompactionManager.java (line 534) Compacting Major: [SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-10-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-7-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-6-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-8-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-9-Data.db')] DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-10-Data.db : 256 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-7-Data.db : 512 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-6-Data.db : 768 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,589 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-8-Data.db : 1024 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,589 SSTableReader.java (line 132) index size for bloom filter calc
[jira] [Commented] (CASSANDRA-2528) NPE from PrecompactedRow
[ https://issues.apache.org/jira/browse/CASSANDRA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022887#comment-13022887 ] Jackson Chung commented on CASSANDRA-2528: -- $ grep java.lang.AssertionError -A3 /var/log/cassandra/system.log {noformat} java.lang.AssertionError at org.apache.cassandra.io.PrecompactedRow.init(PrecompactedRow.java:91) at org.apache.cassandra.io.CompactionIterator.getCompactedRow(CompactionIterator.java:167) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:124) -- java.lang.AssertionError at org.apache.cassandra.io.PrecompactedRow.init(PrecompactedRow.java:91) at org.apache.cassandra.io.CompactionIterator.getCompactedRow(CompactionIterator.java:167) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:124) {noformat} NPE from PrecompactedRow Key: CASSANDRA-2528 URL: https://issues.apache.org/jira/browse/CASSANDRA-2528 Project: Cassandra Issue Type: Bug Affects Versions: 0.8 beta 1 Reporter: Jackson Chung Assignee: Jonathan Ellis Fix For: 0.8.0 Attachments: 2528.txt received a NPE from trunk (0.8) on PrecompactedRow: ERROR [CompactionExecutor:2] 2011-04-21 17:21:31,610 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[CompactionExecutor:2,1,main] java.lang.NullPointerException at org.apache.cassandra.io.PrecompactedRow.init(PrecompactedRow.java:86) at org.apache.cassandra.io.CompactionIterator.getCompactedRow(CompactionIterator.java:167) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:124) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:44) at org.apache.cassandra.utils.ReducingIterator.computeNext(ReducingIterator.java:74) at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:140) at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:135) at org.apache.commons.collections.iterators.FilterIterator.setNextObject(FilterIterator.java:183) at org.apache.commons.collections.iterators.FilterIterator.hasNext(FilterIterator.java:94) at org.apache.cassandra.db.CompactionManager.doCompaction(CompactionManager.java:553) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:146) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:112) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) at java.util.concurrent.FutureTask.run(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:662) size of data in /var/lib/cassandra is 11G on this, but there is also report that 1.7G also see the same. data was previously populated from 0.7.4 cassandra added debug logging, not sure how much this help (this is logged before the exception.) INFO [CompactionExecutor:2] 2011-04-21 17:21:31,588 CompactionManager.java (line 534) Compacting Major: [SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-10-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-7-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-6-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-8-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-9-Data.db')] DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-10-Data.db : 256 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-7-Data.db : 512 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-6-Data.db : 768 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,589 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-8-Data.db : 1024 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,589 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-9-Data.db : 1280 INFO [CompactionExecutor:2] 2011-04-21 17:21:31,609 CompactionIterator.java (line 185) Major@1181554512(cfs, inode.path, 523/10895) now
[jira] [Created] (CASSANDRA-2529) CQL: Cassandra CLI allows a simple create keyspace statement, but CQL does not
CQL: Cassandra CLI allows a simple create keyspace statement, but CQL does not -- Key: CASSANDRA-2529 URL: https://issues.apache.org/jira/browse/CASSANDRA-2529 Project: Cassandra Issue Type: Bug Environment: 3 nodes on rackspace running Centos 5.5 Cassandra 0.8 build 30: https://builds.apache.org/hudson/job/Cassandra-0.8/30/ Reporter: Cathy Daw Priority: Minor Fix For: 0.8.0 *CQL* {code} cqlsh create keyspace testcql0; Bad Request: line 1:20 mismatched input ';' expecting K_WITH {code} *Cassandra CLI* {code} [default@unknown] create keyspace testcli0; 3535f660-6c4f-11e0--710abe20addf Waiting for schema agreement... ... schemas agree across the cluster [default@unknown] describe keyspace testcli0; Keyspace: none: Replication Strategy: org.apache.cassandra.locator.NetworkTopologyStrategy Options: [datacenter1:1] Column Families: {code} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2529) CQL: Cassandra CLI allows a simple create keyspace statement, but CQL does not
[ https://issues.apache.org/jira/browse/CASSANDRA-2529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cathy Daw updated CASSANDRA-2529: - Labels: cql (was: ) Description: *CQL* {code} cqlsh create keyspace testcql0; Bad Request: line 1:20 mismatched input ';' expecting K_WITH {code} *Cassandra CLI* {code} [default@unknown] create keyspace testcli0; 3535f660-6c4f-11e0--710abe20addf Waiting for schema agreement... ... schemas agree across the cluster [default@unknown] describe keyspace testcli0; Keyspace: none: Replication Strategy: org.apache.cassandra.locator.NetworkTopologyStrategy Options: [datacenter1:1] Column Families: {code} was: *CQL* {code} cqlsh create keyspace testcql0; Bad Request: line 1:20 mismatched input ';' expecting K_WITH {code} *Cassandra CLI* {code} [default@unknown] create keyspace testcli0; 3535f660-6c4f-11e0--710abe20addf Waiting for schema agreement... ... schemas agree across the cluster [default@unknown] describe keyspace testcli0; Keyspace: none: Replication Strategy: org.apache.cassandra.locator.NetworkTopologyStrategy Options: [datacenter1:1] Column Families: {code} CQL: Cassandra CLI allows a simple create keyspace statement, but CQL does not -- Key: CASSANDRA-2529 URL: https://issues.apache.org/jira/browse/CASSANDRA-2529 Project: Cassandra Issue Type: Bug Environment: 3 nodes on rackspace running Centos 5.5 Cassandra 0.8 build 30: https://builds.apache.org/hudson/job/Cassandra-0.8/30/ Reporter: Cathy Daw Priority: Minor Labels: cql Fix For: 0.8.0 *CQL* {code} cqlsh create keyspace testcql0; Bad Request: line 1:20 mismatched input ';' expecting K_WITH {code} *Cassandra CLI* {code} [default@unknown] create keyspace testcli0; 3535f660-6c4f-11e0--710abe20addf Waiting for schema agreement... ... schemas agree across the cluster [default@unknown] describe keyspace testcli0; Keyspace: none: Replication Strategy: org.apache.cassandra.locator.NetworkTopologyStrategy Options: [datacenter1:1] Column Families: {code} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2512) Updating a column's validation class from AsciiType to UTF8Type does not actually work
[ https://issues.apache.org/jira/browse/CASSANDRA-2512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022893#comment-13022893 ] Hudson commented on CASSANDRA-2512: --- Integrated in Cassandra #861 (See [https://builds.apache.org/hudson/job/Cassandra/861/]) merge CASSANDRA-2512 from 0.8 Updating a column's validation class from AsciiType to UTF8Type does not actually work -- Key: CASSANDRA-2512 URL: https://issues.apache.org/jira/browse/CASSANDRA-2512 Project: Cassandra Issue Type: Bug Affects Versions: 0.7.0 Environment: Single Node on MacOSX, installed from 0.7.4 binary .tar ball. Reporter: Cathy Daw Assignee: Jonathan Ellis Fix For: 0.7.5 Attachments: 2512.txt Please note this is reproducible on both Cassandra 0.74 and the April 18th trunk build. *Reproduction Steps* {code} create column family users with comparator = UTF8Type and column_metadata = [{column_name: password, validation_class: UTF8Type}, {column_name: gender, validation_class: AsciiType}]; update column family users with comparator = UTF8Type and column_metadata = [{column_name: password, validation_class: UTF8Type} {column_name: gender, validation_class: UTF8Type}]; {code} *Before After quitting cassandra-cli: Notice the validation class for the gender client still shows AsciiType* {code} [default@demo] describe keyspace demo; Keyspace: demo: Replication Strategy: org.apache.cassandra.locator.NetworkTopologyStrategy Options: [datacenter1:1] Column Families: ColumnFamily: users Key Validation Class: org.apache.cassandra.db.marshal.BytesType Default column value validator: org.apache.cassandra.db.marshal.BytesType Columns sorted by: org.apache.cassandra.db.marshal.UTF8Type Row cache size / save period in seconds: 0.0/0 Key cache size / save period in seconds: 20.0/14400 Memtable thresholds: 0.290624997/62/1440 (millions of ops/MB/minutes) GC grace seconds: 864000 Compaction min/max thresholds: 4/32 Read repair chance: 1.0 Replicate on write: false Built indexes: [] Column Metadata: Column Name: gender Validation Class: org.apache.cassandra.db.marshal.AsciiType Column Name: password Validation Class: org.apache.cassandra.db.marshal.UTF8Type {code} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2512) Updating a column's validation class from AsciiType to UTF8Type does not actually work
[ https://issues.apache.org/jira/browse/CASSANDRA-2512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022894#comment-13022894 ] Hudson commented on CASSANDRA-2512: --- Integrated in Cassandra-0.8 #31 (See [https://builds.apache.org/hudson/job/Cassandra-0.8/31/]) merge CASSANDRA-2512 from 0.7 Updating a column's validation class from AsciiType to UTF8Type does not actually work -- Key: CASSANDRA-2512 URL: https://issues.apache.org/jira/browse/CASSANDRA-2512 Project: Cassandra Issue Type: Bug Affects Versions: 0.7.0 Environment: Single Node on MacOSX, installed from 0.7.4 binary .tar ball. Reporter: Cathy Daw Assignee: Jonathan Ellis Fix For: 0.7.5 Attachments: 2512.txt Please note this is reproducible on both Cassandra 0.74 and the April 18th trunk build. *Reproduction Steps* {code} create column family users with comparator = UTF8Type and column_metadata = [{column_name: password, validation_class: UTF8Type}, {column_name: gender, validation_class: AsciiType}]; update column family users with comparator = UTF8Type and column_metadata = [{column_name: password, validation_class: UTF8Type} {column_name: gender, validation_class: UTF8Type}]; {code} *Before After quitting cassandra-cli: Notice the validation class for the gender client still shows AsciiType* {code} [default@demo] describe keyspace demo; Keyspace: demo: Replication Strategy: org.apache.cassandra.locator.NetworkTopologyStrategy Options: [datacenter1:1] Column Families: ColumnFamily: users Key Validation Class: org.apache.cassandra.db.marshal.BytesType Default column value validator: org.apache.cassandra.db.marshal.BytesType Columns sorted by: org.apache.cassandra.db.marshal.UTF8Type Row cache size / save period in seconds: 0.0/0 Key cache size / save period in seconds: 20.0/14400 Memtable thresholds: 0.290624997/62/1440 (millions of ops/MB/minutes) GC grace seconds: 864000 Compaction min/max thresholds: 4/32 Read repair chance: 1.0 Replicate on write: false Built indexes: [] Column Metadata: Column Name: gender Validation Class: org.apache.cassandra.db.marshal.AsciiType Column Name: password Validation Class: org.apache.cassandra.db.marshal.UTF8Type {code} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Created] (CASSANDRA-2530) Additional AbstractType data type definitions to enrich CQL
Additional AbstractType data type definitions to enrich CQL --- Key: CASSANDRA-2530 URL: https://issues.apache.org/jira/browse/CASSANDRA-2530 Project: Cassandra Issue Type: Improvement Components: Core Affects Versions: 0.8.0 Reporter: Rick Shaw Priority: Trivial Provide 5 additional Datatypes: ByteType, DateType, BooleanType, FloatType, DoubleType. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2280) Request specific column families using StreamIn
[ https://issues.apache.org/jira/browse/CASSANDRA-2280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis updated CASSANDRA-2280: -- Attachment: 2280-v3.txt bq. StreamInSession (the session created by the requesting node) doesn't record any of the information about the request That's what I was missing. Thanks for clarifying. v3 rebases and removes special casing of empty CF list. As expected, this improves encapsulation of special cases (only streaming code needs to care, instead of leaking to anything that might touch a list of CF names). Also converted to passing CFS objects around instead of strings, resulting in a minor improvement on the amount of manual looping that gets done. Note that passing table is redundant (CFS objects know their table) and I think the entire single file stream mode is unused too, but I've left these alone for now. Request specific column families using StreamIn --- Key: CASSANDRA-2280 URL: https://issues.apache.org/jira/browse/CASSANDRA-2280 Project: Cassandra Issue Type: Improvement Components: Core Reporter: Stu Hood Assignee: Stu Hood Fix For: 0.8.0 Attachments: 0001-Allow-specific-column-families-to-be-requested-for-str.txt, 0001-Allow-specific-column-families-to-be-requested-for-str.txt, 2280-v3.txt StreamIn.requestRanges only specifies a keyspace, meaning that requesting a range will request it for all column families: if you have a large number of CFs, this can cause quite a headache. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2530) Additional AbstractType data type definitions to enrich CQL
[ https://issues.apache.org/jira/browse/CASSANDRA-2530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rick Shaw updated CASSANDRA-2530: - Attachment: patch-to-add -5 -new-AbstractTypes.txt Additional AbstractType data type definitions to enrich CQL --- Key: CASSANDRA-2530 URL: https://issues.apache.org/jira/browse/CASSANDRA-2530 Project: Cassandra Issue Type: Improvement Components: Core Affects Versions: 0.8.0 Reporter: Rick Shaw Priority: Trivial Labels: cql Attachments: patch-to-add -5 -new-AbstractTypes.txt Provide 5 additional Datatypes: ByteType, DateType, BooleanType, FloatType, DoubleType. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2280) Request specific column families using StreamIn
[ https://issues.apache.org/jira/browse/CASSANDRA-2280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis updated CASSANDRA-2280: -- Fix Version/s: (was: 0.8.0) 0.8.1 This is a big enough change that I don't want to sneak it into 0.8 RC. Tagging 0.8.1, meaning, commit to trunk for now and backport after 0.8.0. Request specific column families using StreamIn --- Key: CASSANDRA-2280 URL: https://issues.apache.org/jira/browse/CASSANDRA-2280 Project: Cassandra Issue Type: Improvement Components: Core Reporter: Stu Hood Assignee: Stu Hood Fix For: 0.8.1 Attachments: 0001-Allow-specific-column-families-to-be-requested-for-str.txt, 0001-Allow-specific-column-families-to-be-requested-for-str.txt, 2280-v3.txt StreamIn.requestRanges only specifies a keyspace, meaning that requesting a range will request it for all column families: if you have a large number of CFs, this can cause quite a headache. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2530) Additional AbstractType data type definitions to enrich CQL
[ https://issues.apache.org/jira/browse/CASSANDRA-2530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022908#comment-13022908 ] Jeremy Hanna commented on CASSANDRA-2530: - If you're working against the current 0.8 branch, you'll see that you need decompose on the AbstractType as well - just going the other direction. Thanks for putting a patch together! Additional AbstractType data type definitions to enrich CQL --- Key: CASSANDRA-2530 URL: https://issues.apache.org/jira/browse/CASSANDRA-2530 Project: Cassandra Issue Type: Improvement Components: Core Affects Versions: 0.8.0 Reporter: Rick Shaw Priority: Trivial Labels: cql Attachments: patch-to-add -5 -new-AbstractTypes.txt Provide 5 additional Datatypes: ByteType, DateType, BooleanType, FloatType, DoubleType. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2238) Allow nodetool to print out hostnames given an option
[ https://issues.apache.org/jira/browse/CASSANDRA-2238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022907#comment-13022907 ] paul cannon commented on CASSANDRA-2238: bq. Can you elaborate on why that's a bad idea? Cause it seems like a pretty arbitrary information source. I've seen remarkably few production environments that provided actual, resolvable, useful, consistent IP-name lookups between internal addresses. In most cases, when a reverse lookup name is available, it will be a mostly-useless restatement of the IP (like c124-54-18-41.random.cloudsite.com), or it will have a good change of being different depending on the request's origin node. And even when a consistent answer is available, nodetool won't know if it is supposed to get it via PTR request through DNS, or through a different OS administrative interface (like /etc/hosts, getent, NSS), or by something entirely different. When a user has a need for this, it might be more straightforward for them to use a dumb awk script to replace the first field of nodetool output with a name, translated according to their own site procedures. Allow nodetool to print out hostnames given an option - Key: CASSANDRA-2238 URL: https://issues.apache.org/jira/browse/CASSANDRA-2238 Project: Cassandra Issue Type: Improvement Components: Tools Reporter: Joaquin Casares Assignee: paul cannon Priority: Trivial Fix For: 0.8.1 Give nodetool the option of either displaying IPs or hostnames for the nodes in a ring. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Resolved] (CASSANDRA-2238) Allow nodetool to print out hostnames given an option
[ https://issues.apache.org/jira/browse/CASSANDRA-2238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis resolved CASSANDRA-2238. --- Resolution: Won't Fix Fix Version/s: (was: 0.8.1) Assignee: (was: paul cannon) Makes sense to me. Allow nodetool to print out hostnames given an option - Key: CASSANDRA-2238 URL: https://issues.apache.org/jira/browse/CASSANDRA-2238 Project: Cassandra Issue Type: Improvement Components: Tools Reporter: Joaquin Casares Priority: Trivial Give nodetool the option of either displaying IPs or hostnames for the nodes in a ring. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2530) Additional AbstractType data type definitions to enrich CQL
[ https://issues.apache.org/jira/browse/CASSANDRA-2530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022913#comment-13022913 ] Jonathan Ellis commented on CASSANDRA-2530: --- Thanks for the patch! I'm slightly against having both Float and Double -- I'd like to discourage premature optimization and using 4 bytes for floating point instead of 8 is almost always the wrong space:accuracy tradeoff today. Similarly not sure there is a raison d'être for ByteType. This looks wrong: {noformat} +if (bytes.remaining() != 4) +{ +throw new MarshalException(A double is exactly 8 bytes) : +bytes.remaining()); +} {noformat} Please check use of whitespace w/ http://wiki.apache.org/cassandra/CodeStyle. Would like to see new Types covered by RoundTripTest. Would like to see new Types integrated into CQL; this does involve digging into the Antlr code though (to allow it to recognize new literal types). So if you want we can open a separate ticket for that. Additional AbstractType data type definitions to enrich CQL --- Key: CASSANDRA-2530 URL: https://issues.apache.org/jira/browse/CASSANDRA-2530 Project: Cassandra Issue Type: Improvement Components: Core Affects Versions: 0.8.0 Reporter: Rick Shaw Priority: Trivial Labels: cql Attachments: patch-to-add -5 -new-AbstractTypes.txt Provide 5 additional Datatypes: ByteType, DateType, BooleanType, FloatType, DoubleType. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2530) Additional AbstractType data type definitions to enrich CQL
[ https://issues.apache.org/jira/browse/CASSANDRA-2530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rick Shaw updated CASSANDRA-2530: - Attachment: patch-to-add -5 -new-AbstractTypes-v2.txt Sorry... Things changed out from under me! Additional AbstractType data type definitions to enrich CQL --- Key: CASSANDRA-2530 URL: https://issues.apache.org/jira/browse/CASSANDRA-2530 Project: Cassandra Issue Type: Improvement Components: Core Affects Versions: 0.8.0 Reporter: Rick Shaw Priority: Trivial Labels: cql Attachments: patch-to-add -5 -new-AbstractTypes-v2.txt, patch-to-add -5 -new-AbstractTypes.txt Provide 5 additional Datatypes: ByteType, DateType, BooleanType, FloatType, DoubleType. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2528) NPE from PrecompactedRow
[ https://issues.apache.org/jira/browse/CASSANDRA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis updated CASSANDRA-2528: -- Attachment: 2528.txt Patch to preserve the CFMetaData object used to construct the ColumnFamily, instead of looking it up from the registry (which does not contain metadata for index CFs). NPE from PrecompactedRow Key: CASSANDRA-2528 URL: https://issues.apache.org/jira/browse/CASSANDRA-2528 Project: Cassandra Issue Type: Bug Affects Versions: 0.8 beta 1 Reporter: Jackson Chung Assignee: Jonathan Ellis Fix For: 0.8.0 Attachments: 2528.txt, 2528.txt received a NPE from trunk (0.8) on PrecompactedRow: ERROR [CompactionExecutor:2] 2011-04-21 17:21:31,610 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[CompactionExecutor:2,1,main] java.lang.NullPointerException at org.apache.cassandra.io.PrecompactedRow.init(PrecompactedRow.java:86) at org.apache.cassandra.io.CompactionIterator.getCompactedRow(CompactionIterator.java:167) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:124) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:44) at org.apache.cassandra.utils.ReducingIterator.computeNext(ReducingIterator.java:74) at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:140) at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:135) at org.apache.commons.collections.iterators.FilterIterator.setNextObject(FilterIterator.java:183) at org.apache.commons.collections.iterators.FilterIterator.hasNext(FilterIterator.java:94) at org.apache.cassandra.db.CompactionManager.doCompaction(CompactionManager.java:553) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:146) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:112) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) at java.util.concurrent.FutureTask.run(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:662) size of data in /var/lib/cassandra is 11G on this, but there is also report that 1.7G also see the same. data was previously populated from 0.7.4 cassandra added debug logging, not sure how much this help (this is logged before the exception.) INFO [CompactionExecutor:2] 2011-04-21 17:21:31,588 CompactionManager.java (line 534) Compacting Major: [SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-10-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-7-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-6-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-8-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-9-Data.db')] DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-10-Data.db : 256 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-7-Data.db : 512 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-6-Data.db : 768 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,589 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-8-Data.db : 1024 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,589 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-9-Data.db : 1280 INFO [CompactionExecutor:2] 2011-04-21 17:21:31,609 CompactionIterator.java (line 185) Major@1181554512(cfs, inode.path, 523/10895) now compacting at 16777 bytes/ms. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Created] (CASSANDRA-2531) There should be an easy way to see what DC and rack a node belongs to
There should be an easy way to see what DC and rack a node belongs to - Key: CASSANDRA-2531 URL: https://issues.apache.org/jira/browse/CASSANDRA-2531 Project: Cassandra Issue Type: New Feature Components: Core Reporter: Brandon Williams Priority: Trivial It would be especially nice to see them in nodetool ring, but I would settle for having it listed in nodetool info. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Resolved] (CASSANDRA-2529) CQL: Cassandra CLI allows a simple create keyspace statement, but CQL does not
[ https://issues.apache.org/jira/browse/CASSANDRA-2529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis resolved CASSANDRA-2529. --- Resolution: Not A Problem Fix Version/s: (was: 0.8.0) This is a case where the cli violates the second part of as simple as possible, but no simpler. The cli makes three assumptions for replication strategy if it is not specified: - you want NetworkTopologyStrategy (reasonable, but wait) - you are using SimpleSnitch (not often the case in production -- and Snitch is pluggable so it may not even be a Snitch class we ship with) - you want one replica in the datacenter containing the node you are connecting to (how is this intuitive?) Now, I said defaulting to NTS is reasonable, but if we make that the default and only require specifying strategy_options it confuses people when we then explain that the options differ based on which strategy class you are using. So it makes the most sense to keep everything explicit. (in the face of ambiguity, refuse the temptation to guess.) tl;dr we screwed up, but rather than break peoples' CLI scripts we're taking the opportunity offered by CQL to fix it. CQL: Cassandra CLI allows a simple create keyspace statement, but CQL does not -- Key: CASSANDRA-2529 URL: https://issues.apache.org/jira/browse/CASSANDRA-2529 Project: Cassandra Issue Type: Bug Environment: 3 nodes on rackspace running Centos 5.5 Cassandra 0.8 build 30: https://builds.apache.org/hudson/job/Cassandra-0.8/30/ Reporter: Cathy Daw Priority: Minor Labels: cql *CQL* {code} cqlsh create keyspace testcql0; Bad Request: line 1:20 mismatched input ';' expecting K_WITH {code} *Cassandra CLI* {code} [default@unknown] create keyspace testcli0; 3535f660-6c4f-11e0--710abe20addf Waiting for schema agreement... ... schemas agree across the cluster [default@unknown] describe keyspace testcli0; Keyspace: none: Replication Strategy: org.apache.cassandra.locator.NetworkTopologyStrategy Options: [datacenter1:1] Column Families: {code} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Created] (CASSANDRA-2532) Log read timeouts at the StorageProxy level
Log read timeouts at the StorageProxy level --- Key: CASSANDRA-2532 URL: https://issues.apache.org/jira/browse/CASSANDRA-2532 Project: Cassandra Issue Type: Bug Reporter: Stu Hood Fix For: 0.8.0 We log successful reads, but not timeouts (although we have a lovely TimeoutException message, it doesn't look like we are printing it). -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2531) There should be an easy way to see what DC and rack a node belongs to
[ https://issues.apache.org/jira/browse/CASSANDRA-2531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis updated CASSANDRA-2531: -- Component/s: (was: Core) Tools Fix Version/s: 0.8.1 Assignee: Joaquin Casares There should be an easy way to see what DC and rack a node belongs to - Key: CASSANDRA-2531 URL: https://issues.apache.org/jira/browse/CASSANDRA-2531 Project: Cassandra Issue Type: New Feature Components: Tools Reporter: Brandon Williams Assignee: Joaquin Casares Priority: Trivial Fix For: 0.8.1 It would be especially nice to see them in nodetool ring, but I would settle for having it listed in nodetool info. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2532) Log read timeouts at the StorageProxy level
[ https://issues.apache.org/jira/browse/CASSANDRA-2532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stu Hood updated CASSANDRA-2532: Attachment: 0001-Log-timeouts-in-SP.txt Log read timeouts at the StorageProxy level --- Key: CASSANDRA-2532 URL: https://issues.apache.org/jira/browse/CASSANDRA-2532 Project: Cassandra Issue Type: Bug Reporter: Stu Hood Fix For: 0.8.0 Attachments: 0001-Log-timeouts-in-SP.txt We log successful reads, but not timeouts (although we have a lovely TimeoutException message, it doesn't look like we are printing it). -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2530) Additional AbstractType data type definitions to enrich CQL
[ https://issues.apache.org/jira/browse/CASSANDRA-2530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022926#comment-13022926 ] Rick Shaw commented on CASSANDRA-2530: -- {quote} I'm slightly against having both Float and Double – I'd like to discourage premature optimization and using 4 bytes for floating point instead of 8 is almost always the wrong space:accuracy tradeoff today. {quote} I guess I added Float and Double together because they were so similar it seemed silly not to. It is also a JDBC type and seemed easy enough to provide and make implementing the next stages of JDBC easier. Selfishly, my implementations use a lot of small float numbers like: 1.2 or 66.667 so a row might have 50 columns of such data and 5-50 million rows. So a selfish trend on my part is to provide the smallest representation on bytes stored/in-memory. {quote} Similarly not sure there is a raison d'être for ByteType. {quote} My reasoning was more about a guaranteed length that was short. We plan to put ENUMs into them in prepared statements. Again, selfishly, if we have a lot of Float usage we *really* have a lot of numbers between 1-10 to store! So all these volumes above are just more exaggerated in our need to store lots of short numbers in an optimal width. But I do understand the variable integer {{IntegerType}} could be used. {quote} This looks wrong: {quote} Yep... Cut-n-paste in a hurry... will get you every time! I'll fix with v3 patch. (starting to see a trend) Yes. I'll look into the error of my whitespace ways. I will try to conjure some tests that dovetail into the existing testing framework. A separate ticket would probably be good for ANTLR work. I'll give it a shot but am about 30 years rusty on parsing grammars. But I'll gladly give it a try. Additional AbstractType data type definitions to enrich CQL --- Key: CASSANDRA-2530 URL: https://issues.apache.org/jira/browse/CASSANDRA-2530 Project: Cassandra Issue Type: Improvement Components: Core Affects Versions: 0.8.0 Reporter: Rick Shaw Priority: Trivial Labels: cql Attachments: patch-to-add -5 -new-AbstractTypes-v2.txt, patch-to-add -5 -new-AbstractTypes.txt Provide 5 additional Datatypes: ByteType, DateType, BooleanType, FloatType, DoubleType. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2532) Log read timeouts at the StorageProxy level
[ https://issues.apache.org/jira/browse/CASSANDRA-2532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022928#comment-13022928 ] Jonathan Ellis commented on CASSANDRA-2532: --- as discussed on irc, we should centralize timeout logging in SP rather than mixing it into both CassandraServer + SP. Log read timeouts at the StorageProxy level --- Key: CASSANDRA-2532 URL: https://issues.apache.org/jira/browse/CASSANDRA-2532 Project: Cassandra Issue Type: Bug Reporter: Stu Hood Fix For: 0.8.0 Attachments: 0001-Log-timeouts-in-SP.txt We log successful reads, but not timeouts (although we have a lovely TimeoutException message, it doesn't look like we are printing it). -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Created] (CASSANDRA-2533) CQL documentation missing INSERT syntax
CQL documentation missing INSERT syntax --- Key: CASSANDRA-2533 URL: https://issues.apache.org/jira/browse/CASSANDRA-2533 Project: Cassandra Issue Type: Bug Affects Versions: 0.8.0 Reporter: Cathy Daw Both documents are missing syntax for the INSERT statement: https://github.com/apache/cassandra/blob/trunk/doc/cql/CQL.textile https://github.com/apache/cassandra/raw/trunk/doc/cql/CQL.html -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2532) Log read timeouts at the StorageProxy level
[ https://issues.apache.org/jira/browse/CASSANDRA-2532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stu Hood updated CASSANDRA-2532: Attachment: 0002-Remove-useless-timeout-entries-in-thrift.CS.txt 0002 removes the useless timeout entry from thrift.CassandraServer for symmetry. Log read timeouts at the StorageProxy level --- Key: CASSANDRA-2532 URL: https://issues.apache.org/jira/browse/CASSANDRA-2532 Project: Cassandra Issue Type: Bug Reporter: Stu Hood Fix For: 0.8.0 Attachments: 0001-Log-timeouts-in-SP.txt, 0002-Remove-useless-timeout-entries-in-thrift.CS.txt We log successful reads, but not timeouts (although we have a lovely TimeoutException message, it doesn't look like we are printing it). -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2532) Log read timeouts at the StorageProxy level
[ https://issues.apache.org/jira/browse/CASSANDRA-2532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022935#comment-13022935 ] Jonathan Ellis commented on CASSANDRA-2532: --- can we do inserts too for consistency? Log read timeouts at the StorageProxy level --- Key: CASSANDRA-2532 URL: https://issues.apache.org/jira/browse/CASSANDRA-2532 Project: Cassandra Issue Type: Bug Reporter: Stu Hood Fix For: 0.8.0 Attachments: 0001-Log-timeouts-in-SP.txt, 0002-Remove-useless-timeout-entries-in-thrift.CS.txt We log successful reads, but not timeouts (although we have a lovely TimeoutException message, it doesn't look like we are printing it). -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2530) Additional AbstractType data type definitions to enrich CQL
[ https://issues.apache.org/jira/browse/CASSANDRA-2530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rick Shaw updated CASSANDRA-2530: - Attachment: patch-to-add -5 -new-AbstractTypes-v3.txt Additional AbstractType data type definitions to enrich CQL --- Key: CASSANDRA-2530 URL: https://issues.apache.org/jira/browse/CASSANDRA-2530 Project: Cassandra Issue Type: Improvement Components: Core Affects Versions: 0.8.0 Reporter: Rick Shaw Priority: Trivial Labels: cql Attachments: patch-to-add -5 -new-AbstractTypes-v2.txt, patch-to-add -5 -new-AbstractTypes-v3.txt, patch-to-add -5 -new-AbstractTypes.txt Provide 5 additional Datatypes: ByteType, DateType, BooleanType, FloatType, DoubleType. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2533) CQL documentation missing INSERT syntax
[ https://issues.apache.org/jira/browse/CASSANDRA-2533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022960#comment-13022960 ] Cathy Daw commented on CASSANDRA-2533: -- The more I look at the code, docs and existing tests, it looks like we use UPDATE since it behaves like an upsert. If that is the case, just let me know. CQL documentation missing INSERT syntax --- Key: CASSANDRA-2533 URL: https://issues.apache.org/jira/browse/CASSANDRA-2533 Project: Cassandra Issue Type: Bug Affects Versions: 0.8.0 Reporter: Cathy Daw Labels: cql Both documents are missing syntax for the INSERT statement: https://github.com/apache/cassandra/blob/trunk/doc/cql/CQL.textile https://github.com/apache/cassandra/raw/trunk/doc/cql/CQL.html -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Created] (CASSANDRA-2534) CQL: CREATE CF, DROP CF, CREATE CF caused my cluster to crash
CQL: CREATE CF, DROP CF, CREATE CF caused my cluster to crash - Key: CASSANDRA-2534 URL: https://issues.apache.org/jira/browse/CASSANDRA-2534 Project: Cassandra Issue Type: Bug Affects Versions: 0.8.0 Reporter: Cathy Daw Priority: Critical The following test case of CREATE CF, DROP CF, CREATE CF caused my cluster to crash. *CREATE/DROP/CREATE CF users* {code} cqlsh CREATE COLUMNFAMILY users ( ... KEY varchar PRIMARY KEY, ... password varchar); cqlsh drop columnfamily users; cqlsh CREATE COLUMNFAMILY users ( ... userkey varchar PRIMARY KEY, ... password varchar); Exception: TSocket read 0 bytes {code} *Cassandra CLI - session broken* {code} [default@clidb] describe keyspace cqldb; java.net.SocketException: Broken pipe {code} *Nodetool - server down* {code} [cassandra@cdaw-qa1 bin]$ ./nodetool -h cdaw-qa1 -p 7199 ring Error connection to remote JMX agent! java.io.IOException: Failed to retrieve RMIServer stub: javax.naming.ServiceUnavailableException [Root exception is java.rmi.ConnectException: Connection refused to host: cdaw-qa1; nested exception is: java.net.ConnectException: Connection refused] at javax.management.remote.rmi.RMIConnector.connect(RMIConnector.java:342) at javax.management.remote.JMXConnectorFactory.connect(JMXConnectorFactory.java:267) at org.apache.cassandra.tools.NodeProbe.connect(NodeProbe.java:139) at org.apache.cassandra.tools.NodeProbe.init(NodeProbe.java:109) at org.apache.cassandra.tools.NodeCmd.main(NodeCmd.java:525) Caused by: javax.naming.ServiceUnavailableException [Root exception is java.rmi.ConnectException: Connection refused to host: cdaw-qa1; nested exception is: java.net.ConnectException: Connection refused] at com.sun.jndi.rmi.registry.RegistryContext.lookup(RegistryContext.java:118) at com.sun.jndi.toolkit.url.GenericURLContext.lookup(GenericURLContext.java:203) at javax.naming.InitialContext.lookup(InitialContext.java:409) at javax.management.remote.rmi.RMIConnector.findRMIServerJNDI(RMIConnector.java:1902) at javax.management.remote.rmi.RMIConnector.findRMIServer(RMIConnector.java:1871) at javax.management.remote.rmi.RMIConnector.connect(RMIConnector.java:276) ... 4 more Caused by: java.rmi.ConnectException: Connection refused to host: cdaw-qa1; nested exception is: java.net.ConnectException: Connection refused at sun.rmi.transport.tcp.TCPEndpoint.newSocket(TCPEndpoint.java:619) at sun.rmi.transport.tcp.TCPChannel.createConnection(TCPChannel.java:216) at sun.rmi.transport.tcp.TCPChannel.newConnection(TCPChannel.java:202) at sun.rmi.server.UnicastRef.newCall(UnicastRef.java:340) at sun.rmi.registry.RegistryImpl_Stub.lookup(Unknown Source) at com.sun.jndi.rmi.registry.RegistryContext.lookup(RegistryContext.java:114) ... 9 more Caused by: java.net.ConnectException: Connection refused at java.net.PlainSocketImpl.socketConnect(Native Method) at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:310) at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:176) at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:163) at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:384) at java.net.Socket.connect(Socket.java:546) at java.net.Socket.connect(Socket.java:495) at java.net.Socket.init(Socket.java:392) at java.net.Socket.init(Socket.java:206) at sun.rmi.transport.proxy.RMIDirectSocketFactory.createSocket(RMIDirectSocketFactory.java:40) at sun.rmi.transport.proxy.RMIMasterSocketFactory.createSocket(RMIMasterSocketFactory.java:146) at sun.rmi.transport.tcp.TCPEndpoint.newSocket(TCPEndpoint.java:613) ... 14 more {code} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2534) CQL: CREATE CF, DROP CF, CREATE CF caused my cluster to crash
[ https://issues.apache.org/jira/browse/CASSANDRA-2534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022963#comment-13022963 ] Cathy Daw commented on CASSANDRA-2534: -- *Here is the activity on the consoles for each node* {noformat} First Node (Seed): cdaw-qa1 INFO 21:28:42,340 Completed flushing /var/lib/cassandra/data/system/Schema-f-39-Data.db (3549 bytes) INFO 21:36:53,342 Deleted /var/lib/cassandra/data/system/Schema-f-36 console was disconnected Second Node: cdaw-qa2 INFO 21:28:00,955 Completed flushing /var/lib/cassandra/data/system/Schema-f-39-Data.db (3549 bytes) console was disconnected Third Node: cdaw-qa3 INFO 21:28:37,321 Completed flushing /var/lib/cassandra/data/system/Schema-f-39-Data.db (3549 bytes) console was disconnected {noformat} CQL: CREATE CF, DROP CF, CREATE CF caused my cluster to crash - Key: CASSANDRA-2534 URL: https://issues.apache.org/jira/browse/CASSANDRA-2534 Project: Cassandra Issue Type: Bug Affects Versions: 0.8.0 Reporter: Cathy Daw Priority: Critical Labels: cql The following test case of CREATE CF, DROP CF, CREATE CF caused my cluster to crash. *CREATE/DROP/CREATE CF users* {code} cqlsh CREATE COLUMNFAMILY users ( ... KEY varchar PRIMARY KEY, ... password varchar); cqlsh drop columnfamily users; cqlsh CREATE COLUMNFAMILY users ( ... userkey varchar PRIMARY KEY, ... password varchar); Exception: TSocket read 0 bytes {code} *Cassandra CLI - session broken* {code} [default@clidb] describe keyspace cqldb; java.net.SocketException: Broken pipe {code} *Nodetool - server down* {code} [cassandra@cdaw-qa1 bin]$ ./nodetool -h cdaw-qa1 -p 7199 ring Error connection to remote JMX agent! java.io.IOException: Failed to retrieve RMIServer stub: javax.naming.ServiceUnavailableException [Root exception is java.rmi.ConnectException: Connection refused to host: cdaw-qa1; nested exception is: java.net.ConnectException: Connection refused] at javax.management.remote.rmi.RMIConnector.connect(RMIConnector.java:342) at javax.management.remote.JMXConnectorFactory.connect(JMXConnectorFactory.java:267) at org.apache.cassandra.tools.NodeProbe.connect(NodeProbe.java:139) at org.apache.cassandra.tools.NodeProbe.init(NodeProbe.java:109) at org.apache.cassandra.tools.NodeCmd.main(NodeCmd.java:525) Caused by: javax.naming.ServiceUnavailableException [Root exception is java.rmi.ConnectException: Connection refused to host: cdaw-qa1; nested exception is: java.net.ConnectException: Connection refused] at com.sun.jndi.rmi.registry.RegistryContext.lookup(RegistryContext.java:118) at com.sun.jndi.toolkit.url.GenericURLContext.lookup(GenericURLContext.java:203) at javax.naming.InitialContext.lookup(InitialContext.java:409) at javax.management.remote.rmi.RMIConnector.findRMIServerJNDI(RMIConnector.java:1902) at javax.management.remote.rmi.RMIConnector.findRMIServer(RMIConnector.java:1871) at javax.management.remote.rmi.RMIConnector.connect(RMIConnector.java:276) ... 4 more Caused by: java.rmi.ConnectException: Connection refused to host: cdaw-qa1; nested exception is: java.net.ConnectException: Connection refused at sun.rmi.transport.tcp.TCPEndpoint.newSocket(TCPEndpoint.java:619) at sun.rmi.transport.tcp.TCPChannel.createConnection(TCPChannel.java:216) at sun.rmi.transport.tcp.TCPChannel.newConnection(TCPChannel.java:202) at sun.rmi.server.UnicastRef.newCall(UnicastRef.java:340) at sun.rmi.registry.RegistryImpl_Stub.lookup(Unknown Source) at com.sun.jndi.rmi.registry.RegistryContext.lookup(RegistryContext.java:114) ... 9 more Caused by: java.net.ConnectException: Connection refused at java.net.PlainSocketImpl.socketConnect(Native Method) at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:310) at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:176) at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:163) at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:384) at java.net.Socket.connect(Socket.java:546) at java.net.Socket.connect(Socket.java:495) at java.net.Socket.init(Socket.java:392) at java.net.Socket.init(Socket.java:206) at sun.rmi.transport.proxy.RMIDirectSocketFactory.createSocket(RMIDirectSocketFactory.java:40) at sun.rmi.transport.proxy.RMIMasterSocketFactory.createSocket(RMIMasterSocketFactory.java:146) at sun.rmi.transport.tcp.TCPEndpoint.newSocket(TCPEndpoint.java:613) ... 14 more {code} -- This message is automatically
[jira] [Commented] (CASSANDRA-2528) NPE from PrecompactedRow
[ https://issues.apache.org/jira/browse/CASSANDRA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022962#comment-13022962 ] Jackson Chung commented on CASSANDRA-2528: -- the fix does address the NPE as now all CF has metadata. NPE from PrecompactedRow Key: CASSANDRA-2528 URL: https://issues.apache.org/jira/browse/CASSANDRA-2528 Project: Cassandra Issue Type: Bug Affects Versions: 0.8 beta 1 Reporter: Jackson Chung Assignee: Jonathan Ellis Fix For: 0.8.0 Attachments: 2528.txt, 2528.txt received a NPE from trunk (0.8) on PrecompactedRow: ERROR [CompactionExecutor:2] 2011-04-21 17:21:31,610 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[CompactionExecutor:2,1,main] java.lang.NullPointerException at org.apache.cassandra.io.PrecompactedRow.init(PrecompactedRow.java:86) at org.apache.cassandra.io.CompactionIterator.getCompactedRow(CompactionIterator.java:167) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:124) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:44) at org.apache.cassandra.utils.ReducingIterator.computeNext(ReducingIterator.java:74) at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:140) at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:135) at org.apache.commons.collections.iterators.FilterIterator.setNextObject(FilterIterator.java:183) at org.apache.commons.collections.iterators.FilterIterator.hasNext(FilterIterator.java:94) at org.apache.cassandra.db.CompactionManager.doCompaction(CompactionManager.java:553) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:146) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:112) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) at java.util.concurrent.FutureTask.run(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:662) size of data in /var/lib/cassandra is 11G on this, but there is also report that 1.7G also see the same. data was previously populated from 0.7.4 cassandra added debug logging, not sure how much this help (this is logged before the exception.) INFO [CompactionExecutor:2] 2011-04-21 17:21:31,588 CompactionManager.java (line 534) Compacting Major: [SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-10-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-7-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-6-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-8-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-9-Data.db')] DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-10-Data.db : 256 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-7-Data.db : 512 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-6-Data.db : 768 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,589 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-8-Data.db : 1024 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,589 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-9-Data.db : 1280 INFO [CompactionExecutor:2] 2011-04-21 17:21:31,609 CompactionIterator.java (line 185) Major@1181554512(cfs, inode.path, 523/10895) now compacting at 16777 bytes/ms. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Issue Comment Edited] (CASSANDRA-2534) CQL: CREATE CF, DROP CF, CREATE CF caused my cluster to crash
[ https://issues.apache.org/jira/browse/CASSANDRA-2534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022963#comment-13022963 ] Cathy Daw edited comment on CASSANDRA-2534 at 4/21/11 10:43 PM: *Here is the activity on the consoles for each node* {noformat} First Node (Seed): cdaw-qa1 INFO 21:28:42,340 Completed flushing /var/lib/cassandra/data/system/Schema-f-39-Data.db (3549 bytes) INFO 21:36:53,342 Deleted /var/lib/cassandra/data/system/Schema-f-36 console was disconnected Second Node: cdaw-qa2 INFO 21:28:00,955 Completed flushing /var/lib/cassandra/data/system/Schema-f-39-Data.db (3549 bytes) console was disconnected Third Node: cdaw-qa3 INFO 21:28:37,321 Completed flushing /var/lib/cassandra/data/system/Schema-f-39-Data.db (3549 bytes) console was disconnected {noformat} * I was able to restart each node successfully * {noformat} [cassandra@cdaw-qa1 bin]$ ./nodetool -h cdaw-qa1 ring Address Status State LoadOwnsToken 113427455640312821154458202477256070484 184.106.199.149 Up Normal 319.69 KB 33.33% 0 184.106.233.230 Up Normal 323.97 KB 33.33% 56713727820156410577229101238628035242 184.106.206.193 Up Normal 323.97 KB 33.33% 113427455640312821154458202477256070484 {noformat} *From cassandra-cli, the CF has been dropped* {noformat} Keyspace: cqldb: Replication Strategy: org.apache.cassandra.locator.SimpleStrategy Options: [replication_factor:2] Column Families: {noformat} was (Author: cdaw): *Here is the activity on the consoles for each node* {noformat} First Node (Seed): cdaw-qa1 INFO 21:28:42,340 Completed flushing /var/lib/cassandra/data/system/Schema-f-39-Data.db (3549 bytes) INFO 21:36:53,342 Deleted /var/lib/cassandra/data/system/Schema-f-36 console was disconnected Second Node: cdaw-qa2 INFO 21:28:00,955 Completed flushing /var/lib/cassandra/data/system/Schema-f-39-Data.db (3549 bytes) console was disconnected Third Node: cdaw-qa3 INFO 21:28:37,321 Completed flushing /var/lib/cassandra/data/system/Schema-f-39-Data.db (3549 bytes) console was disconnected {noformat} CQL: CREATE CF, DROP CF, CREATE CF caused my cluster to crash - Key: CASSANDRA-2534 URL: https://issues.apache.org/jira/browse/CASSANDRA-2534 Project: Cassandra Issue Type: Bug Affects Versions: 0.8.0 Reporter: Cathy Daw Priority: Critical Labels: cql The following test case of CREATE CF, DROP CF, CREATE CF caused my cluster to crash. *CREATE/DROP/CREATE CF users* {code} cqlsh CREATE COLUMNFAMILY users ( ... KEY varchar PRIMARY KEY, ... password varchar); cqlsh drop columnfamily users; cqlsh CREATE COLUMNFAMILY users ( ... userkey varchar PRIMARY KEY, ... password varchar); Exception: TSocket read 0 bytes {code} *Cassandra CLI - session broken* {code} [default@clidb] describe keyspace cqldb; java.net.SocketException: Broken pipe {code} *Nodetool - server down* {code} [cassandra@cdaw-qa1 bin]$ ./nodetool -h cdaw-qa1 -p 7199 ring Error connection to remote JMX agent! java.io.IOException: Failed to retrieve RMIServer stub: javax.naming.ServiceUnavailableException [Root exception is java.rmi.ConnectException: Connection refused to host: cdaw-qa1; nested exception is: java.net.ConnectException: Connection refused] at javax.management.remote.rmi.RMIConnector.connect(RMIConnector.java:342) at javax.management.remote.JMXConnectorFactory.connect(JMXConnectorFactory.java:267) at org.apache.cassandra.tools.NodeProbe.connect(NodeProbe.java:139) at org.apache.cassandra.tools.NodeProbe.init(NodeProbe.java:109) at org.apache.cassandra.tools.NodeCmd.main(NodeCmd.java:525) Caused by: javax.naming.ServiceUnavailableException [Root exception is java.rmi.ConnectException: Connection refused to host: cdaw-qa1; nested exception is: java.net.ConnectException: Connection refused] at com.sun.jndi.rmi.registry.RegistryContext.lookup(RegistryContext.java:118) at com.sun.jndi.toolkit.url.GenericURLContext.lookup(GenericURLContext.java:203) at javax.naming.InitialContext.lookup(InitialContext.java:409) at javax.management.remote.rmi.RMIConnector.findRMIServerJNDI(RMIConnector.java:1902) at javax.management.remote.rmi.RMIConnector.findRMIServer(RMIConnector.java:1871) at javax.management.remote.rmi.RMIConnector.connect(RMIConnector.java:276) ... 4 more Caused by: java.rmi.ConnectException: Connection refused to host: cdaw-qa1; nested exception is:
[jira] [Created] (CASSANDRA-2535) CQL create keyspace throws exceptions
CQL create keyspace throws exceptions - Key: CASSANDRA-2535 URL: https://issues.apache.org/jira/browse/CASSANDRA-2535 Project: Cassandra Issue Type: Bug Reporter: Chris Goffinet Was trying out CQL: cqlsh create keyspace foo with replication_factor=1 and strategy_class='org.apache.cassandra.locator.SimpleStrategy'; Bad Request: org.apache.cassandra.config.ConfigurationException: SimpleStrategy requires a replication_factor strategy option. On Cassandra side: INFO 15:41:14,423 Applying migration 768b63c0-6c68-11e0--242d50cf1fbf Add keyspace: foorep strategy:SimpleStrategy{} INFO 15:41:14,424 Enqueuing flush of Memtable-Migrations@17649447(6489/8111 serialized/live bytes, 1 ops) INFO 15:41:14,425 Enqueuing flush of Memtable-Schema@186829279(2599/3248 serialized/live bytes, 3 ops) INFO 15:41:14,425 Writing Memtable-Migrations@17649447(6489/8111 serialized/live bytes, 1 ops) INFO 15:41:14,435 Completed flushing /var/lib/cassandra/data/system/Migrations-f-1-Data.db (6553 bytes) INFO 15:41:14,436 Writing Memtable-Schema@186829279(2599/3248 serialized/live bytes, 3 ops) INFO 15:41:14,449 Completed flushing /var/lib/cassandra/data/system/Schema-f-1-Data.db (2749 bytes) ERROR 15:41:14,452 Fatal exception in thread Thread[MigrationStage:1,5,main] java.lang.RuntimeException: org.apache.cassandra.config.ConfigurationException: SimpleStrategy requires a replication_factor strategy option. at org.apache.cassandra.db.Table.init(Table.java:278) at org.apache.cassandra.db.Table.open(Table.java:110) at org.apache.cassandra.db.migration.AddKeyspace.applyModels(AddKeyspace.java:74) at org.apache.cassandra.db.migration.Migration.apply(Migration.java:154) at org.apache.cassandra.cql.QueryProcessor$1.call(QueryProcessor.java:339) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) at java.util.concurrent.FutureTask.run(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:680) Caused by: org.apache.cassandra.config.ConfigurationException: SimpleStrategy requires a replication_factor strategy option. at org.apache.cassandra.locator.SimpleStrategy.validateOptions(SimpleStrategy.java:79) at org.apache.cassandra.locator.AbstractReplicationStrategy.createReplicationStrategy(AbstractReplicationStrategy.java:262) at org.apache.cassandra.db.Table.createReplicationStrategy(Table.java:328) at org.apache.cassandra.db.Table.init(Table.java:274) ... 9 more INFO 15:41:37,210 Applying migration 843c7c70-6c68-11e0--242d50cf1fbf Drop keyspace: foo INFO 15:41:37,211 Enqueuing flush of Memtable-Migrations@1289702396(6372/7965 serialized/live bytes, 1 ops) INFO 15:41:37,211 Writing Memtable-Migrations@1289702396(6372/7965 serialized/live bytes, 1 ops) INFO 15:41:37,212 Enqueuing flush of Memtable-Schema@1475720401(2529/3161 serialized/live bytes, 2 ops) INFO 15:41:37,222 Completed flushing /var/lib/cassandra/data/system/Migrations-f-2-Data.db (6436 bytes) INFO 15:41:37,223 Writing Memtable-Schema@1475720401(2529/3161 serialized/live bytes, 2 ops) INFO 15:41:37,244 Completed flushing /var/lib/cassandra/data/system/Schema-f-2-Data.db (2679 bytes) The keyspace gets created anyway and I can no longer drop it, I get this message: cqlsh drop keyspace foo; Exception: TSocket read 0 bytes ERROR 15:41:37,246 Fatal exception in thread Thread[MigrationStage:1,5,main] java.lang.AssertionError at org.apache.cassandra.db.migration.DropKeyspace.applyModels(DropKeyspace.java:81) at org.apache.cassandra.db.migration.Migration.apply(Migration.java:154) at org.apache.cassandra.cql.QueryProcessor$1.call(QueryProcessor.java:339) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) at java.util.concurrent.FutureTask.run(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:680) ERROR 15:41:37,246 Thrift error occurred during processing of message. org.apache.thrift.protocol.TProtocolException: Required field 'why' was not present! Struct: InvalidRequestException(why:null) at org.apache.cassandra.thrift.InvalidRequestException.validate(InvalidRequestException.java:334) at org.apache.cassandra.thrift.InvalidRequestException.write(InvalidRequestException.java:303) at org.apache.cassandra.thrift.Cassandra$execute_cql_query_result.write(Cassandra.java:32011) at
[jira] [Issue Comment Edited] (CASSANDRA-2534) CQL: CREATE CF, DROP CF, CREATE CF caused my cluster to crash
[ https://issues.apache.org/jira/browse/CASSANDRA-2534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022963#comment-13022963 ] Cathy Daw edited comment on CASSANDRA-2534 at 4/21/11 10:46 PM: *Here is the activity on the consoles for each node* {noformat} First Node (Seed): cdaw-qa1 INFO 21:28:42,340 Completed flushing /var/lib/cassandra/data/system/Schema-f-39-Data.db (3549 bytes) INFO 21:36:53,342 Deleted /var/lib/cassandra/data/system/Schema-f-36 console was disconnected Second Node: cdaw-qa2 INFO 21:28:00,955 Completed flushing /var/lib/cassandra/data/system/Schema-f-39-Data.db (3549 bytes) console was disconnected Third Node: cdaw-qa3 INFO 21:28:37,321 Completed flushing /var/lib/cassandra/data/system/Schema-f-39-Data.db (3549 bytes) console was disconnected {noformat} *I was able to restart each node successfully * {noformat} [cassandra@cdaw-qa1 bin]$ ./nodetool -h cdaw-qa1 ring Address Status State LoadOwnsToken 113427455640312821154458202477256070484 184.106.199.149 Up Normal 319.69 KB 33.33% 0 184.106.233.230 Up Normal 323.97 KB 33.33% 56713727820156410577229101238628035242 184.106.206.193 Up Normal 323.97 KB 33.33% 113427455640312821154458202477256070484 {noformat} *From cassandra-cli, I can see the CF has been dropped* {noformat} Keyspace: cqldb: Replication Strategy: org.apache.cassandra.locator.SimpleStrategy Options: [replication_factor:2] Column Families: {noformat} *From cassandra-cli, I can do CREATE/DROP/CREATE CF successfully* {noformat} CREATE COLUMN FAMILY users with comparator = UTF8Type and column_metadata = [ {column_name: password, validation_class: UTF8Type}]; DROP COLUMN FAMILY users; CREATE COLUMN FAMILY users with comparator = UTF8Type and column_metadata = [ {column_name: password, validation_class: UTF8Type}]; {noformat} was (Author: cdaw): *Here is the activity on the consoles for each node* {noformat} First Node (Seed): cdaw-qa1 INFO 21:28:42,340 Completed flushing /var/lib/cassandra/data/system/Schema-f-39-Data.db (3549 bytes) INFO 21:36:53,342 Deleted /var/lib/cassandra/data/system/Schema-f-36 console was disconnected Second Node: cdaw-qa2 INFO 21:28:00,955 Completed flushing /var/lib/cassandra/data/system/Schema-f-39-Data.db (3549 bytes) console was disconnected Third Node: cdaw-qa3 INFO 21:28:37,321 Completed flushing /var/lib/cassandra/data/system/Schema-f-39-Data.db (3549 bytes) console was disconnected {noformat} * I was able to restart each node successfully * {noformat} [cassandra@cdaw-qa1 bin]$ ./nodetool -h cdaw-qa1 ring Address Status State LoadOwnsToken 113427455640312821154458202477256070484 184.106.199.149 Up Normal 319.69 KB 33.33% 0 184.106.233.230 Up Normal 323.97 KB 33.33% 56713727820156410577229101238628035242 184.106.206.193 Up Normal 323.97 KB 33.33% 113427455640312821154458202477256070484 {noformat} *From cassandra-cli, the CF has been dropped* {noformat} Keyspace: cqldb: Replication Strategy: org.apache.cassandra.locator.SimpleStrategy Options: [replication_factor:2] Column Families: {noformat} CQL: CREATE CF, DROP CF, CREATE CF caused my cluster to crash - Key: CASSANDRA-2534 URL: https://issues.apache.org/jira/browse/CASSANDRA-2534 Project: Cassandra Issue Type: Bug Affects Versions: 0.8.0 Reporter: Cathy Daw Priority: Critical Labels: cql The following test case of CREATE CF, DROP CF, CREATE CF caused my cluster to crash. *CREATE/DROP/CREATE CF users* {code} cqlsh CREATE COLUMNFAMILY users ( ... KEY varchar PRIMARY KEY, ... password varchar); cqlsh drop columnfamily users; cqlsh CREATE COLUMNFAMILY users ( ... userkey varchar PRIMARY KEY, ... password varchar); Exception: TSocket read 0 bytes {code} *Cassandra CLI - session broken* {code} [default@clidb] describe keyspace cqldb; java.net.SocketException: Broken pipe {code} *Nodetool - server down* {code} [cassandra@cdaw-qa1 bin]$ ./nodetool -h cdaw-qa1 -p 7199 ring Error connection to remote JMX agent! java.io.IOException: Failed to retrieve RMIServer stub: javax.naming.ServiceUnavailableException [Root exception is java.rmi.ConnectException: Connection refused to host: cdaw-qa1; nested exception is: java.net.ConnectException: Connection refused] at
[jira] [Issue Comment Edited] (CASSANDRA-2534) CQL: CREATE CF, DROP CF, CREATE CF caused my cluster to crash
[ https://issues.apache.org/jira/browse/CASSANDRA-2534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022963#comment-13022963 ] Cathy Daw edited comment on CASSANDRA-2534 at 4/21/11 10:47 PM: *I was able to restart each node successfully* {noformat} [cassandra@cdaw-qa1 bin]$ ./nodetool -h cdaw-qa1 ring Address Status State LoadOwnsToken 113427455640312821154458202477256070484 184.106.199.149 Up Normal 319.69 KB 33.33% 0 184.106.233.230 Up Normal 323.97 KB 33.33% 56713727820156410577229101238628035242 184.106.206.193 Up Normal 323.97 KB 33.33% 113427455640312821154458202477256070484 {noformat} *From cassandra-cli, I can see the CF has been dropped from the cqldb keyspace* {noformat} Keyspace: cqldb: Replication Strategy: org.apache.cassandra.locator.SimpleStrategy Options: [replication_factor:2] Column Families: {noformat} *From cassandra-cli, I can do CREATE/DROP/CREATE CF successfully from the clidb keyspace* {noformat} CREATE COLUMN FAMILY users with comparator = UTF8Type and column_metadata = [ {column_name: password, validation_class: UTF8Type}]; DROP COLUMN FAMILY users; CREATE COLUMN FAMILY users with comparator = UTF8Type and column_metadata = [ {column_name: password, validation_class: UTF8Type}]; {noformat} was (Author: cdaw): *Here is the activity on the consoles for each node* {noformat} First Node (Seed): cdaw-qa1 INFO 21:28:42,340 Completed flushing /var/lib/cassandra/data/system/Schema-f-39-Data.db (3549 bytes) INFO 21:36:53,342 Deleted /var/lib/cassandra/data/system/Schema-f-36 console was disconnected Second Node: cdaw-qa2 INFO 21:28:00,955 Completed flushing /var/lib/cassandra/data/system/Schema-f-39-Data.db (3549 bytes) console was disconnected Third Node: cdaw-qa3 INFO 21:28:37,321 Completed flushing /var/lib/cassandra/data/system/Schema-f-39-Data.db (3549 bytes) console was disconnected {noformat} *I was able to restart each node successfully * {noformat} [cassandra@cdaw-qa1 bin]$ ./nodetool -h cdaw-qa1 ring Address Status State LoadOwnsToken 113427455640312821154458202477256070484 184.106.199.149 Up Normal 319.69 KB 33.33% 0 184.106.233.230 Up Normal 323.97 KB 33.33% 56713727820156410577229101238628035242 184.106.206.193 Up Normal 323.97 KB 33.33% 113427455640312821154458202477256070484 {noformat} *From cassandra-cli, I can see the CF has been dropped* {noformat} Keyspace: cqldb: Replication Strategy: org.apache.cassandra.locator.SimpleStrategy Options: [replication_factor:2] Column Families: {noformat} *From cassandra-cli, I can do CREATE/DROP/CREATE CF successfully* {noformat} CREATE COLUMN FAMILY users with comparator = UTF8Type and column_metadata = [ {column_name: password, validation_class: UTF8Type}]; DROP COLUMN FAMILY users; CREATE COLUMN FAMILY users with comparator = UTF8Type and column_metadata = [ {column_name: password, validation_class: UTF8Type}]; {noformat} CQL: CREATE CF, DROP CF, CREATE CF caused my cluster to crash - Key: CASSANDRA-2534 URL: https://issues.apache.org/jira/browse/CASSANDRA-2534 Project: Cassandra Issue Type: Bug Affects Versions: 0.8.0 Reporter: Cathy Daw Priority: Critical Labels: cql The following test case of CREATE CF, DROP CF, CREATE CF caused my cluster to crash. *CREATE/DROP/CREATE CF users* {code} cqlsh CREATE COLUMNFAMILY users ( ... KEY varchar PRIMARY KEY, ... password varchar); cqlsh drop columnfamily users; cqlsh CREATE COLUMNFAMILY users ( ... userkey varchar PRIMARY KEY, ... password varchar); Exception: TSocket read 0 bytes {code} *Cassandra CLI - session broken* {code} [default@clidb] describe keyspace cqldb; java.net.SocketException: Broken pipe {code} *Nodetool - server down* {code} [cassandra@cdaw-qa1 bin]$ ./nodetool -h cdaw-qa1 -p 7199 ring Error connection to remote JMX agent! java.io.IOException: Failed to retrieve RMIServer stub: javax.naming.ServiceUnavailableException [Root exception is java.rmi.ConnectException: Connection refused to host: cdaw-qa1; nested exception is: java.net.ConnectException: Connection refused] at javax.management.remote.rmi.RMIConnector.connect(RMIConnector.java:342) at javax.management.remote.JMXConnectorFactory.connect(JMXConnectorFactory.java:267) at
svn commit: r1095840 - in /cassandra/branches/cassandra-0.8: CHANGES.txt src/java/org/apache/cassandra/db/ColumnFamily.java src/java/org/apache/cassandra/tools/SSTableImport.java
Author: jbellis Date: Thu Apr 21 22:48:39 2011 New Revision: 1095840 URL: http://svn.apache.org/viewvc?rev=1095840view=rev Log: fix NPE compacting index CFs patch by jbellis; reviewed by Jackson Chung for CASSANDRA-2528 Modified: cassandra/branches/cassandra-0.8/CHANGES.txt cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/db/ColumnFamily.java cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/tools/SSTableImport.java Modified: cassandra/branches/cassandra-0.8/CHANGES.txt URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/CHANGES.txt?rev=1095840r1=1095839r2=1095840view=diff == --- cassandra/branches/cassandra-0.8/CHANGES.txt (original) +++ cassandra/branches/cassandra-0.8/CHANGES.txt Thu Apr 21 22:48:39 2011 @@ -1,3 +1,7 @@ +0.8.0-? + * fix NPE compacting index CFs (CASSANDRA-2528) + + 0.8.0-beta1 * remove Avro RPC support (CASSANDRA-926) * adds support for columns that act as incr/decr counters Modified: cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/db/ColumnFamily.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/db/ColumnFamily.java?rev=1095840r1=1095839r2=1095840view=diff == --- cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/db/ColumnFamily.java (original) +++ cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/db/ColumnFamily.java Thu Apr 21 22:48:39 2011 @@ -36,7 +36,6 @@ import org.slf4j.LoggerFactory; import org.apache.cassandra.config.CFMetaData; import org.apache.cassandra.config.DatabaseDescriptor; import org.apache.cassandra.db.filter.QueryPath; -import org.apache.cassandra.db.marshal.AbstractCommutativeType; import org.apache.cassandra.db.marshal.AbstractType; import org.apache.cassandra.db.marshal.MarshalException; import org.apache.cassandra.io.IColumnSerializer; @@ -49,6 +48,7 @@ public class ColumnFamily implements ICo /* The column serializer for this Column Family. Create based on config. */ private static ColumnFamilySerializer serializer = new ColumnFamilySerializer(); +private final CFMetaData cfm; public static ColumnFamilySerializer serializer() { @@ -67,29 +67,25 @@ public class ColumnFamily implements ICo public static ColumnFamily create(CFMetaData cfm) { -assert cfm != null; -return new ColumnFamily(cfm.cfType, cfm.comparator, cfm.subcolumnComparator, cfm.cfId); +return new ColumnFamily(cfm); } -private final Integer cfid; -private final ColumnFamilyType type; - private transient IColumnSerializer columnSerializer; final AtomicLong markedForDeleteAt = new AtomicLong(Long.MIN_VALUE); final AtomicInteger localDeletionTime = new AtomicInteger(Integer.MIN_VALUE); private ConcurrentSkipListMapByteBuffer, IColumn columns; -public ColumnFamily(ColumnFamilyType type, AbstractType comparator, AbstractType subcolumnComparator, Integer cfid) +public ColumnFamily(CFMetaData cfm) { -this.type = type; -columnSerializer = type == ColumnFamilyType.Standard ? Column.serializer() : SuperColumn.serializer(subcolumnComparator); -columns = new ConcurrentSkipListMapByteBuffer, IColumn(comparator); -this.cfid = cfid; +assert cfm != null; +this.cfm = cfm; +columnSerializer = cfm.cfType == ColumnFamilyType.Standard ? Column.serializer() : SuperColumn.serializer(cfm.subcolumnComparator); +columns = new ConcurrentSkipListMapByteBuffer, IColumn(cfm.comparator); } public ColumnFamily cloneMeShallow() { -ColumnFamily cf = new ColumnFamily(type, getComparator(), getSubComparator(), cfid); +ColumnFamily cf = new ColumnFamily(cfm); cf.markedForDeleteAt.set(markedForDeleteAt.get()); cf.localDeletionTime.set(localDeletionTime.get()); return cf; @@ -100,9 +96,9 @@ public class ColumnFamily implements ICo return (columnSerializer instanceof SuperColumnSerializer) ? ((SuperColumnSerializer)columnSerializer).getComparator() : null; } -public ColumnFamilyType getColumnFamilyType() +public ColumnFamilyType getType() { -return type; +return cfm.cfType; } public ColumnFamily cloneMe() @@ -114,15 +110,15 @@ public class ColumnFamily implements ICo public Integer id() { -return cfid; +return cfm.cfId; } /** - * @return The CFMetaData for this row, or null if the column family was dropped. + * @return The CFMetaData for this row */ public CFMetaData metadata() { -return DatabaseDescriptor.getCFMetaData(cfid); +return cfm; } /* @@ -148,7 +144,7 @@ public class ColumnFamily implements ICo public
[jira] [Updated] (CASSANDRA-2535) CQL create keyspace throws exceptions
[ https://issues.apache.org/jira/browse/CASSANDRA-2535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Goffinet updated CASSANDRA-2535: -- Affects Version/s: 0.8 beta 1 CQL create keyspace throws exceptions - Key: CASSANDRA-2535 URL: https://issues.apache.org/jira/browse/CASSANDRA-2535 Project: Cassandra Issue Type: Bug Affects Versions: 0.8 beta 1 Reporter: Chris Goffinet Labels: CQL Was trying out CQL: cqlsh create keyspace foo with replication_factor=1 and strategy_class='org.apache.cassandra.locator.SimpleStrategy'; Bad Request: org.apache.cassandra.config.ConfigurationException: SimpleStrategy requires a replication_factor strategy option. On Cassandra side: INFO 15:41:14,423 Applying migration 768b63c0-6c68-11e0--242d50cf1fbf Add keyspace: foorep strategy:SimpleStrategy{} INFO 15:41:14,424 Enqueuing flush of Memtable-Migrations@17649447(6489/8111 serialized/live bytes, 1 ops) INFO 15:41:14,425 Enqueuing flush of Memtable-Schema@186829279(2599/3248 serialized/live bytes, 3 ops) INFO 15:41:14,425 Writing Memtable-Migrations@17649447(6489/8111 serialized/live bytes, 1 ops) INFO 15:41:14,435 Completed flushing /var/lib/cassandra/data/system/Migrations-f-1-Data.db (6553 bytes) INFO 15:41:14,436 Writing Memtable-Schema@186829279(2599/3248 serialized/live bytes, 3 ops) INFO 15:41:14,449 Completed flushing /var/lib/cassandra/data/system/Schema-f-1-Data.db (2749 bytes) ERROR 15:41:14,452 Fatal exception in thread Thread[MigrationStage:1,5,main] java.lang.RuntimeException: org.apache.cassandra.config.ConfigurationException: SimpleStrategy requires a replication_factor strategy option. at org.apache.cassandra.db.Table.init(Table.java:278) at org.apache.cassandra.db.Table.open(Table.java:110) at org.apache.cassandra.db.migration.AddKeyspace.applyModels(AddKeyspace.java:74) at org.apache.cassandra.db.migration.Migration.apply(Migration.java:154) at org.apache.cassandra.cql.QueryProcessor$1.call(QueryProcessor.java:339) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) at java.util.concurrent.FutureTask.run(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:680) Caused by: org.apache.cassandra.config.ConfigurationException: SimpleStrategy requires a replication_factor strategy option. at org.apache.cassandra.locator.SimpleStrategy.validateOptions(SimpleStrategy.java:79) at org.apache.cassandra.locator.AbstractReplicationStrategy.createReplicationStrategy(AbstractReplicationStrategy.java:262) at org.apache.cassandra.db.Table.createReplicationStrategy(Table.java:328) at org.apache.cassandra.db.Table.init(Table.java:274) ... 9 more INFO 15:41:37,210 Applying migration 843c7c70-6c68-11e0--242d50cf1fbf Drop keyspace: foo INFO 15:41:37,211 Enqueuing flush of Memtable-Migrations@1289702396(6372/7965 serialized/live bytes, 1 ops) INFO 15:41:37,211 Writing Memtable-Migrations@1289702396(6372/7965 serialized/live bytes, 1 ops) INFO 15:41:37,212 Enqueuing flush of Memtable-Schema@1475720401(2529/3161 serialized/live bytes, 2 ops) INFO 15:41:37,222 Completed flushing /var/lib/cassandra/data/system/Migrations-f-2-Data.db (6436 bytes) INFO 15:41:37,223 Writing Memtable-Schema@1475720401(2529/3161 serialized/live bytes, 2 ops) INFO 15:41:37,244 Completed flushing /var/lib/cassandra/data/system/Schema-f-2-Data.db (2679 bytes) The keyspace gets created anyway and I can no longer drop it, I get this message: cqlsh drop keyspace foo; Exception: TSocket read 0 bytes ERROR 15:41:37,246 Fatal exception in thread Thread[MigrationStage:1,5,main] java.lang.AssertionError at org.apache.cassandra.db.migration.DropKeyspace.applyModels(DropKeyspace.java:81) at org.apache.cassandra.db.migration.Migration.apply(Migration.java:154) at org.apache.cassandra.cql.QueryProcessor$1.call(QueryProcessor.java:339) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) at java.util.concurrent.FutureTask.run(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:680) ERROR 15:41:37,246 Thrift error occurred during processing of message. org.apache.thrift.protocol.TProtocolException: Required field 'why' was not present! Struct: InvalidRequestException(why:null) at
[jira] [Resolved] (CASSANDRA-2535) CQL create keyspace throws exceptions
[ https://issues.apache.org/jira/browse/CASSANDRA-2535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis resolved CASSANDRA-2535. --- Resolution: Duplicate CASSANDRA-2525 CQL create keyspace throws exceptions - Key: CASSANDRA-2535 URL: https://issues.apache.org/jira/browse/CASSANDRA-2535 Project: Cassandra Issue Type: Bug Affects Versions: 0.8 beta 1 Reporter: Chris Goffinet Labels: CQL Was trying out CQL: cqlsh create keyspace foo with replication_factor=1 and strategy_class='org.apache.cassandra.locator.SimpleStrategy'; Bad Request: org.apache.cassandra.config.ConfigurationException: SimpleStrategy requires a replication_factor strategy option. On Cassandra side: INFO 15:41:14,423 Applying migration 768b63c0-6c68-11e0--242d50cf1fbf Add keyspace: foorep strategy:SimpleStrategy{} INFO 15:41:14,424 Enqueuing flush of Memtable-Migrations@17649447(6489/8111 serialized/live bytes, 1 ops) INFO 15:41:14,425 Enqueuing flush of Memtable-Schema@186829279(2599/3248 serialized/live bytes, 3 ops) INFO 15:41:14,425 Writing Memtable-Migrations@17649447(6489/8111 serialized/live bytes, 1 ops) INFO 15:41:14,435 Completed flushing /var/lib/cassandra/data/system/Migrations-f-1-Data.db (6553 bytes) INFO 15:41:14,436 Writing Memtable-Schema@186829279(2599/3248 serialized/live bytes, 3 ops) INFO 15:41:14,449 Completed flushing /var/lib/cassandra/data/system/Schema-f-1-Data.db (2749 bytes) ERROR 15:41:14,452 Fatal exception in thread Thread[MigrationStage:1,5,main] java.lang.RuntimeException: org.apache.cassandra.config.ConfigurationException: SimpleStrategy requires a replication_factor strategy option. at org.apache.cassandra.db.Table.init(Table.java:278) at org.apache.cassandra.db.Table.open(Table.java:110) at org.apache.cassandra.db.migration.AddKeyspace.applyModels(AddKeyspace.java:74) at org.apache.cassandra.db.migration.Migration.apply(Migration.java:154) at org.apache.cassandra.cql.QueryProcessor$1.call(QueryProcessor.java:339) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) at java.util.concurrent.FutureTask.run(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:680) Caused by: org.apache.cassandra.config.ConfigurationException: SimpleStrategy requires a replication_factor strategy option. at org.apache.cassandra.locator.SimpleStrategy.validateOptions(SimpleStrategy.java:79) at org.apache.cassandra.locator.AbstractReplicationStrategy.createReplicationStrategy(AbstractReplicationStrategy.java:262) at org.apache.cassandra.db.Table.createReplicationStrategy(Table.java:328) at org.apache.cassandra.db.Table.init(Table.java:274) ... 9 more INFO 15:41:37,210 Applying migration 843c7c70-6c68-11e0--242d50cf1fbf Drop keyspace: foo INFO 15:41:37,211 Enqueuing flush of Memtable-Migrations@1289702396(6372/7965 serialized/live bytes, 1 ops) INFO 15:41:37,211 Writing Memtable-Migrations@1289702396(6372/7965 serialized/live bytes, 1 ops) INFO 15:41:37,212 Enqueuing flush of Memtable-Schema@1475720401(2529/3161 serialized/live bytes, 2 ops) INFO 15:41:37,222 Completed flushing /var/lib/cassandra/data/system/Migrations-f-2-Data.db (6436 bytes) INFO 15:41:37,223 Writing Memtable-Schema@1475720401(2529/3161 serialized/live bytes, 2 ops) INFO 15:41:37,244 Completed flushing /var/lib/cassandra/data/system/Schema-f-2-Data.db (2679 bytes) The keyspace gets created anyway and I can no longer drop it, I get this message: cqlsh drop keyspace foo; Exception: TSocket read 0 bytes ERROR 15:41:37,246 Fatal exception in thread Thread[MigrationStage:1,5,main] java.lang.AssertionError at org.apache.cassandra.db.migration.DropKeyspace.applyModels(DropKeyspace.java:81) at org.apache.cassandra.db.migration.Migration.apply(Migration.java:154) at org.apache.cassandra.cql.QueryProcessor$1.call(QueryProcessor.java:339) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) at java.util.concurrent.FutureTask.run(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:680) ERROR 15:41:37,246 Thrift error occurred during processing of message. org.apache.thrift.protocol.TProtocolException: Required field 'why' was not present! Struct: InvalidRequestException(why:null) at
[jira] [Updated] (CASSANDRA-2532) Log read timeouts at the StorageProxy level
[ https://issues.apache.org/jira/browse/CASSANDRA-2532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stu Hood updated CASSANDRA-2532: Attachment: 0003-Log-write-timeouts-in-SP.txt Log read timeouts at the StorageProxy level --- Key: CASSANDRA-2532 URL: https://issues.apache.org/jira/browse/CASSANDRA-2532 Project: Cassandra Issue Type: Bug Reporter: Stu Hood Fix For: 0.8.0 Attachments: 0001-Log-timeouts-in-SP.txt, 0002-Remove-useless-timeout-entries-in-thrift.CS.txt, 0003-Log-write-timeouts-in-SP.txt We log successful reads, but not timeouts (although we have a lovely TimeoutException message, it doesn't look like we are printing it). -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2532) Log read timeouts at the StorageProxy level
[ https://issues.apache.org/jira/browse/CASSANDRA-2532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022970#comment-13022970 ] Stu Hood commented on CASSANDRA-2532: - Done in 0003 Log read timeouts at the StorageProxy level --- Key: CASSANDRA-2532 URL: https://issues.apache.org/jira/browse/CASSANDRA-2532 Project: Cassandra Issue Type: Bug Reporter: Stu Hood Fix For: 0.8.0 Attachments: 0001-Log-timeouts-in-SP.txt, 0002-Remove-useless-timeout-entries-in-thrift.CS.txt, 0003-Log-write-timeouts-in-SP.txt We log successful reads, but not timeouts (although we have a lovely TimeoutException message, it doesn't look like we are printing it). -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Created] (CASSANDRA-2536) Schema disagreements when using connections to multiple hosts
Schema disagreements when using connections to multiple hosts - Key: CASSANDRA-2536 URL: https://issues.apache.org/jira/browse/CASSANDRA-2536 Project: Cassandra Issue Type: Bug Components: Core Affects Versions: 0.8 beta 1 Environment: Two node 0.8-beta1 cluster with one seed and JNA. Reporter: Tyler Hobbs Attachments: schema_disagree.py If you have two thrift connections open to different nodes and you create a KS using the first, then a CF in that KS using the second, you wind up with a schema disagreement even if you wait/sleep after creating the KS. The attached script reproduces the issue using pycassa (1.0.6 should work fine, although it has the 0.7 thrift-gen code). It's also reproducible by hand with two cassandra-cli sessions. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2536) Schema disagreements when using connections to multiple hosts
[ https://issues.apache.org/jira/browse/CASSANDRA-2536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tyler Hobbs updated CASSANDRA-2536: --- Attachment: schema_disagree.py Schema disagreements when using connections to multiple hosts - Key: CASSANDRA-2536 URL: https://issues.apache.org/jira/browse/CASSANDRA-2536 Project: Cassandra Issue Type: Bug Components: Core Affects Versions: 0.8 beta 1 Environment: Two node 0.8-beta1 cluster with one seed and JNA. Reporter: Tyler Hobbs Attachments: schema_disagree.py If you have two thrift connections open to different nodes and you create a KS using the first, then a CF in that KS using the second, you wind up with a schema disagreement even if you wait/sleep after creating the KS. The attached script reproduces the issue using pycassa (1.0.6 should work fine, although it has the 0.7 thrift-gen code). It's also reproducible by hand with two cassandra-cli sessions. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2534) CQL: CREATE CF, DROP CF, CREATE CF caused my cluster to crash
[ https://issues.apache.org/jira/browse/CASSANDRA-2534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022971#comment-13022971 ] Cathy Daw commented on CASSANDRA-2534: -- After restart, I can recreate the table successfully via cqlsh. CQL: CREATE CF, DROP CF, CREATE CF caused my cluster to crash - Key: CASSANDRA-2534 URL: https://issues.apache.org/jira/browse/CASSANDRA-2534 Project: Cassandra Issue Type: Bug Affects Versions: 0.8.0 Reporter: Cathy Daw Priority: Critical Labels: cql The following test case of CREATE CF, DROP CF, CREATE CF caused my cluster to crash. *CREATE/DROP/CREATE CF users* {code} cqlsh CREATE COLUMNFAMILY users ( ... KEY varchar PRIMARY KEY, ... password varchar); cqlsh drop columnfamily users; cqlsh CREATE COLUMNFAMILY users ( ... userkey varchar PRIMARY KEY, ... password varchar); Exception: TSocket read 0 bytes {code} *Cassandra CLI - session broken* {code} [default@clidb] describe keyspace cqldb; java.net.SocketException: Broken pipe {code} *Nodetool - server down* {code} [cassandra@cdaw-qa1 bin]$ ./nodetool -h cdaw-qa1 -p 7199 ring Error connection to remote JMX agent! java.io.IOException: Failed to retrieve RMIServer stub: javax.naming.ServiceUnavailableException [Root exception is java.rmi.ConnectException: Connection refused to host: cdaw-qa1; nested exception is: java.net.ConnectException: Connection refused] at javax.management.remote.rmi.RMIConnector.connect(RMIConnector.java:342) at javax.management.remote.JMXConnectorFactory.connect(JMXConnectorFactory.java:267) at org.apache.cassandra.tools.NodeProbe.connect(NodeProbe.java:139) at org.apache.cassandra.tools.NodeProbe.init(NodeProbe.java:109) at org.apache.cassandra.tools.NodeCmd.main(NodeCmd.java:525) Caused by: javax.naming.ServiceUnavailableException [Root exception is java.rmi.ConnectException: Connection refused to host: cdaw-qa1; nested exception is: java.net.ConnectException: Connection refused] at com.sun.jndi.rmi.registry.RegistryContext.lookup(RegistryContext.java:118) at com.sun.jndi.toolkit.url.GenericURLContext.lookup(GenericURLContext.java:203) at javax.naming.InitialContext.lookup(InitialContext.java:409) at javax.management.remote.rmi.RMIConnector.findRMIServerJNDI(RMIConnector.java:1902) at javax.management.remote.rmi.RMIConnector.findRMIServer(RMIConnector.java:1871) at javax.management.remote.rmi.RMIConnector.connect(RMIConnector.java:276) ... 4 more Caused by: java.rmi.ConnectException: Connection refused to host: cdaw-qa1; nested exception is: java.net.ConnectException: Connection refused at sun.rmi.transport.tcp.TCPEndpoint.newSocket(TCPEndpoint.java:619) at sun.rmi.transport.tcp.TCPChannel.createConnection(TCPChannel.java:216) at sun.rmi.transport.tcp.TCPChannel.newConnection(TCPChannel.java:202) at sun.rmi.server.UnicastRef.newCall(UnicastRef.java:340) at sun.rmi.registry.RegistryImpl_Stub.lookup(Unknown Source) at com.sun.jndi.rmi.registry.RegistryContext.lookup(RegistryContext.java:114) ... 9 more Caused by: java.net.ConnectException: Connection refused at java.net.PlainSocketImpl.socketConnect(Native Method) at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:310) at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:176) at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:163) at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:384) at java.net.Socket.connect(Socket.java:546) at java.net.Socket.connect(Socket.java:495) at java.net.Socket.init(Socket.java:392) at java.net.Socket.init(Socket.java:206) at sun.rmi.transport.proxy.RMIDirectSocketFactory.createSocket(RMIDirectSocketFactory.java:40) at sun.rmi.transport.proxy.RMIMasterSocketFactory.createSocket(RMIMasterSocketFactory.java:146) at sun.rmi.transport.tcp.TCPEndpoint.newSocket(TCPEndpoint.java:613) ... 14 more {code} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2444) An option to disable compaction on startup
[ https://issues.apache.org/jira/browse/CASSANDRA-2444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Goffinet updated CASSANDRA-2444: -- Fix Version/s: 0.8.1 An option to disable compaction on startup -- Key: CASSANDRA-2444 URL: https://issues.apache.org/jira/browse/CASSANDRA-2444 Project: Cassandra Issue Type: Bug Reporter: Chris Goffinet Assignee: Chris Goffinet Priority: Minor Labels: compaction Fix For: 0.8.1 We've ran into many times where we do not want compaction to run right away against CFs when booting up a node. I propose we make that an option in the config, so operators do not have to take the penalty of compacting right away, and can return the node as close to working state as possible. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Assigned] (CASSANDRA-2444) An option to disable compaction on startup
[ https://issues.apache.org/jira/browse/CASSANDRA-2444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Goffinet reassigned CASSANDRA-2444: - Assignee: Chris Goffinet An option to disable compaction on startup -- Key: CASSANDRA-2444 URL: https://issues.apache.org/jira/browse/CASSANDRA-2444 Project: Cassandra Issue Type: Bug Reporter: Chris Goffinet Assignee: Chris Goffinet Priority: Minor Labels: compaction Fix For: 0.8.1 We've ran into many times where we do not want compaction to run right away against CFs when booting up a node. I propose we make that an option in the config, so operators do not have to take the penalty of compacting right away, and can return the node as close to working state as possible. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Created] (CASSANDRA-2537) CQL: Error performing batch insert
CQL: Error performing batch insert -- Key: CASSANDRA-2537 URL: https://issues.apache.org/jira/browse/CASSANDRA-2537 Project: Cassandra Issue Type: Bug Affects Versions: 0.8.0 Environment: 3-node Centos 5.5 cluster running 0.8 build from apr20. Reporter: Cathy Daw *Test Case To Run* {code} // Setup CREATE COLUMNFAMILY users ( KEY varchar PRIMARY KEY, password varchar); //Batch Insert BEGIN BATCH USING QUORUM INSERT INTO users (KEY, password) VALUES ('user2', 'ch@ngem3b'); INSERT INTO users (KEY, password) VALUES ('user3', 'ch@ngem3c'); APPLY BATCH {code} *Actual Behavior* {code} cqlsh BEGIN BATCH USING QUORUM ... INSERT INTO users (KEY, password) VALUES ('user2', 'ch@ngem3b'); Bad Request: line 0:-1 mismatched input 'EOF' expecting K_APPLY {code} *Documentation Sample* {code} BEGIN BATCH [USING CONSISTENCY] UPDATE CF1 SET name1 = value1, name2 = value2 WHERE KEY = keyname1; UPDATE CF1 SET name3 = value3 WHERE KEY = keyname2; UPDATE CF2 SET name4 = value4, name5 = value5 WHERE KEY = keyname3; APPLY BATCH {code} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2444) An option to disable compaction on startup
[ https://issues.apache.org/jira/browse/CASSANDRA-2444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Goffinet updated CASSANDRA-2444: -- Attachment: 0001-CASSANDRA-2444-Provide-an-option-to-enable-disable-c.patch An option to disable compaction on startup -- Key: CASSANDRA-2444 URL: https://issues.apache.org/jira/browse/CASSANDRA-2444 Project: Cassandra Issue Type: Bug Reporter: Chris Goffinet Assignee: Chris Goffinet Priority: Minor Labels: compaction Fix For: 0.8.1 Attachments: 0001-CASSANDRA-2444-Provide-an-option-to-enable-disable-c.patch We've ran into many times where we do not want compaction to run right away against CFs when booting up a node. I propose we make that an option in the config, so operators do not have to take the penalty of compacting right away, and can return the node as close to working state as possible. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2528) NPE from PrecompactedRow
[ https://issues.apache.org/jira/browse/CASSANDRA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022977#comment-13022977 ] Hudson commented on CASSANDRA-2528: --- Integrated in Cassandra-0.8 #32 (See [https://builds.apache.org/hudson/job/Cassandra-0.8/32/]) fix NPE compacting index CFs patch by jbellis; reviewed by Jackson Chung for CASSANDRA-2528 NPE from PrecompactedRow Key: CASSANDRA-2528 URL: https://issues.apache.org/jira/browse/CASSANDRA-2528 Project: Cassandra Issue Type: Bug Affects Versions: 0.8 beta 1 Reporter: Jackson Chung Assignee: Jonathan Ellis Fix For: 0.8.0 Attachments: 2528.txt, 2528.txt received a NPE from trunk (0.8) on PrecompactedRow: ERROR [CompactionExecutor:2] 2011-04-21 17:21:31,610 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[CompactionExecutor:2,1,main] java.lang.NullPointerException at org.apache.cassandra.io.PrecompactedRow.init(PrecompactedRow.java:86) at org.apache.cassandra.io.CompactionIterator.getCompactedRow(CompactionIterator.java:167) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:124) at org.apache.cassandra.io.CompactionIterator.getReduced(CompactionIterator.java:44) at org.apache.cassandra.utils.ReducingIterator.computeNext(ReducingIterator.java:74) at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:140) at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:135) at org.apache.commons.collections.iterators.FilterIterator.setNextObject(FilterIterator.java:183) at org.apache.commons.collections.iterators.FilterIterator.hasNext(FilterIterator.java:94) at org.apache.cassandra.db.CompactionManager.doCompaction(CompactionManager.java:553) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:146) at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:112) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) at java.util.concurrent.FutureTask.run(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:662) size of data in /var/lib/cassandra is 11G on this, but there is also report that 1.7G also see the same. data was previously populated from 0.7.4 cassandra added debug logging, not sure how much this help (this is logged before the exception.) INFO [CompactionExecutor:2] 2011-04-21 17:21:31,588 CompactionManager.java (line 534) Compacting Major: [SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-10-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-7-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-6-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-8-Data.db'), SSTableReader(path='/var/lib/cassandra/data/cfs/inode.path-f-9-Data.db')] DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-10-Data.db : 256 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-7-Data.db : 512 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,588 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-6-Data.db : 768 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,589 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-8-Data.db : 1024 DEBUG [CompactionExecutor:2] 2011-04-21 17:21:31,589 SSTableReader.java (line 132) index size for bloom filter calc for file : /var/lib/cassandra/data/cfs/inode.path-f-9-Data.db : 1280 INFO [CompactionExecutor:2] 2011-04-21 17:21:31,609 CompactionIterator.java (line 185) Major@1181554512(cfs, inode.path, 523/10895) now compacting at 16777 bytes/ms. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2536) Schema disagreements when using connections to multiple hosts
[ https://issues.apache.org/jira/browse/CASSANDRA-2536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022978#comment-13022978 ] Mike Bulman commented on CASSANDRA-2536: I feel like a better, more critical sounding explanation, is: create a keyspace on node1, create a cf in that keyspace on node2 = hang + schema disagreement. Schema disagreements when using connections to multiple hosts - Key: CASSANDRA-2536 URL: https://issues.apache.org/jira/browse/CASSANDRA-2536 Project: Cassandra Issue Type: Bug Components: Core Affects Versions: 0.8 beta 1 Environment: Two node 0.8-beta1 cluster with one seed and JNA. Reporter: Tyler Hobbs Attachments: schema_disagree.py If you have two thrift connections open to different nodes and you create a KS using the first, then a CF in that KS using the second, you wind up with a schema disagreement even if you wait/sleep after creating the KS. The attached script reproduces the issue using pycassa (1.0.6 should work fine, although it has the 0.7 thrift-gen code). It's also reproducible by hand with two cassandra-cli sessions. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2444) An option to disable compaction on startup
[ https://issues.apache.org/jira/browse/CASSANDRA-2444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13022981#comment-13022981 ] Stu Hood commented on CASSANDRA-2444: - Rather than adding an option for this, I think we should remove the check entirely. If the node needs to compact, it will do so at the first flush, which is more likely to be staggered across the cluster (and if this flush is forced by commitlogs, then AOK). An option to disable compaction on startup -- Key: CASSANDRA-2444 URL: https://issues.apache.org/jira/browse/CASSANDRA-2444 Project: Cassandra Issue Type: Bug Reporter: Chris Goffinet Assignee: Chris Goffinet Priority: Minor Labels: compaction Fix For: 0.8.1 Attachments: 0001-CASSANDRA-2444-Provide-an-option-to-enable-disable-c.patch We've ran into many times where we do not want compaction to run right away against CFs when booting up a node. I propose we make that an option in the config, so operators do not have to take the penalty of compacting right away, and can return the node as close to working state as possible. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Created] (CASSANDRA-2538) CQL: NPE running SELECT with an IN clause
CQL: NPE running SELECT with an IN clause - Key: CASSANDRA-2538 URL: https://issues.apache.org/jira/browse/CASSANDRA-2538 Project: Cassandra Issue Type: Bug Affects Versions: 0.8.0 Reporter: Cathy Daw *Test Case to Run* {noformat} cqlsh select * from users where key in ('user2', 'user3'); Internal application error {noformat} *Test Setup* {noformat} CREATE COLUMNFAMILY users ( KEY varchar PRIMARY KEY, password varchar); INSERT INTO users (KEY, password) VALUES ('user1', 'ch@ngem3a'); {noformat} *Log Files* {noformat} ERROR [RequestResponseStage:17] 2011-04-21 23:36:41,600 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[RequestResponseStage:17,5,main] java.lang.AssertionError at org.apache.cassandra.service.ReadCallback.response(ReadCallback.java:127) at org.apache.cassandra.net.ResponseVerbHandler.doVerb(ResponseVerbHandler.java:49) at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:72) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) ERROR [RequestResponseStage:17] 2011-04-21 23:36:41,600 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[RequestResponseStage:17,5,main] java.lang.AssertionError at org.apache.cassandra.service.ReadCallback.response(ReadCallback.java:127) at org.apache.cassandra.net.ResponseVerbHandler.doVerb(ResponseVerbHandler.java:49) at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:72) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) ERROR [pool-2-thread-5] 2011-04-21 23:37:12,026 Cassandra.java (line 4082) Internal error processing execute_cql_query java.lang.NullPointerException at org.apache.cassandra.cql.WhereClause.and(WhereClause.java:59) at org.apache.cassandra.cql.WhereClause.init(WhereClause.java:44) at org.apache.cassandra.cql.CqlParser.whereClause(CqlParser.java:816) at org.apache.cassandra.cql.CqlParser.selectStatement(CqlParser.java:502) at org.apache.cassandra.cql.CqlParser.query(CqlParser.java:191) at org.apache.cassandra.cql.QueryProcessor.getStatement(QueryProcessor.java:834) at org.apache.cassandra.cql.QueryProcessor.process(QueryProcessor.java:463) at org.apache.cassandra.thrift.CassandraServer.execute_cql_query(CassandraServer.java:1134) at org.apache.cassandra.thrift.Cassandra$Processor$execute_cql_query.process(Cassandra.java:4072) at org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:2889) at org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:187) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) {noformat} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2538) CQL: NPE running SELECT with an IN clause
[ https://issues.apache.org/jira/browse/CASSANDRA-2538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13023038#comment-13023038 ] Cathy Daw commented on CASSANDRA-2538: -- After running this test case, 2 of my 3 nodes went down. The seed node was still up. CQL: NPE running SELECT with an IN clause - Key: CASSANDRA-2538 URL: https://issues.apache.org/jira/browse/CASSANDRA-2538 Project: Cassandra Issue Type: Bug Affects Versions: 0.8.0 Reporter: Cathy Daw Labels: cql *Test Case to Run* {noformat} cqlsh select * from users where key in ('user2', 'user3'); Internal application error {noformat} *Test Setup* {noformat} CREATE COLUMNFAMILY users ( KEY varchar PRIMARY KEY, password varchar); INSERT INTO users (KEY, password) VALUES ('user1', 'ch@ngem3a'); {noformat} *Log Files* {noformat} ERROR [RequestResponseStage:17] 2011-04-21 23:36:41,600 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[RequestResponseStage:17,5,main] java.lang.AssertionError at org.apache.cassandra.service.ReadCallback.response(ReadCallback.java:127) at org.apache.cassandra.net.ResponseVerbHandler.doVerb(ResponseVerbHandler.java:49) at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:72) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) ERROR [RequestResponseStage:17] 2011-04-21 23:36:41,600 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[RequestResponseStage:17,5,main] java.lang.AssertionError at org.apache.cassandra.service.ReadCallback.response(ReadCallback.java:127) at org.apache.cassandra.net.ResponseVerbHandler.doVerb(ResponseVerbHandler.java:49) at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:72) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) ERROR [pool-2-thread-5] 2011-04-21 23:37:12,026 Cassandra.java (line 4082) Internal error processing execute_cql_query java.lang.NullPointerException at org.apache.cassandra.cql.WhereClause.and(WhereClause.java:59) at org.apache.cassandra.cql.WhereClause.init(WhereClause.java:44) at org.apache.cassandra.cql.CqlParser.whereClause(CqlParser.java:816) at org.apache.cassandra.cql.CqlParser.selectStatement(CqlParser.java:502) at org.apache.cassandra.cql.CqlParser.query(CqlParser.java:191) at org.apache.cassandra.cql.QueryProcessor.getStatement(QueryProcessor.java:834) at org.apache.cassandra.cql.QueryProcessor.process(QueryProcessor.java:463) at org.apache.cassandra.thrift.CassandraServer.execute_cql_query(CassandraServer.java:1134) at org.apache.cassandra.thrift.Cassandra$Processor$execute_cql_query.process(Cassandra.java:4072) at org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:2889) at org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:187) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) {noformat} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Created] (CASSANDRA-2539) CQL: cqlsh does shows Exception, but not error message when running truncate while a node is down.
CQL: cqlsh does shows Exception, but not error message when running truncate while a node is down. --- Key: CASSANDRA-2539 URL: https://issues.apache.org/jira/browse/CASSANDRA-2539 Project: Cassandra Issue Type: Bug Affects Versions: 0.8.0 Reporter: Cathy Daw Priority: Trivial This is really just a usability bug, but it would nice to bubble the error message that is printed in the log file up to the interface. *cqlsh output* {noformat} cqlsh truncate users; Exception: UnavailableException() {noformat} *log file error* {noformat} INFO [pool-2-thread-5] 2011-04-21 23:53:30,466 StorageProxy.java (line 1021) Cannot perform truncate, some hosts are down {noformat} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2538) CQL: NPE running SELECT with an IN clause
[ https://issues.apache.org/jira/browse/CASSANDRA-2538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cathy Daw updated CASSANDRA-2538: - Comment: was deleted (was: After running this test case, 2 of my 3 nodes went down. The seed node was still up.) CQL: NPE running SELECT with an IN clause - Key: CASSANDRA-2538 URL: https://issues.apache.org/jira/browse/CASSANDRA-2538 Project: Cassandra Issue Type: Bug Affects Versions: 0.8.0 Reporter: Cathy Daw Labels: cql *Test Case to Run* {noformat} cqlsh select * from users where key in ('user2', 'user3'); Internal application error {noformat} *Test Setup* {noformat} CREATE COLUMNFAMILY users ( KEY varchar PRIMARY KEY, password varchar); INSERT INTO users (KEY, password) VALUES ('user1', 'ch@ngem3a'); {noformat} *Log Files* {noformat} ERROR [RequestResponseStage:17] 2011-04-21 23:36:41,600 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[RequestResponseStage:17,5,main] java.lang.AssertionError at org.apache.cassandra.service.ReadCallback.response(ReadCallback.java:127) at org.apache.cassandra.net.ResponseVerbHandler.doVerb(ResponseVerbHandler.java:49) at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:72) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) ERROR [RequestResponseStage:17] 2011-04-21 23:36:41,600 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[RequestResponseStage:17,5,main] java.lang.AssertionError at org.apache.cassandra.service.ReadCallback.response(ReadCallback.java:127) at org.apache.cassandra.net.ResponseVerbHandler.doVerb(ResponseVerbHandler.java:49) at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:72) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) ERROR [pool-2-thread-5] 2011-04-21 23:37:12,026 Cassandra.java (line 4082) Internal error processing execute_cql_query java.lang.NullPointerException at org.apache.cassandra.cql.WhereClause.and(WhereClause.java:59) at org.apache.cassandra.cql.WhereClause.init(WhereClause.java:44) at org.apache.cassandra.cql.CqlParser.whereClause(CqlParser.java:816) at org.apache.cassandra.cql.CqlParser.selectStatement(CqlParser.java:502) at org.apache.cassandra.cql.CqlParser.query(CqlParser.java:191) at org.apache.cassandra.cql.QueryProcessor.getStatement(QueryProcessor.java:834) at org.apache.cassandra.cql.QueryProcessor.process(QueryProcessor.java:463) at org.apache.cassandra.thrift.CassandraServer.execute_cql_query(CassandraServer.java:1134) at org.apache.cassandra.thrift.Cassandra$Processor$execute_cql_query.process(Cassandra.java:4072) at org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:2889) at org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:187) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) {noformat} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[Cassandra Wiki] Update of Operations_JP by MakiWatanabe
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The Operations_JP page has been changed by MakiWatanabe. http://wiki.apache.org/cassandra/Operations_JP?action=diffrev1=106rev2=107 -- `nodetool loadbalance`は指定ノードに対してトークン選択の項で説明した自動トークン選択ルールに基づいて新たなトークンを決定し、decomissionとbootstrapを実行するコマンドです。このコマンドではリング全体の負荷均等化は行えません。 - 移動やデータ格納量の均等化状況は`nodetool`に`streams`引数を与えることで監視できます。 + 移動やデータ格納量の均等化状況はnodetoolのnetstats引数(0.7以降)またはstreams 引数(Cassandra 0.6)で監視できます。 == 整合性 == Cassandraではreadやwriteにおいて必要な整合性レベルをクライアントが指定できます([[API]]参照)。R、W、Nがそれぞれ読み出したレプリカ数、書き込んだレプリカ数、レプリケーションファクターを示すとすると、R + W N であればすべての read は最新の write を読むことができます。この条件を満たさない場合、タイミングによっては read は古いデータを返すかもしれません。これは結果整合性evantual consistencyと呼ばれています。
[jira] [Assigned] (CASSANDRA-2536) Schema disagreements when using connections to multiple hosts
[ https://issues.apache.org/jira/browse/CASSANDRA-2536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis reassigned CASSANDRA-2536: - Assignee: Gary Dusbabek And this is fine in 0.7? Schema disagreements when using connections to multiple hosts - Key: CASSANDRA-2536 URL: https://issues.apache.org/jira/browse/CASSANDRA-2536 Project: Cassandra Issue Type: Bug Components: Core Affects Versions: 0.8 beta 1 Environment: Two node 0.8-beta1 cluster with one seed and JNA. Reporter: Tyler Hobbs Assignee: Gary Dusbabek Attachments: schema_disagree.py If you have two thrift connections open to different nodes and you create a KS using the first, then a CF in that KS using the second, you wind up with a schema disagreement even if you wait/sleep after creating the KS. The attached script reproduces the issue using pycassa (1.0.6 should work fine, although it has the 0.7 thrift-gen code). It's also reproducible by hand with two cassandra-cli sessions. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2538) CQL: NPE running SELECT with an IN clause
[ https://issues.apache.org/jira/browse/CASSANDRA-2538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis updated CASSANDRA-2538: -- Priority: Minor (was: Major) Affects Version/s: (was: 0.8.0) 0.8 beta 1 Fix Version/s: 0.8.0 Assignee: Eric Evans Eric, can you make it so CQL is more clear about not supporting IN, without internal errors? CQL: NPE running SELECT with an IN clause - Key: CASSANDRA-2538 URL: https://issues.apache.org/jira/browse/CASSANDRA-2538 Project: Cassandra Issue Type: Bug Affects Versions: 0.8 beta 1 Reporter: Cathy Daw Assignee: Eric Evans Priority: Minor Labels: cql Fix For: 0.8.0 *Test Case to Run* {noformat} cqlsh select * from users where key in ('user2', 'user3'); Internal application error {noformat} *Test Setup* {noformat} CREATE COLUMNFAMILY users ( KEY varchar PRIMARY KEY, password varchar); INSERT INTO users (KEY, password) VALUES ('user1', 'ch@ngem3a'); {noformat} *Log Files* {noformat} ERROR [RequestResponseStage:17] 2011-04-21 23:36:41,600 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[RequestResponseStage:17,5,main] java.lang.AssertionError at org.apache.cassandra.service.ReadCallback.response(ReadCallback.java:127) at org.apache.cassandra.net.ResponseVerbHandler.doVerb(ResponseVerbHandler.java:49) at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:72) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) ERROR [RequestResponseStage:17] 2011-04-21 23:36:41,600 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[RequestResponseStage:17,5,main] java.lang.AssertionError at org.apache.cassandra.service.ReadCallback.response(ReadCallback.java:127) at org.apache.cassandra.net.ResponseVerbHandler.doVerb(ResponseVerbHandler.java:49) at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:72) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) ERROR [pool-2-thread-5] 2011-04-21 23:37:12,026 Cassandra.java (line 4082) Internal error processing execute_cql_query java.lang.NullPointerException at org.apache.cassandra.cql.WhereClause.and(WhereClause.java:59) at org.apache.cassandra.cql.WhereClause.init(WhereClause.java:44) at org.apache.cassandra.cql.CqlParser.whereClause(CqlParser.java:816) at org.apache.cassandra.cql.CqlParser.selectStatement(CqlParser.java:502) at org.apache.cassandra.cql.CqlParser.query(CqlParser.java:191) at org.apache.cassandra.cql.QueryProcessor.getStatement(QueryProcessor.java:834) at org.apache.cassandra.cql.QueryProcessor.process(QueryProcessor.java:463) at org.apache.cassandra.thrift.CassandraServer.execute_cql_query(CassandraServer.java:1134) at org.apache.cassandra.thrift.Cassandra$Processor$execute_cql_query.process(Cassandra.java:4072) at org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:2889) at org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:187) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) {noformat} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2537) CQL: Error performing batch insert
[ https://issues.apache.org/jira/browse/CASSANDRA-2537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13023078#comment-13023078 ] Jonathan Ellis commented on CASSANDRA-2537: --- CONSISTENCY is defined as follows: {noformat} Consistency level specifications are made up the keyword @USING@, followed by a consistency level identifier. Valid consistency levels are as follows: * @CONSISTENCY ZERO@ * @CONSISTENCY ONE@ (default) * @CONSISTENCY QUORUM@ * @CONSISTENCY ALL@ * @CONSISTENCY DCQUORUM@ * @CONSISTENCY DCQUORUMSYNC@ {noformat} i.e., you want BEGIN BATCH USING CONSISTENCY QUORUM CQL: Error performing batch insert -- Key: CASSANDRA-2537 URL: https://issues.apache.org/jira/browse/CASSANDRA-2537 Project: Cassandra Issue Type: Bug Affects Versions: 0.8.0 Environment: 3-node Centos 5.5 cluster running 0.8 build from apr20. Reporter: Cathy Daw Labels: cql *Test Case To Run* {code} // Setup CREATE COLUMNFAMILY users ( KEY varchar PRIMARY KEY, password varchar); //Batch Insert BEGIN BATCH USING QUORUM INSERT INTO users (KEY, password) VALUES ('user2', 'ch@ngem3b'); INSERT INTO users (KEY, password) VALUES ('user3', 'ch@ngem3c'); APPLY BATCH {code} *Actual Behavior* {code} cqlsh BEGIN BATCH USING QUORUM ... INSERT INTO users (KEY, password) VALUES ('user2', 'ch@ngem3b'); Bad Request: line 0:-1 mismatched input 'EOF' expecting K_APPLY {code} *Documentation Sample* {code} BEGIN BATCH [USING CONSISTENCY] UPDATE CF1 SET name1 = value1, name2 = value2 WHERE KEY = keyname1; UPDATE CF1 SET name3 = value3 WHERE KEY = keyname2; UPDATE CF2 SET name4 = value4, name5 = value5 WHERE KEY = keyname3; APPLY BATCH {code} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2523) Distributed test scripts not working with Whirr 0.4.0
[ https://issues.apache.org/jira/browse/CASSANDRA-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stu Hood updated CASSANDRA-2523: Attachment: 0001-WIP-Update-to-use-jclouds-magical-functions-directory-.txt A work-in-progress patch to include our own functions directory as alluded to in the Whirr FAQ. I'm not yet certain that it's getting picked up at all. Distributed test scripts not working with Whirr 0.4.0 - Key: CASSANDRA-2523 URL: https://issues.apache.org/jira/browse/CASSANDRA-2523 Project: Cassandra Issue Type: Bug Reporter: Stu Hood Fix For: 0.8.0 Attachments: 0001-WIP-Update-to-use-jclouds-magical-functions-directory-.txt I suspect that our runurl based script execution is not working with Whirr 0.4.0, which is causing distributed tests that kill/wipe nodes to timeout. See [this FAQ entry|http://incubator.apache.org/whirr/faq.html#how-can-i-modify-the-instance-installation-and-configuration-scripts] for a description of the change. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2538) CQL: NPE running SELECT with an IN clause
[ https://issues.apache.org/jira/browse/CASSANDRA-2538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eric Evans updated CASSANDRA-2538: -- Attachment: v1-0001-CASSANDRA-2538-NPE-running-SELECT-with-an-IN-clause.txt CQL: NPE running SELECT with an IN clause - Key: CASSANDRA-2538 URL: https://issues.apache.org/jira/browse/CASSANDRA-2538 Project: Cassandra Issue Type: Bug Affects Versions: 0.8 beta 1 Reporter: Cathy Daw Assignee: Eric Evans Priority: Minor Labels: cql Fix For: 0.8.0 Attachments: v1-0001-CASSANDRA-2538-NPE-running-SELECT-with-an-IN-clause.txt *Test Case to Run* {noformat} cqlsh select * from users where key in ('user2', 'user3'); Internal application error {noformat} *Test Setup* {noformat} CREATE COLUMNFAMILY users ( KEY varchar PRIMARY KEY, password varchar); INSERT INTO users (KEY, password) VALUES ('user1', 'ch@ngem3a'); {noformat} *Log Files* {noformat} ERROR [RequestResponseStage:17] 2011-04-21 23:36:41,600 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[RequestResponseStage:17,5,main] java.lang.AssertionError at org.apache.cassandra.service.ReadCallback.response(ReadCallback.java:127) at org.apache.cassandra.net.ResponseVerbHandler.doVerb(ResponseVerbHandler.java:49) at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:72) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) ERROR [RequestResponseStage:17] 2011-04-21 23:36:41,600 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[RequestResponseStage:17,5,main] java.lang.AssertionError at org.apache.cassandra.service.ReadCallback.response(ReadCallback.java:127) at org.apache.cassandra.net.ResponseVerbHandler.doVerb(ResponseVerbHandler.java:49) at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:72) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) ERROR [pool-2-thread-5] 2011-04-21 23:37:12,026 Cassandra.java (line 4082) Internal error processing execute_cql_query java.lang.NullPointerException at org.apache.cassandra.cql.WhereClause.and(WhereClause.java:59) at org.apache.cassandra.cql.WhereClause.init(WhereClause.java:44) at org.apache.cassandra.cql.CqlParser.whereClause(CqlParser.java:816) at org.apache.cassandra.cql.CqlParser.selectStatement(CqlParser.java:502) at org.apache.cassandra.cql.CqlParser.query(CqlParser.java:191) at org.apache.cassandra.cql.QueryProcessor.getStatement(QueryProcessor.java:834) at org.apache.cassandra.cql.QueryProcessor.process(QueryProcessor.java:463) at org.apache.cassandra.thrift.CassandraServer.execute_cql_query(CassandraServer.java:1134) at org.apache.cassandra.thrift.Cassandra$Processor$execute_cql_query.process(Cassandra.java:4072) at org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:2889) at org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:187) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) {noformat} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
svn commit: r1095863 - /cassandra/branches/cassandra-0.8/doc/cql/CQL.textile
Author: jbellis Date: Fri Apr 22 04:47:41 2011 New Revision: 1095863 URL: http://svn.apache.org/viewvc?rev=1095863view=rev Log: s/CONSISTENCY CL/CONSISTENCY/ Modified: cassandra/branches/cassandra-0.8/doc/cql/CQL.textile Modified: cassandra/branches/cassandra-0.8/doc/cql/CQL.textile URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/doc/cql/CQL.textile?rev=1095863r1=1095862r2=1095863view=diff == --- cassandra/branches/cassandra-0.8/doc/cql/CQL.textile (original) +++ cassandra/branches/cassandra-0.8/doc/cql/CQL.textile Fri Apr 22 04:47:41 2011 @@ -73,7 +73,7 @@ h2. UPDATE _Synopsis:_ bc. -UPDATE COLUMN FAMILY [USING CONSISTENCY CL] +UPDATE COLUMN FAMILY [USING CONSISTENCY] SET name1 = value1, name2 = value2 WHERE KEY = keyname; An @UPDATE@ is used to write one or more columns to a record in a Cassandra column family. No results are returned.
[jira] [Commented] (CASSANDRA-2444) An option to disable compaction on startup
[ https://issues.apache.org/jira/browse/CASSANDRA-2444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13023112#comment-13023112 ] Jonathan Ellis commented on CASSANDRA-2444: --- bq. Rather than adding an option for this, I think we should remove the check entirely. If the node needs to compact, it will do so at the first flush +1 An option to disable compaction on startup -- Key: CASSANDRA-2444 URL: https://issues.apache.org/jira/browse/CASSANDRA-2444 Project: Cassandra Issue Type: Bug Reporter: Chris Goffinet Assignee: Chris Goffinet Priority: Minor Labels: compaction Fix For: 0.8.1 Attachments: 0001-CASSANDRA-2444-Provide-an-option-to-enable-disable-c.patch We've ran into many times where we do not want compaction to run right away against CFs when booting up a node. I propose we make that an option in the config, so operators do not have to take the penalty of compacting right away, and can return the node as close to working state as possible. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2538) CQL: NPE running SELECT with an IN clause
[ https://issues.apache.org/jira/browse/CASSANDRA-2538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis updated CASSANDRA-2538: -- I see validateSelect checking for several unsupported query types but I'm not sure how IN would fit in there. CQL: NPE running SELECT with an IN clause - Key: CASSANDRA-2538 URL: https://issues.apache.org/jira/browse/CASSANDRA-2538 Project: Cassandra Issue Type: Bug Affects Versions: 0.8 beta 1 Reporter: Cathy Daw Assignee: Eric Evans Priority: Minor Labels: cql Fix For: 0.8.0 Attachments: v1-0001-CASSANDRA-2538-NPE-running-SELECT-with-an-IN-clause.txt *Test Case to Run* {noformat} cqlsh select * from users where key in ('user2', 'user3'); Internal application error {noformat} *Test Setup* {noformat} CREATE COLUMNFAMILY users ( KEY varchar PRIMARY KEY, password varchar); INSERT INTO users (KEY, password) VALUES ('user1', 'ch@ngem3a'); {noformat} *Log Files* {noformat} ERROR [RequestResponseStage:17] 2011-04-21 23:36:41,600 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[RequestResponseStage:17,5,main] java.lang.AssertionError at org.apache.cassandra.service.ReadCallback.response(ReadCallback.java:127) at org.apache.cassandra.net.ResponseVerbHandler.doVerb(ResponseVerbHandler.java:49) at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:72) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) ERROR [RequestResponseStage:17] 2011-04-21 23:36:41,600 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[RequestResponseStage:17,5,main] java.lang.AssertionError at org.apache.cassandra.service.ReadCallback.response(ReadCallback.java:127) at org.apache.cassandra.net.ResponseVerbHandler.doVerb(ResponseVerbHandler.java:49) at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:72) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) ERROR [pool-2-thread-5] 2011-04-21 23:37:12,026 Cassandra.java (line 4082) Internal error processing execute_cql_query java.lang.NullPointerException at org.apache.cassandra.cql.WhereClause.and(WhereClause.java:59) at org.apache.cassandra.cql.WhereClause.init(WhereClause.java:44) at org.apache.cassandra.cql.CqlParser.whereClause(CqlParser.java:816) at org.apache.cassandra.cql.CqlParser.selectStatement(CqlParser.java:502) at org.apache.cassandra.cql.CqlParser.query(CqlParser.java:191) at org.apache.cassandra.cql.QueryProcessor.getStatement(QueryProcessor.java:834) at org.apache.cassandra.cql.QueryProcessor.process(QueryProcessor.java:463) at org.apache.cassandra.thrift.CassandraServer.execute_cql_query(CassandraServer.java:1134) at org.apache.cassandra.thrift.Cassandra$Processor$execute_cql_query.process(Cassandra.java:4072) at org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:2889) at org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:187) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) {noformat} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2538) CQL: NPE running SELECT with an IN clause
[ https://issues.apache.org/jira/browse/CASSANDRA-2538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis updated CASSANDRA-2538: -- Comment: was deleted (was: I see validateSelect checking for several unsupported query types but I'm not sure how IN would fit in there.) CQL: NPE running SELECT with an IN clause - Key: CASSANDRA-2538 URL: https://issues.apache.org/jira/browse/CASSANDRA-2538 Project: Cassandra Issue Type: Bug Affects Versions: 0.8 beta 1 Reporter: Cathy Daw Assignee: Eric Evans Priority: Minor Labels: cql Fix For: 0.8.0 Attachments: v1-0001-CASSANDRA-2538-NPE-running-SELECT-with-an-IN-clause.txt *Test Case to Run* {noformat} cqlsh select * from users where key in ('user2', 'user3'); Internal application error {noformat} *Test Setup* {noformat} CREATE COLUMNFAMILY users ( KEY varchar PRIMARY KEY, password varchar); INSERT INTO users (KEY, password) VALUES ('user1', 'ch@ngem3a'); {noformat} *Log Files* {noformat} ERROR [RequestResponseStage:17] 2011-04-21 23:36:41,600 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[RequestResponseStage:17,5,main] java.lang.AssertionError at org.apache.cassandra.service.ReadCallback.response(ReadCallback.java:127) at org.apache.cassandra.net.ResponseVerbHandler.doVerb(ResponseVerbHandler.java:49) at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:72) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) ERROR [RequestResponseStage:17] 2011-04-21 23:36:41,600 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[RequestResponseStage:17,5,main] java.lang.AssertionError at org.apache.cassandra.service.ReadCallback.response(ReadCallback.java:127) at org.apache.cassandra.net.ResponseVerbHandler.doVerb(ResponseVerbHandler.java:49) at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:72) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) ERROR [pool-2-thread-5] 2011-04-21 23:37:12,026 Cassandra.java (line 4082) Internal error processing execute_cql_query java.lang.NullPointerException at org.apache.cassandra.cql.WhereClause.and(WhereClause.java:59) at org.apache.cassandra.cql.WhereClause.init(WhereClause.java:44) at org.apache.cassandra.cql.CqlParser.whereClause(CqlParser.java:816) at org.apache.cassandra.cql.CqlParser.selectStatement(CqlParser.java:502) at org.apache.cassandra.cql.CqlParser.query(CqlParser.java:191) at org.apache.cassandra.cql.QueryProcessor.getStatement(QueryProcessor.java:834) at org.apache.cassandra.cql.QueryProcessor.process(QueryProcessor.java:463) at org.apache.cassandra.thrift.CassandraServer.execute_cql_query(CassandraServer.java:1134) at org.apache.cassandra.thrift.Cassandra$Processor$execute_cql_query.process(Cassandra.java:4072) at org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:2889) at org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:187) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) {noformat} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2538) CQL: NPE running SELECT with an IN clause
[ https://issues.apache.org/jira/browse/CASSANDRA-2538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis updated CASSANDRA-2538: -- Reviewer: cdaw CQL: NPE running SELECT with an IN clause - Key: CASSANDRA-2538 URL: https://issues.apache.org/jira/browse/CASSANDRA-2538 Project: Cassandra Issue Type: Bug Affects Versions: 0.8 beta 1 Reporter: Cathy Daw Assignee: Eric Evans Priority: Minor Labels: cql Fix For: 0.8.0 Attachments: v1-0001-CASSANDRA-2538-NPE-running-SELECT-with-an-IN-clause.txt *Test Case to Run* {noformat} cqlsh select * from users where key in ('user2', 'user3'); Internal application error {noformat} *Test Setup* {noformat} CREATE COLUMNFAMILY users ( KEY varchar PRIMARY KEY, password varchar); INSERT INTO users (KEY, password) VALUES ('user1', 'ch@ngem3a'); {noformat} *Log Files* {noformat} ERROR [RequestResponseStage:17] 2011-04-21 23:36:41,600 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[RequestResponseStage:17,5,main] java.lang.AssertionError at org.apache.cassandra.service.ReadCallback.response(ReadCallback.java:127) at org.apache.cassandra.net.ResponseVerbHandler.doVerb(ResponseVerbHandler.java:49) at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:72) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) ERROR [RequestResponseStage:17] 2011-04-21 23:36:41,600 AbstractCassandraDaemon.java (line 112) Fatal exception in thread Thread[RequestResponseStage:17,5,main] java.lang.AssertionError at org.apache.cassandra.service.ReadCallback.response(ReadCallback.java:127) at org.apache.cassandra.net.ResponseVerbHandler.doVerb(ResponseVerbHandler.java:49) at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:72) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) ERROR [pool-2-thread-5] 2011-04-21 23:37:12,026 Cassandra.java (line 4082) Internal error processing execute_cql_query java.lang.NullPointerException at org.apache.cassandra.cql.WhereClause.and(WhereClause.java:59) at org.apache.cassandra.cql.WhereClause.init(WhereClause.java:44) at org.apache.cassandra.cql.CqlParser.whereClause(CqlParser.java:816) at org.apache.cassandra.cql.CqlParser.selectStatement(CqlParser.java:502) at org.apache.cassandra.cql.CqlParser.query(CqlParser.java:191) at org.apache.cassandra.cql.QueryProcessor.getStatement(QueryProcessor.java:834) at org.apache.cassandra.cql.QueryProcessor.process(QueryProcessor.java:463) at org.apache.cassandra.thrift.CassandraServer.execute_cql_query(CassandraServer.java:1134) at org.apache.cassandra.thrift.Cassandra$Processor$execute_cql_query.process(Cassandra.java:4072) at org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:2889) at org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:187) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:636) {noformat} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-2494) Quorum reads are not consistent
[ https://issues.apache.org/jira/browse/CASSANDRA-2494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13023116#comment-13023116 ] Stu Hood commented on CASSANDRA-2494: - W plus R must be _greater than_ N for consistency. Quorum reads are not consistent --- Key: CASSANDRA-2494 URL: https://issues.apache.org/jira/browse/CASSANDRA-2494 Project: Cassandra Issue Type: Bug Reporter: Sean Bridges As discussed in this thread, http://www.mail-archive.com/user@cassandra.apache.org/msg12421.html Quorum reads should be consistent. Assume we have a cluster of 3 nodes (X,Y,Z) and a replication factor of 3. If a write of N is committed to X, but not Y and Z, then a read from X should not return N unless the read is committed to at least two nodes. To ensure this, a read from X should wait for an ack of the read repair write from either Y or Z before returning. Are there system tests for cassandra? If so, there should be a test similar to the original post in the email thread. One thread should write 1,2,3... at consistency level ONE. Another thread should read at consistency level QUORUM from a random host, and verify that each read is = the last read. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2404) if out of disk space reclaim compacted SSTables during memtable flush
[ https://issues.apache.org/jira/browse/CASSANDRA-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis updated CASSANDRA-2404: -- Affects Version/s: (was: 0.7.4) Assignee: Jonathan Ellis (was: Aaron Morton) The reason we didn't do this historically is we didn't know how much free space should be the Panic Threshold on flush, whereas compaction has an easy-to-compute upper bound. Now we we can compute the flush size very easily (basically the throughput value + 2xkey sizes) so we can run the same if not enough room then attempt a GC logic. if out of disk space reclaim compacted SSTables during memtable flush - Key: CASSANDRA-2404 URL: https://issues.apache.org/jira/browse/CASSANDRA-2404 Project: Cassandra Issue Type: Improvement Components: Core Reporter: Aaron Morton Assignee: Jonathan Ellis Priority: Minor Fix For: 0.7.6 During compaction if there is not enough disk space we invoke GC to reclaim unused space. During memtable and binary memtable flush we just error out if there is not enough disk space to flush the table. Can we make cfs.createFlushWriter() use the same logic as Table.getDataFileLocation() to reclaim space if needed? -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Created] (CASSANDRA-2540) Data reads by default
Data reads by default - Key: CASSANDRA-2540 URL: https://issues.apache.org/jira/browse/CASSANDRA-2540 Project: Cassandra Issue Type: Bug Reporter: Stu Hood Fix For: 0.8.0 The intention of digest vs data reads is to save bandwidth in the read path at the cost of latency, but I expect that this has been a premature optimization. * Data requested by a read will often be within an order of magnitude of the digest size, and a failed digest means extra roundtrips, more bandwidth * The [digest reads but not your data read|https://issues.apache.org/jira/browse/CASSANDRA-2282?focusedCommentId=13004656page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-13004656] problem means failing QUORUM reads because a single node is unavailable, and would require eagerly re-requesting at some fraction of your timeout * Saving bandwidth in cross datacenter usecases comes at huge cost to latency, since both constraints increase proportionally enough that the tradeoff is not clear Some options: # Add an option to use digest reads # Remove digest reads entirely (and/or punt and make them a runtime optimization based on data size in the future) \\ The outcome of data-reads-by-default should be significantly improved latency, with a moderate increase in bandwidth usage for large reads. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-2540) Data reads by default
[ https://issues.apache.org/jira/browse/CASSANDRA-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stu Hood updated CASSANDRA-2540: Description: The intention of digest vs data reads is to save bandwidth in the read path at the cost of latency, but I expect that this has been a premature optimization. * Data requested by a read will often be within an order of magnitude of the digest size, and a failed digest means extra roundtrips, more bandwidth * The [digest reads but not your data read|https://issues.apache.org/jira/browse/CASSANDRA-2282?focusedCommentId=13004656page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-13004656] problem means failing QUORUM reads because a single node is unavailable, and would require eagerly re-requesting at some fraction of your timeout * Saving bandwidth in cross datacenter usecases comes at huge cost to latency, since both constraints increase proportionally enough that the tradeoff is not clear Some options: # Add an option to use digest reads # Remove digest reads entirely (and/or punt and make them a runtime optimization based on data size in the future) # Continue to use digest reads, but send them to {{N - R}} nodes for (somewhat) more predicatable behavior with QUORUM \\ The outcome of data-reads-by-default should be significantly improved latency, with a moderate increase in bandwidth usage for large reads. was: The intention of digest vs data reads is to save bandwidth in the read path at the cost of latency, but I expect that this has been a premature optimization. * Data requested by a read will often be within an order of magnitude of the digest size, and a failed digest means extra roundtrips, more bandwidth * The [digest reads but not your data read|https://issues.apache.org/jira/browse/CASSANDRA-2282?focusedCommentId=13004656page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-13004656] problem means failing QUORUM reads because a single node is unavailable, and would require eagerly re-requesting at some fraction of your timeout * Saving bandwidth in cross datacenter usecases comes at huge cost to latency, since both constraints increase proportionally enough that the tradeoff is not clear Some options: # Add an option to use digest reads # Remove digest reads entirely (and/or punt and make them a runtime optimization based on data size in the future) \\ The outcome of data-reads-by-default should be significantly improved latency, with a moderate increase in bandwidth usage for large reads. Data reads by default - Key: CASSANDRA-2540 URL: https://issues.apache.org/jira/browse/CASSANDRA-2540 Project: Cassandra Issue Type: Bug Reporter: Stu Hood Fix For: 0.8.0 The intention of digest vs data reads is to save bandwidth in the read path at the cost of latency, but I expect that this has been a premature optimization. * Data requested by a read will often be within an order of magnitude of the digest size, and a failed digest means extra roundtrips, more bandwidth * The [digest reads but not your data read|https://issues.apache.org/jira/browse/CASSANDRA-2282?focusedCommentId=13004656page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-13004656] problem means failing QUORUM reads because a single node is unavailable, and would require eagerly re-requesting at some fraction of your timeout * Saving bandwidth in cross datacenter usecases comes at huge cost to latency, since both constraints increase proportionally enough that the tradeoff is not clear Some options: # Add an option to use digest reads # Remove digest reads entirely (and/or punt and make them a runtime optimization based on data size in the future) # Continue to use digest reads, but send them to {{N - R}} nodes for (somewhat) more predicatable behavior with QUORUM \\ The outcome of data-reads-by-default should be significantly improved latency, with a moderate increase in bandwidth usage for large reads. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira