Created
July 10, 2012 15:02
-
-
Save zamith/3083876 to your computer and use it in GitHub Desktop.
Cassandra error
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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(); | |
} |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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