Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- hive> show create table light_column;
- OK
- CREATE EXTERNAL TABLE light_column(
- ise string COMMENT 'from deserializer',
- filtre int COMMENT 'from deserializer',
- value_1 int COMMENT 'from deserializer')
- ROW FORMAT SERDE
- 'org.apache.hadoop.hive.cassandra.serde.CassandraColumnSerDe'
- STORED BY
- 'org.apache.hadoop.hive.cassandra.CassandraStorageHandler'
- WITH SERDEPROPERTIES (
- 'cassandra.partitioner'='org.apache.cassandra.dht.Murmur3Partitioner',
- 'cassandra.cf.name'='light_column',
- 'serialization.format'='1',
- 'cassandra.columns.mapping'=':key, filtre, value_1')
- LOCATION
- 'hdfs://localhost:54310/user/hive/warehouse/light_column'
- TBLPROPERTIES (
- 'cassandra.ks.name'='pns_fr',
- 'cassandra.cf.name'='light_column',
- 'transient_lastDdlTime'='1377457665')
- Time taken: 4.817 seconds
- hive> select * from light_column;
- OK
- xxxx 2 54738
- yyyy 1 18504
- zzzz 2 3601
- cyril14 100 82
- Time taken: 0.983 seconds
- hive> show create table light_column_cql3;
- OK
- CREATE EXTERNAL TABLE light_column_cql3(
- ise string COMMENT 'from deserializer',
- filter smallint COMMENT 'from deserializer',
- value_1 smallint COMMENT 'from deserializer')
- ROW FORMAT SERDE
- 'org.apache.hadoop.hive.cassandra.serde.cql.CqlSerDe'
- STORED BY
- 'org.apache.hadoop.hive.cassandra.cql.CqlStorageHandler'
- WITH SERDEPROPERTIES (
- 'cassandra.cf.name'='light_column_cql3',
- 'serialization.format'='1',
- 'cassandra.columns.mapping'=':key, filter, value_1')
- LOCATION
- 'hdfs://localhost:54310/user/hive/warehouse/light_column_cql3'
- TBLPROPERTIES (
- 'cassandra.ks.name'='pns_fr',
- 'cassandra.cf.name'='light_column_cql3',
- 'transient_lastDdlTime'='1377455121')
- Time taken: 0.103 seconds
- hive> select * from light_column_cql3;
- OK
- Failed with exception java.io.IOException:java.lang.ClassCastException: org.apache.hadoop.io.MapWritable cannot be cast to org.apache.hadoop.io.WritableComparable
- Time taken: 0.39 seconds
- 2013-08-25 22:08:46,557 ERROR CliDriver (SessionState.java:printError(401)) - Failed with exception java.io.IOException:java.lang.ClassCastException: org.apache.hadoop.io.MapWritable cannot be cast to org.apache.hadoop.io.WritableComparable
- java.io.IOException: java.lang.ClassCastException: org.apache.hadoop.io.MapWritable cannot be cast to org.apache.hadoop.io.WritableComparable
- at org.apache.hadoop.hive.ql.exec.FetchOperator.getNextRow(FetchOperator.java:521)
- at org.apache.hadoop.hive.ql.exec.FetchOperator.pushRow(FetchOperator.java:466)
- at org.apache.hadoop.hive.ql.exec.FetchTask.fetch(FetchTask.java:136)
- at org.apache.hadoop.hive.ql.Driver.getResults(Driver.java:1387)
- at org.apache.hadoop.hive.cli.CliDriver.processLocalCmd(CliDriver.java:270)
- at org.apache.hadoop.hive.cli.CliDriver.processCmd(CliDriver.java:216)
- at org.apache.hadoop.hive.cli.CliDriver.processLine(CliDriver.java:412)
- at org.apache.hadoop.hive.cli.CliDriver.run(CliDriver.java:755)
- at org.apache.hadoop.hive.cli.CliDriver.main(CliDriver.java:613)
- at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
- at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
- at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
- at java.lang.reflect.Method.invoke(Method.java:601)
- at org.apache.hadoop.util.RunJar.main(RunJar.java:160)
- Caused by: java.lang.ClassCastException: org.apache.hadoop.io.MapWritable cannot be cast to org.apache.hadoop.io.WritableComparable
- at org.apache.hadoop.hive.ql.exec.FetchOperator.getRecordReader(FetchOperator.java:431)
- at org.apache.hadoop.hive.ql.exec.FetchOperator.getNextRow(FetchOperator.java:486)
- ... 13 more
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement