首页 文章

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

提问于
浏览
2

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

我试图创建一个新的列族:

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

但我得到了这个:

回溯(最近一次调用最后一次):文件“./cqlsh”,第908行,在perform_statement self.cursor.execute(statement,decoder = decoder)文件“./../lib/cql-internal-only-1.0 . 10.zip/cql-1.0.10/cql/cursor.py“,第117行,执行响应= self.handle_cql_execution_errors(doquery,prepared_q,compress)文件”./../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/Cassandra.py“,第1583行,在execute_cql_query中self.send_execute_cql_query(查询,压缩)文件”./../lib/cql-internal-only-1.0.10 .zip / cql-1.0.10 / cql / cassandra / Cassandra.py“,第1593行,在send_execute_cql_query中self.oprot.trans.flush()文件”./../lib/thrift-python-internal-only-0.7 .0.zip / thrift / transport / TTransport.py“,第293行,在flush self._trans.write(buf)文件中”./../lib/thrift-python-internal-only-0.7.0.zip/ thrift / transport / TSocket.py“,第117行,写入加= self.hand le.send(buff)错误:[Errno 32]管道破裂

并在服务器控制台上:

处理消息时出错 . 位于org.apache.cassandra.db的org.apache.cassandra.db.marshal.AbstractCompositeType.getBytes(AbstractCompositeType.java:51)的java.nio.Buffer.limit(Buffer.java:247)中的java.lang.IllegalArgumentException . marshal.AbstractCompositeType.getWithShortLength(AbstractCompositeType.java:60)位于org.apache.cassandra.config.CFMetaData.validate(CFMetaData.java)的org.apache.cassandra.db.marshal.AbstractCompositeType.getString(AbstractCompositeType.java:140) 929)org.apache.cassandra.service.MigrationManager.announceNewColumnFamily(MigrationManager.java:131)org.apache.cassandra.cql3.statements.CreateColumnFamilyStatement.announceMigration(CreateColumnFamilyStatement.java:83)at org.apache.cassandra.cql3 .statements.SchemaAlteringStatement.execute(SchemaAlteringStatement.java:99)atg.apache.cassandra.cql3.QueryProcessor.processStatement(QueryProcessor.java:108)org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:121) )在org.apache.cassandra.thrift.CassandraServer.execute_cq l_query(CassandraServer.java:1237)org.apache.cassandra.thrift.Cassandra $ Processor $ execute_cql_query.getResult(Cassandra.java:3542)at 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)at java.util.concurrent.ThreadPoolExecutor $ Worker.run(ThreadPoolExecutor.java:908)at java . lang.Thread.run(Thread.java:680)

1 回答

相关问题