[jira] [Updated] (CASSANDRA-2221) 'show create' commands on the CLI to export schema

2011-04-21 Thread Aaron Morton (JIRA)

 [ 
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

2011-04-21 Thread Aaron Morton (JIRA)

 [ 
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

2011-04-21 Thread Sylvain Lebresne (JIRA)

 [ 
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

2011-04-21 Thread Sylvain Lebresne (JIRA)

[ 
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

2011-04-21 Thread Pavel Yaskevich (JIRA)

 [ 
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

2011-04-21 Thread slebresne
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/

2011-04-21 Thread slebresne
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

2011-04-21 Thread slebresne
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

2011-04-21 Thread Jonathan Ellis (JIRA)

 [ 
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

2011-04-21 Thread Jonathan Ellis (JIRA)

[ 
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

2011-04-21 Thread jbellis
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

2011-04-21 Thread jbellis
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/

2011-04-21 Thread jbellis
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

2011-04-21 Thread Jeremy Hanna (JIRA)
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

2011-04-21 Thread jbellis
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/

2011-04-21 Thread jbellis
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/

2011-04-21 Thread jbellis
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/

2011-04-21 Thread jbellis
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/

2011-04-21 Thread jbellis
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

2011-04-21 Thread Nate McCall (JIRA)

[ 
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

2011-04-21 Thread Jackson Chung (JIRA)
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

2011-04-21 Thread Patricio Echague (JIRA)

[ 
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

2011-04-21 Thread Hudson (JIRA)

[ 
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

2011-04-21 Thread Hudson (JIRA)

[ 
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

2011-04-21 Thread Gary Dusbabek (JIRA)

[ 
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

2011-04-21 Thread Jonathan Ellis (JIRA)

 [ 
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

2011-04-21 Thread Jonathan Ellis (JIRA)

 [ 
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

2011-04-21 Thread Jackson Chung (JIRA)

[ 
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

2011-04-21 Thread Jackson Chung (JIRA)

[ 
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

2011-04-21 Thread Jackson Chung (JIRA)

[ 
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

2011-04-21 Thread Jackson Chung (JIRA)

[ 
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

2011-04-21 Thread Cathy Daw (JIRA)
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

2011-04-21 Thread Cathy Daw (JIRA)

 [ 
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

2011-04-21 Thread Hudson (JIRA)

[ 
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

2011-04-21 Thread Hudson (JIRA)

[ 
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

2011-04-21 Thread Rick Shaw (JIRA)
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

2011-04-21 Thread Jonathan Ellis (JIRA)

 [ 
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

2011-04-21 Thread Rick Shaw (JIRA)

 [ 
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

2011-04-21 Thread Jonathan Ellis (JIRA)

 [ 
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

2011-04-21 Thread Jeremy Hanna (JIRA)

[ 
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

2011-04-21 Thread paul cannon (JIRA)

[ 
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

2011-04-21 Thread Jonathan Ellis (JIRA)

 [ 
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

2011-04-21 Thread Jonathan Ellis (JIRA)

[ 
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

2011-04-21 Thread Rick Shaw (JIRA)

 [ 
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

2011-04-21 Thread Jonathan Ellis (JIRA)

 [ 
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

2011-04-21 Thread Brandon Williams (JIRA)
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

2011-04-21 Thread Jonathan Ellis (JIRA)

 [ 
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

2011-04-21 Thread Stu Hood (JIRA)
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

2011-04-21 Thread Jonathan Ellis (JIRA)

 [ 
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

2011-04-21 Thread Stu Hood (JIRA)

 [ 
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

2011-04-21 Thread Rick Shaw (JIRA)

[ 
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

2011-04-21 Thread Jonathan Ellis (JIRA)

[ 
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

2011-04-21 Thread Cathy Daw (JIRA)
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

2011-04-21 Thread Stu Hood (JIRA)

 [ 
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

2011-04-21 Thread Jonathan Ellis (JIRA)

[ 
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

2011-04-21 Thread Rick Shaw (JIRA)

 [ 
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

2011-04-21 Thread Cathy Daw (JIRA)

[ 
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

2011-04-21 Thread Cathy Daw (JIRA)
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

2011-04-21 Thread Cathy Daw (JIRA)

[ 
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

2011-04-21 Thread Jackson Chung (JIRA)

[ 
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

2011-04-21 Thread Cathy Daw (JIRA)

[ 
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

2011-04-21 Thread Chris Goffinet (JIRA)
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

2011-04-21 Thread Cathy Daw (JIRA)

[ 
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

2011-04-21 Thread Cathy Daw (JIRA)

[ 
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

2011-04-21 Thread jbellis
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

2011-04-21 Thread Chris Goffinet (JIRA)

 [ 
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

2011-04-21 Thread Jonathan Ellis (JIRA)

 [ 
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

2011-04-21 Thread Stu Hood (JIRA)

 [ 
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

2011-04-21 Thread Stu Hood (JIRA)

[ 
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

2011-04-21 Thread Tyler Hobbs (JIRA)
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

2011-04-21 Thread Tyler Hobbs (JIRA)

 [ 
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

2011-04-21 Thread Cathy Daw (JIRA)

[ 
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

2011-04-21 Thread Chris Goffinet (JIRA)

 [ 
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

2011-04-21 Thread Chris Goffinet (JIRA)

 [ 
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

2011-04-21 Thread Cathy Daw (JIRA)
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

2011-04-21 Thread Chris Goffinet (JIRA)

 [ 
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

2011-04-21 Thread Hudson (JIRA)

[ 
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

2011-04-21 Thread Mike Bulman (JIRA)

[ 
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

2011-04-21 Thread Stu Hood (JIRA)

[ 
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

2011-04-21 Thread Cathy Daw (JIRA)
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

2011-04-21 Thread Cathy Daw (JIRA)

[ 
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.

2011-04-21 Thread Cathy Daw (JIRA)
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

2011-04-21 Thread Cathy Daw (JIRA)

 [ 
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

2011-04-21 Thread Apache Wiki
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

2011-04-21 Thread Jonathan Ellis (JIRA)

 [ 
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

2011-04-21 Thread Jonathan Ellis (JIRA)

 [ 
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

2011-04-21 Thread Jonathan Ellis (JIRA)

[ 
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

2011-04-21 Thread Stu Hood (JIRA)

 [ 
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

2011-04-21 Thread Eric Evans (JIRA)

 [ 
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

2011-04-21 Thread jbellis
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

2011-04-21 Thread Jonathan Ellis (JIRA)

[ 
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

2011-04-21 Thread Jonathan Ellis (JIRA)

 [ 
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

2011-04-21 Thread Jonathan Ellis (JIRA)

 [ 
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

2011-04-21 Thread Jonathan Ellis (JIRA)

 [ 
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

2011-04-21 Thread Stu Hood (JIRA)

[ 
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

2011-04-21 Thread Jonathan Ellis (JIRA)

 [ 
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

2011-04-21 Thread Stu Hood (JIRA)
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

2011-04-21 Thread Stu Hood (JIRA)

 [ 
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