Skip to content

Instantly share code, notes, and snippets.

@zamith
Created July 10, 2012 15:02
Show Gist options
  • Save zamith/3083876 to your computer and use it in GitHub Desktop.
Save zamith/3083876 to your computer and use it in GitHub Desktop.
Cassandra error
List column_families = new ArrayList();
CfDef base_columns_cf_definition = new CfDef();
base_columns_cf_definition.setKeyspace("Indexes");
base_columns_cf_definition.setName("PrimaryIndexes");
base_columns_cf_definition.setColumn_type("Standard");
base_columns_cf_definition.setComparator_type("BytesType");
base_columns_cf_definition.setKey_validation_class("BytesType");
base_columns_cf_definition.setDefault_validation_class("BytesType");
try {
base_columns_cf_definition.setKey_alias("key".getBytes("UTF8"));
} catch (UnsupportedEncodingException e1) {
e1.printStackTrace();
}
base_columns_cf_definition.setCaching("all");
column_families.add(base_columns_cf_definition);
CfDef base_columns_cf_definition_index = new CfDef();
base_columns_cf_definition_index.setKeyspace("Indexes");
base_columns_cf_definition_index.setName("SecundaryIndexes");
base_columns_cf_definition_index.setColumn_type("Standard");
base_columns_cf_definition_index.setComparator_type("BytesType");
base_columns_cf_definition_index.setKey_validation_class("BytesType");
base_columns_cf_definition_index.setDefault_validation_class("BytesType");
try {
base_columns_cf_definition_index.setKey_alias("key".getBytes("UTF8"));
} catch (UnsupportedEncodingException e1) {
e1.printStackTrace();
}
base_columns_cf_definition_index.setCaching("all");
column_families.add(base_columns_cf_definition_index);
KsDef keyspace_definition = new KsDef();
keyspace_definition.setName("Indexes");
keyspace_definition.setCf_defs(column_families);
keyspace_definition.setStrategy_class(props.getProperty("replication_strategy"));
Map strategy_options = new HashMap();
strategy_options.put("replication_factor", props.getProperty("replication_factor"));
keyspace_definition.setStrategy_options(strategy_options);
String[] conns = props.getProperty("cluster_ip_list").split(";");
TSocket tsocket = new TSocket(conns[0], 9160);
TFramedTransport transport = new TFramedTransport(tsocket);
Cassandra.Client client = new Cassandra.Client(new TBinaryProtocol(transport));
try {
transport.open();
} catch (TTransportException e) {
e.printStackTrace();
}
try {
client.system_add_keyspace(keyspace_definition);
} catch (InvalidRequestException e) {
e.printStackTrace();
} catch (TException e) {
e.printStackTrace();
} catch (SchemaDisagreementException e) {
e.printStackTrace();
}
org.apache.cassandra.db.marshal.MarshalException: invalid UTF8 bytes 4ffc414b
at org.apache.cassandra.db.marshal.UTF8Type.getString(UTF8Type.java:56)
at org.apache.cassandra.cql3.ColumnIdentifier.<init>(ColumnIdentifier.java:47)
at org.apache.cassandra.cql3.CFDefinition.getValueId(CFDefinition.java:140)
at org.apache.cassandra.cql3.CFDefinition.<init>(CFDefinition.java:104)
at org.apache.cassandra.config.CFMetaData.updateCfDef(CFMetaData.java:1303)
at org.apache.cassandra.config.CFMetaData.valueAlias(CFMetaData.java:227)
at org.apache.cassandra.config.CFMetaData.fromSchemaNoColumns(CFMetaData.java:1194)
at org.apache.cassandra.config.CFMetaData.fromSchema(CFMetaData.java:1215)
at org.apache.cassandra.config.KSMetaData.deserializeColumnFamilies(KSMetaData.java:291)
at org.apache.cassandra.db.DefsTable.mergeColumnFamilies(DefsTable.java:359)
at org.apache.cassandra.db.DefsTable.mergeSchema(DefsTable.java:271)
at org.apache.cassandra.db.DefsTable.mergeRemoteSchema(DefsTable.java:249)
at org.apache.cassandra.db.DefinitionsUpdateVerbHandler$1.runMayThrow(DefinitionsUpdateVerbHandler.java:48)
at org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:30)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
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)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment