date:20120513

git commit: Fix CQL3 index dropping

2012-05-13 Thread slebresne

Updated Branches:
  refs/heads/cassandra-1.1 47783861a -> f58a51bc5


Fix CQL3 index dropping

patch by slebresne; reviewed by jbellis for CASSANDRA-4192


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/f58a51bc
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/f58a51bc
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/f58a51bc

Branch: refs/heads/cassandra-1.1
Commit: f58a51bc5f9815b554a52f93b48d70670a55047e
Parents: 4778386
Author: Sylvain Lebresne 
Authored: Mon May 14 08:51:03 2012 +0200
Committer: Sylvain Lebresne 
Committed: Mon May 14 08:51:03 2012 +0200

--
 CHANGES.txt|1 +
 .../org/apache/cassandra/config/CFMetaData.java|   31 ++
 .../cql3/statements/DropIndexStatement.java|   17 +---
 3 files changed, 33 insertions(+), 16 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/cassandra/blob/f58a51bc/CHANGES.txt
--
diff --git a/CHANGES.txt b/CHANGES.txt
index 9246433..b37bd83 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -40,6 +40,7 @@
(CASSANDRA-4187)
  * Fix exception during move when localhost is the only source (CASSANDRA-4200)
  * (cql3) Allow paging through non-ordered partitioner results (CASSANDRA-3771)
+ * (cql3) Fix drop index
 Merged from 1.0:
  * Fix super columns bug where cache is not updated (CASSANDRA-4190)
  * fix maxTimestamp to include row tombstones (CASSANDRA-4116)

http://git-wip-us.apache.org/repos/asf/cassandra/blob/f58a51bc/src/java/org/apache/cassandra/config/CFMetaData.java
--
diff --git a/src/java/org/apache/cassandra/config/CFMetaData.java 
b/src/java/org/apache/cassandra/config/CFMetaData.java
index e36ea2d..ce4ed76 100644
--- a/src/java/org/apache/cassandra/config/CFMetaData.java
+++ b/src/java/org/apache/cassandra/config/CFMetaData.java
@@ -849,10 +849,18 @@ public final class CFMetaData
  */
 public void addDefaultIndexNames() throws ConfigurationException
 {
+Set existingNames = existingIndexNames(null);
 for (ColumnDefinition column : column_metadata.values())
 {
 if (column.getIndexType() != null && column.getIndexName() == null)
-column.setIndexName(getDefaultIndexName(cfName, comparator, 
column.name));
+{
+String baseName = getDefaultIndexName(cfName, comparator, 
column.name);
+String indexName = baseName;
+int i = 0;
+while (existingNames.contains(indexName))
+indexName = baseName + '_' + (++i);
+column.setIndexName(indexName);
+}
 }
 }
 
@@ -941,14 +949,7 @@ public final class CFMetaData
 validateAlias(valueAlias, "Value");
 
 // initialize a set of names NOT in the CF under consideration
-Set indexNames = new HashSet();
-for (ColumnFamilyStore cfs : ColumnFamilyStore.all())
-{
-if (!cfs.getColumnFamilyName().equals(cfName))
-for (ColumnDefinition cd : 
cfs.metadata.getColumn_metadata().values())
-indexNames.add(cd.getIndexName());
-}
-
+Set indexNames = existingIndexNames(cfName);
 for (ColumnDefinition c : column_metadata.values())
 {
 AbstractType comparator = getColumnDefinitionComparator(c);
@@ -995,6 +996,18 @@ public final class CFMetaData
 return this;
 }
 
+private static Set existingIndexNames(String cfToExclude)
+{
+Set indexNames = new HashSet();
+for (ColumnFamilyStore cfs : ColumnFamilyStore.all())
+{
+if (cfToExclude == null || 
!cfs.getColumnFamilyName().equals(cfToExclude))
+for (ColumnDefinition cd : 
cfs.metadata.getColumn_metadata().values())
+indexNames.add(cd.getIndexName());
+}
+return indexNames;
+}
+
 private static void validateAlias(ByteBuffer alias, String msg) throws 
