search

fullcontact / hadoop-sstable

Splittable Input Format for Reading Cassandra SSTables Directly
Apache License 2.0
49 stars 14 forks source link

Runtime Exception while running SimpleExample MR job #8

Closed gadodia closed 9 years ago

gadodia commented 9 years ago

14/11/03 15:20:22 WARN mapred.LocalJobRunner: job_local_0001 java.lang.RuntimeException: Error configuring SSTable reader. Cannot proceed at com.fullcontact.sstable.hadoop.mapreduce.SSTableRecordReader.getCreateColumnFamilyStatement(SSTableRecordReader.java:144) at com.fullcontact.sstable.hadoop.mapreduce.SSTableRecordReader.initializeCfMetaData(SSTableRecordReader.java:122) at com.fullcontact.sstable.hadoop.mapreduce.SSTableRecordReader.initialize(SSTableRecordReader.java:69) at org.apache.hadoop.mapred.MapTask$NewTrackingRecordReader.initialize(MapTask.java:522) at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:763) at org.apache.hadoop.mapred.MapTask.run(MapTask.java:370) at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) Caused by: org.apache.cassandra.exceptions.SyntaxException: line 1:13 no viable alternative at input '.' at org.apache.cassandra.cql3.CqlParser.throwLastRecognitionError(CqlParser.java:220) at org.apache.cassandra.cql3.QueryProcessor.parseStatement(QueryProcessor.java:261) at com.fullcontact.sstable.hadoop.mapreduce.SSTableRecordReader.getCreateColumnFamilyStatement(SSTableRecordReader.java:141) ... 6 more 14/11/03 15:20:23 INFO mapred.JobClient: Job complete: job_local_0001 14/11/03 15:20:23 INFO mapred.JobClient: Counters: 0 14/11/03 15:20:23 INFO example.SimpleExample: Total runtime: 2s