尝试新的 CQL 3 时出现 Cassandra 错误

Question

我下载了Cassandra 1.1.1并在3版本下启动了cqlsh

我尝试创建一个新的列族：

CREATE TABLE stats (
 pid          blob,
 period      int,
 targetid     blob,
 sum         counter,
PRIMARY KEY (pid, period, targetid)
);

但我得到了这个：

Traceback（最近一次调用最后一次）： 文件“./cqlsh”，第 908 行，在 perform_statement self.cursor.execute（语句，解码器=解码器） 文件“./../lib/cql-internal-only-1.0.10.zip/cql-1.0.10/cql/cursor.py”，第 117 行，在执行中 响应 = self.handle_cql_execution_errors（doquery，prepared_q，压缩） 文件“./../lib/cql-internal-only-1.0.10.zip/cql-1.0.10/cql/cursor.py”，第 132 行，在 handle_cql_execution_errors 返回执行器（*args，**kwargs） 文件“./../lib/cql-internal-only-1.0.10.zip/cql-1.0.10/cql/cassandra/Cas​​sandra.py”，第 1583 行，在 execute_cql_query self.send_execute_cql_query（查询，压缩） 文件“./../lib/cql-internal-only-1.0.10.zip/cql-1.0.10/cql/cassandra/Cas​​sandra.py”，第 1593 行，在 send_execute_cql_query self.oprot.trans.flush() 文件“./../lib/thrift-python-internal-only-0.7.0.zip/thrift/transport/TTransport.py”，第 293 行，齐平 自我。_trans.write(buf) 文件“./../lib/thrift-python-internal-only-0.7.0.zip/thrift/transport/TSocket.py”，第 117 行，写入 加 = self.handle.send(buff) 错误：[Errno 32] 管道损坏

在服务器控制台上：

处理消息时发生错误。 java.lang.IllegalArgumentException 在 java.nio.Buffer.limit(Buffer.java:247) 在 org.apache.cassandra.db.marshal.AbstractCompositeType.getBytes(AbstractCompositeType.java:51) 在 org.apache.cassandra.db.marshal.AbstractCompositeType.getWithShortLength(AbstractCompositeType.java:60) 在 org.apache.cassandra.db.marshal.AbstractCompositeType.getString(AbstractCompositeType.java:140) 在 org.apache.cassandra.config.CFMetaData.validate(CFMetaData.java:929) 在 org.apache.cassandra.service.MigrationManager.announceNewColumnFamily(MigrationManager.java:131) 在 org.apache.cassandra.cql3.statements.CreateColumnFamilyStatement.announceMigration(CreateColumnFamilyStatement.java:83) 在 org.apache.cassandra.cql3.statements.SchemaAlteringStatement.execute（SchemaAlteringStatement.java:99） 在 org.apache.cassandra.cql3.QueryProcessor.processStatement（QueryProcessor.java:108） 在 org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:121) 在 org.apache.cassandra.thrift.CassandraServer.execute_cql_query(CassandraServer.java:1237) 在 org.apache.cassandra.thrift.Cassandra$Processor$execute_cql_query.getResult(Cassandra.java:3542) 在 org.apache.cassandra.thrift.Cassandra$Processor$execute_cql_query.getResult(Cassandra.java:3530) 在 org.apache.thrift.ProcessFunction.process(ProcessFunction.java:32) 在 org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:34) 在 org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:186) 在 java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) 在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) 在 java.lang.Thread.run(Thread.java:680)

Answer 1

我建议在https://issues.apache.org/jira/browse/CASSANDRA 报告错误。