ConfigurationException
 {
 if (alias != null)

http://git-wip-us.apache.org/repos/asf/cassandra/blob/f58a51bc/src/java/org/apache/cassandra/cql3/statements/DropIndexStatement.java
--
diff --git 
a/src/java/org/apache/cassandra/cql3/statements/DropIndexStatement.java 
b/src/java/org/apache/cassandra/cql3/statements/DropIndexStatement.java
index ab47100..12d04c1 100644
--- a/src/java/org/apache/cassandra/cql3/statements/DropIndexStatement.java
+++ b/src/java/org/apache/cassandra/cql3/statements/DropIndexStatement.java
@@ -29,12 +29,12 @@ import org.apache.cassandra.thrift.InvalidRequestException;
 
 public

[jira] [Commented] (CASSANDRA-4230) Deleting a CF always produces an error and that CF remains in an unknown state

2012-05-13 Thread Pavel Yaskevich (JIRA)


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

Pavel Yaskevich commented on CASSANDRA-4230:


No, this bug came together with directory-per-CF which was added into 1.1.

> Deleting a CF always produces an error and that CF remains in an unknown state
> --
>
> Key: CASSANDRA-4230
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4230
> Project: Cassandra
>  Issue Type: Bug
>  Components: Core
>Affects Versions: 1.1.0
> Environment: Debian Linux Squeeze with the cassandra debian package 
> from Apache.
>Reporter: André Cruz
>Assignee: Pavel Yaskevich
> Fix For: 1.1.1
>
> Attachments: CASSANDRA-4230.patch
>
>
> From the CLI perspective:
> [default@Disco] drop column family client; 
> null
> org.apache.thrift.transport.TTransportException
>   at 
> org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132)
>   at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
>   at 
> org.apache.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java:129)
>   at 
> org.apache.thrift.transport.TFramedTransport.read(TFramedTransport.java:101)
>   at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
>   at 
> org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:378)
>   at 
> org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297)
>   at 
> org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:204)
>   at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:69)
>   at 
> org.apache.cassandra.thrift.Cassandra$Client.recv_system_drop_column_family(Cassandra.java:1222)
>   at 
> org.apache.cassandra.thrift.Cassandra$Client.system_drop_column_family(Cassandra.java:1209)
>   at 
> org.apache.cassandra.cli.CliClient.executeDelColumnFamily(CliClient.java:1301)
>   at 
> org.apache.cassandra.cli.CliClient.executeCLIStatement(CliClient.java:234)
>   at 
> org.apache.cassandra.cli.CliMain.processStatementInteractive(CliMain.java:219)
>   at org.apache.cassandra.cli.CliMain.main(CliMain.java:346)
> Log:
>  INFO [MigrationStage:1] 2012-05-09 11:25:35,686 ColumnFamilyStore.java (line 
> 634) Enqueuing flush of Memtable-schema_columnfamilies@225225949(978/1222 
> serialized/live bytes, 21 ops)
>  INFO [FlushWriter:3] 2012-05-09 11:25:35,687 Memtable.java (line 266) 
> Writing Memtable-schema_columnfamilies@225225949(978/1222 serialized/live 
> bytes, 21 ops)
>  INFO [FlushWriter:3] 2012-05-09 11:25:35,748 Memtable.java (line 307) 
> Completed flushing 
> /var/lib/cassandra/data/system/schema_columnfamilies/system-schema_columnfamilies-hc-34-Data.db
>  (1041 bytes)
>  INFO [MigrationStage:1] 2012-05-09 11:25:35,749 ColumnFamilyStore.java (line 
> 634) Enqueuing flush of Memtable-schema_columns@213209572(586/732 
> serialized/live bytes, 12 ops)
>  INFO [FlushWriter:3] 2012-05-09 11:25:35,750 Memtable.java (line 266) 
> Writing Memtable-schema_columns@213209572(586/732 serialized/live bytes, 12 
> ops)
>  INFO [FlushWriter:3] 2012-05-09 11:25:35,812 Memtable.java (line 307) 
> Completed flushing 
> /var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-28-Data.db
>  (649 bytes)
>  INFO [CompactionExecutor:20] 2012-05-09 11:25:35,814 CompactionTask.java 
> (line 114) Compacting 
> [SSTableReader(path='/var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-27-Data.db'),
>  SSTableReader
> (path='/var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-25-Data.db'),
>  
> SSTableReader(path='/var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-26-Data.db'),
>  SSTableReader(path
> ='/var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-28-Data.db')]
>  INFO [MigrationStage:1] 2012-05-09 11:25:35,918 ColumnFamilyStore.java (line 
> 634) Enqueuing flush of Memtable-Client@864320066(372/465 serialized/live 
> bytes, 6 ops)
>  INFO [FlushWriter:3] 2012-05-09 11:25:35,919 Memtable.java (line 266) 
> Writing Memtable-Client@864320066(372/465 serialized/live bytes, 6 ops)
>  INFO [CompactionExecutor:20] 2012-05-09 11:25:35,945 CompactionTask.java 
> (line 225) Compacted to 
> [/var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-29-Data.db,].
>   22,486 to 20,621 (~91% of orig
> inal) bytes for 2 keys at 0.150120MB/s.  Time: 131ms.
>  INFO [FlushWriter:3] 2012-05-09 11:25:36,013 Memtable.java (line 307) 
> Completed flushing 
> /var/lib/cassandra/data/Disco/Client/Disco-Client-hc-5-Data.db (407 bytes)
> ERROR [MigrationStage:1] 2012-05-09 11:25:36,043 CLibrary.java (line

[jira] [Commented] (CASSANDRA-4230) Deleting a CF always produces an error and that CF remains in an unknown state

2012-05-13 Thread Jonathan Ellis (JIRA)


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

Jonathan Ellis commented on CASSANDRA-4230:
---

Do we need this in 1.0 too?

> Deleting a CF always produces an error and that CF remains in an unknown state
> --
>
> Key: CASSANDRA-4230
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4230
> Project: Cassandra
>  Issue Type: Bug
>  Components: Core
>Affects Versions: 1.1.0
> Environment: Debian Linux Squeeze with the cassandra debian package 
> from Apache.
>Reporter: André Cruz
>Assignee: Pavel Yaskevich
> Fix For: 1.1.1
>
> Attachments: CASSANDRA-4230.patch
>
>
> From the CLI perspective:
> [default@Disco] drop column family client; 
> null
> org.apache.thrift.transport.TTransportException
>   at 
> org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132)
>   at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
>   at 
> org.apache.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java:129)
>   at 
> org.apache.thrift.transport.TFramedTransport.read(TFramedTransport.java:101)
>   at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
>   at 
> org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:378)
>   at 
> org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297)
>   at 
> org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:204)
>   at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:69)
>   at 
> org.apache.cassandra.thrift.Cassandra$Client.recv_system_drop_column_family(Cassandra.java:1222)
>   at 
> org.apache.cassandra.thrift.Cassandra$Client.system_drop_column_family(Cassandra.java:1209)
>   at 
> org.apache.cassandra.cli.CliClient.executeDelColumnFamily(CliClient.java:1301)
>   at 
> org.apache.cassandra.cli.CliClient.executeCLIStatement(CliClient.java:234)
>   at 
> org.apache.cassandra.cli.CliMain.processStatementInteractive(CliMain.java:219)
>   at org.apache.cassandra.cli.CliMain.main(CliMain.java:346)
> Log:
>  INFO [MigrationStage:1] 2012-05-09 11:25:35,686 ColumnFamilyStore.java (line 
> 634) Enqueuing flush of Memtable-schema_columnfamilies@225225949(978/1222 
> serialized/live bytes, 21 ops)
>  INFO [FlushWriter:3] 2012-05-09 11:25:35,687 Memtable.java (line 266) 
> Writing Memtable-schema_columnfamilies@225225949(978/1222 serialized/live 
> bytes, 21 ops)
>  INFO [FlushWriter:3] 2012-05-09 11:25:35,748 Memtable.java (line 307) 
> Completed flushing 
> /var/lib/cassandra/data/system/schema_columnfamilies/system-schema_columnfamilies-hc-34-Data.db
>  (1041 bytes)
>  INFO [MigrationStage:1] 2012-05-09 11:25:35,749 ColumnFamilyStore.java (line 
> 634) Enqueuing flush of Memtable-schema_columns@213209572(586/732 
> serialized/live bytes, 12 ops)
>  INFO [FlushWriter:3] 2012-05-09 11:25:35,750 Memtable.java (line 266) 
> Writing Memtable-schema_columns@213209572(586/732 serialized/live bytes, 12 
> ops)
>  INFO [FlushWriter:3] 2012-05-09 11:25:35,812 Memtable.java (line 307) 
> Completed flushing 
> /var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-28-Data.db
>  (649 bytes)
>  INFO [CompactionExecutor:20] 2012-05-09 11:25:35,814 CompactionTask.java 
> (line 114) Compacting 
> [SSTableReader(path='/var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-27-Data.db'),
>  SSTableReader
> (path='/var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-25-Data.db'),
>  
> SSTableReader(path='/var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-26-Data.db'),
>  SSTableReader(path
> ='/var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-28-Data.db')]
>  INFO [MigrationStage:1] 2012-05-09 11:25:35,918 ColumnFamilyStore.java (line 
> 634) Enqueuing flush of Memtable-Client@864320066(372/465 serialized/live 
> bytes, 6 ops)
>  INFO [FlushWriter:3] 2012-05-09 11:25:35,919 Memtable.java (line 266) 
> Writing Memtable-Client@864320066(372/465 serialized/live bytes, 6 ops)
>  INFO [CompactionExecutor:20] 2012-05-09 11:25:35,945 CompactionTask.java 
> (line 225) Compacted to 
> [/var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-29-Data.db,].
>   22,486 to 20,621 (~91% of orig
> inal) bytes for 2 keys at 0.150120MB/s.  Time: 131ms.
>  INFO [FlushWriter:3] 2012-05-09 11:25:36,013 Memtable.java (line 307) 
> Completed flushing 
> /var/lib/cassandra/data/Disco/Client/Disco-Client-hc-5-Data.db (407 bytes)
> ERROR [MigrationStage:1] 2012-05-09 11:25:36,043 CLibrary.java (line 158) 
> Unable to create hard link
> com.sun.jna.

[jira] [Updated] (CASSANDRA-4230) Deleting a CF always produces an error and that CF remains in an unknown state

2012-05-13 Thread Pavel Yaskevich (JIRA)


 [ 
https://issues.apache.org/jira/browse/CASSANDRA-4230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Pavel Yaskevich updated CASSANDRA-4230:
---

Attachment: CASSANDRA-4230.patch

> Deleting a CF always produces an error and that CF remains in an unknown state
> --
>
> Key: CASSANDRA-4230
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4230
> Project: Cassandra
>  Issue Type: Bug
>  Components: Core
>Affects Versions: 1.1.0
> Environment: Debian Linux Squeeze with the cassandra debian package 
> from Apache.
>Reporter: André Cruz
>Assignee: Pavel Yaskevich
> Fix For: 1.1.1
>
> Attachments: CASSANDRA-4230.patch
>
>
> From the CLI perspective:
> [default@Disco] drop column family client; 
> null
> org.apache.thrift.transport.TTransportException
>   at 
> org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132)
>   at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
>   at 
> org.apache.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java:129)
>   at 
> org.apache.thrift.transport.TFramedTransport.read(TFramedTransport.java:101)
>   at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
>   at 
> org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:378)
>   at 
> org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297)
>   at 
> org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:204)
>   at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:69)
>   at 
> org.apache.cassandra.thrift.Cassandra$Client.recv_system_drop_column_family(Cassandra.java:1222)
>   at 
> org.apache.cassandra.thrift.Cassandra$Client.system_drop_column_family(Cassandra.java:1209)
>   at 
> org.apache.cassandra.cli.CliClient.executeDelColumnFamily(CliClient.java:1301)
>   at 
> org.apache.cassandra.cli.CliClient.executeCLIStatement(CliClient.java:234)
>   at 
> org.apache.cassandra.cli.CliMain.processStatementInteractive(CliMain.java:219)
>   at org.apache.cassandra.cli.CliMain.main(CliMain.java:346)
> Log:
>  INFO [MigrationStage:1] 2012-05-09 11:25:35,686 ColumnFamilyStore.java (line 
> 634) Enqueuing flush of Memtable-schema_columnfamilies@225225949(978/1222 
> serialized/live bytes, 21 ops)
>  INFO [FlushWriter:3] 2012-05-09 11:25:35,687 Memtable.java (line 266) 
> Writing Memtable-schema_columnfamilies@225225949(978/1222 serialized/live 
> bytes, 21 ops)
>  INFO [FlushWriter:3] 2012-05-09 11:25:35,748 Memtable.java (line 307) 
> Completed flushing 
> /var/lib/cassandra/data/system/schema_columnfamilies/system-schema_columnfamilies-hc-34-Data.db
>  (1041 bytes)
>  INFO [MigrationStage:1] 2012-05-09 11:25:35,749 ColumnFamilyStore.java (line 
> 634) Enqueuing flush of Memtable-schema_columns@213209572(586/732 
> serialized/live bytes, 12 ops)
>  INFO [FlushWriter:3] 2012-05-09 11:25:35,750 Memtable.java (line 266) 
> Writing Memtable-schema_columns@213209572(586/732 serialized/live bytes, 12 
> ops)
>  INFO [FlushWriter:3] 2012-05-09 11:25:35,812 Memtable.java (line 307) 
> Completed flushing 
> /var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-28-Data.db
>  (649 bytes)
>  INFO [CompactionExecutor:20] 2012-05-09 11:25:35,814 CompactionTask.java 
> (line 114) Compacting 
> [SSTableReader(path='/var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-27-Data.db'),
>  SSTableReader
> (path='/var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-25-Data.db'),
>  
> SSTableReader(path='/var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-26-Data.db'),
>  SSTableReader(path
> ='/var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-28-Data.db')]
>  INFO [MigrationStage:1] 2012-05-09 11:25:35,918 ColumnFamilyStore.java (line 
> 634) Enqueuing flush of Memtable-Client@864320066(372/465 serialized/live 
> bytes, 6 ops)
>  INFO [FlushWriter:3] 2012-05-09 11:25:35,919 Memtable.java (line 266) 
> Writing Memtable-Client@864320066(372/465 serialized/live bytes, 6 ops)
>  INFO [CompactionExecutor:20] 2012-05-09 11:25:35,945 CompactionTask.java 
> (line 225) Compacted to 
> [/var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-29-Data.db,].
>   22,486 to 20,621 (~91% of orig
> inal) bytes for 2 keys at 0.150120MB/s.  Time: 131ms.
>  INFO [FlushWriter:3] 2012-05-09 11:25:36,013 Memtable.java (line 307) 
> Completed flushing 
> /var/lib/cassandra/data/Disco/Client/Disco-Client-hc-5-Data.db (407 bytes)
> ERROR [MigrationStage:1] 2012-05-09 11:25:36,043 CLibrary.java (line 158) 
> Unable to create hard link
> com.sun.jna.LastErrorException: errno was 17
> at org.apache.c

[jira] [Commented] (CASSANDRA-4230) Deleting a CF always produces an error and that CF remains in an unknown state

2012-05-13 Thread Pavel Yaskevich (JIRA)


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

Pavel Yaskevich commented on CASSANDRA-4230:


I have figured out that this problem is caused only when LeveledCompaction is 
used for Secondary Index, it seems like when index's leveled manifest is 
snapshoted it uses the wrong name.

> Deleting a CF always produces an error and that CF remains in an unknown state
> --
>
> Key: CASSANDRA-4230
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4230
> Project: Cassandra
>  Issue Type: Bug
>  Components: Core
>Affects Versions: 1.1.0
> Environment: Debian Linux Squeeze with the cassandra debian package 
> from Apache.
>Reporter: André Cruz
>Assignee: Pavel Yaskevich
>
> From the CLI perspective:
> [default@Disco] drop column family client; 
> null
> org.apache.thrift.transport.TTransportException
>   at 
> org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132)
>   at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
>   at 
> org.apache.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java:129)
>   at 
> org.apache.thrift.transport.TFramedTransport.read(TFramedTransport.java:101)
>   at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
>   at 
> org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:378)
>   at 
> org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297)
>   at 
> org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:204)
>   at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:69)
>   at 
> org.apache.cassandra.thrift.Cassandra$Client.recv_system_drop_column_family(Cassandra.java:1222)
>   at 
> org.apache.cassandra.thrift.Cassandra$Client.system_drop_column_family(Cassandra.java:1209)
>   at 
> org.apache.cassandra.cli.CliClient.executeDelColumnFamily(CliClient.java:1301)
>   at 
> org.apache.cassandra.cli.CliClient.executeCLIStatement(CliClient.java:234)
>   at 
> org.apache.cassandra.cli.CliMain.processStatementInteractive(CliMain.java:219)
>   at org.apache.cassandra.cli.CliMain.main(CliMain.java:346)
> Log:
>  INFO [MigrationStage:1] 2012-05-09 11:25:35,686 ColumnFamilyStore.java (line 
> 634) Enqueuing flush of Memtable-schema_columnfamilies@225225949(978/1222 
> serialized/live bytes, 21 ops)
>  INFO [FlushWriter:3] 2012-05-09 11:25:35,687 Memtable.java (line 266) 
> Writing Memtable-schema_columnfamilies@225225949(978/1222 serialized/live 
> bytes, 21 ops)
>  INFO [FlushWriter:3] 2012-05-09 11:25:35,748 Memtable.java (line 307) 
> Completed flushing 
> /var/lib/cassandra/data/system/schema_columnfamilies/system-schema_columnfamilies-hc-34-Data.db
>  (1041 bytes)
>  INFO [MigrationStage:1] 2012-05-09 11:25:35,749 ColumnFamilyStore.java (line 
> 634) Enqueuing flush of Memtable-schema_columns@213209572(586/732 
> serialized/live bytes, 12 ops)
>  INFO [FlushWriter:3] 2012-05-09 11:25:35,750 Memtable.java (line 266) 
> Writing Memtable-schema_columns@213209572(586/732 serialized/live bytes, 12 
> ops)
>  INFO [FlushWriter:3] 2012-05-09 11:25:35,812 Memtable.java (line 307) 
> Completed flushing 
> /var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-28-Data.db
>  (649 bytes)
>  INFO [CompactionExecutor:20] 2012-05-09 11:25:35,814 CompactionTask.java 
> (line 114) Compacting 
> [SSTableReader(path='/var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-27-Data.db'),
>  SSTableReader
> (path='/var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-25-Data.db'),
>  
> SSTableReader(path='/var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-26-Data.db'),
>  SSTableReader(path
> ='/var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-28-Data.db')]
>  INFO [MigrationStage:1] 2012-05-09 11:25:35,918 ColumnFamilyStore.java (line 
> 634) Enqueuing flush of Memtable-Client@864320066(372/465 serialized/live 
> bytes, 6 ops)
>  INFO [FlushWriter:3] 2012-05-09 11:25:35,919 Memtable.java (line 266) 
> Writing Memtable-Client@864320066(372/465 serialized/live bytes, 6 ops)
>  INFO [CompactionExecutor:20] 2012-05-09 11:25:35,945 CompactionTask.java 
> (line 225) Compacted to 
> [/var/lib/cassandra/data/system/schema_columns/system-schema_columns-hc-29-Data.db,].
>   22,486 to 20,621 (~91% of orig
> inal) bytes for 2 keys at 0.150120MB/s.  Time: 131ms.
>  INFO [FlushWriter:3] 2012-05-09 11:25:36,013 Memtable.java (line 307) 
> Completed flushing 
> /var/lib/cassandra/data/Disco/Client/Disco-Client-hc-5-Data.db (407 bytes)
> ERROR [MigrationStage:1] 2012-05-

[jira] [Updated] (CASSANDRA-4242) Name of parameters should be available in CqlPreparedResult

2012-05-13 Thread Pierre Chalamet (JIRA)


 [ 
https://issues.apache.org/jira/browse/CASSANDRA-4242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Pierre Chalamet updated CASSANDRA-4242:
---

Description: 
Client side, it could be nice to have the name of parameters in 
CqlPreparedResult. This could allow parameters mapping by name instead of by 
index.

{code}
struct CqlNameType {
1: required binary key,
2: required string type
}

struct CqlPreparedResult {
1: required i32 itemId,
2: required i32 count,
3: optional list variable_types,
4: optional list name_types
}
{code}

  was:
Client side, it could be nice to have the name of parameters in 
CqlPreparedResult. This could allow parameters mapping by name instead of by 
index.

{code}
struct CqlPreparedResult {
1: required i32 itemId,
2: required i32 count,
3: optional list variable_types
>>  4: optional map name_types  <<
}
{code}


> Name of parameters should be available in CqlPreparedResult
> ---
>
> Key: CASSANDRA-4242
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4242
> Project: Cassandra
>  Issue Type: Improvement
>  Components: Core
>Affects Versions: 1.1.0
>Reporter: Pierre Chalamet
>Priority: Minor
> Attachments: 4242.txt
>
>
> Client side, it could be nice to have the name of parameters in 
> CqlPreparedResult. This could allow parameters mapping by name instead of by 
> index.
> {code}
> struct CqlNameType {
> 1: required binary key,
>   2: required string type
> }
> struct CqlPreparedResult {
> 1: required i32 itemId,
> 2: required i32 count,
> 3: optional list variable_types,
> 4: optional list name_types
> }
> {code}

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

[jira] [Updated] (CASSANDRA-4242) Name of parameters should be available in CqlPreparedResult

2012-05-13 Thread Pierre Chalamet (JIRA)


 [ 
https://issues.apache.org/jira/browse/CASSANDRA-4242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Pierre Chalamet updated CASSANDRA-4242:
---

Attachment: (was: 4242.txt)

> Name of parameters should be available in CqlPreparedResult
> ---
>
> Key: CASSANDRA-4242
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4242
> Project: Cassandra
>  Issue Type: Improvement
>  Components: Core
>Affects Versions: 1.1.0
>Reporter: Pierre Chalamet
>Priority: Minor
> Attachments: 4242.txt
>
>
> Client side, it could be nice to have the name of parameters in 
> CqlPreparedResult. This could allow parameters mapping by name instead of by 
> index.
> {code}
> struct CqlPreparedResult {
> 1: required i32 itemId,
> 2: required i32 count,
> 3: optional list variable_types
> >>  4: optional map name_types  <<
> }
> {code}

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

[jira] [Updated] (CASSANDRA-4242) Name of parameters should be available in CqlPreparedResult

2012-05-13 Thread Pierre Chalamet (JIRA)


 [ 
https://issues.apache.org/jira/browse/CASSANDRA-4242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Pierre Chalamet updated CASSANDRA-4242:
---

Attachment: 4242.txt

use list instead of map since the order is important

> Name of parameters should be available in CqlPreparedResult
> ---
>
> Key: CASSANDRA-4242
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4242
> Project: Cassandra
>  Issue Type: Improvement
>  Components: Core
>Affects Versions: 1.1.0
>Reporter: Pierre Chalamet
>Priority: Minor
> Attachments: 4242.txt
>
>
> Client side, it could be nice to have the name of parameters in 
> CqlPreparedResult. This could allow parameters mapping by name instead of by 
> index.
> {code}
> struct CqlPreparedResult {
> 1: required i32 itemId,
> 2: required i32 count,
> 3: optional list variable_types
> >>  4: optional map name_types  <<
> }
> {code}

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

git commit: Fix CQL3 index dropping

[jira] [Commented] (CASSANDRA-4230) Deleting a CF always produces an error and that CF remains in an unknown state

[jira] [Commented] (CASSANDRA-4230) Deleting a CF always produces an error and that CF remains in an unknown state

[jira] [Updated] (CASSANDRA-4230) Deleting a CF always produces an error and that CF remains in an unknown state

[jira] [Commented] (CASSANDRA-4230) Deleting a CF always produces an error and that CF remains in an unknown state

[jira] [Updated] (CASSANDRA-4242) Name of parameters should be available in CqlPreparedResult

[jira] [Updated] (CASSANDRA-4242) Name of parameters should be available in CqlPreparedResult

[jira] [Updated] (CASSANDRA-4242) Name of parameters should be available in CqlPreparedResult

8 matches

Site Navigation

Mail list logo

Footer information