Advertisement
Guest User

hive errors with cql3 column family

a guest
Aug 25th, 2013
48
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 3.72 KB | None | 0 0
  1. hive> show create table light_column;
  2. OK
  3. CREATE EXTERNAL TABLE light_column(
  4. ise string COMMENT 'from deserializer',
  5. filtre int COMMENT 'from deserializer',
  6. value_1 int COMMENT 'from deserializer')
  7. ROW FORMAT SERDE
  8. 'org.apache.hadoop.hive.cassandra.serde.CassandraColumnSerDe'
  9. STORED BY
  10. 'org.apache.hadoop.hive.cassandra.CassandraStorageHandler'
  11. WITH SERDEPROPERTIES (
  12. 'cassandra.partitioner'='org.apache.cassandra.dht.Murmur3Partitioner',
  13. 'cassandra.cf.name'='light_column',
  14. 'serialization.format'='1',
  15. 'cassandra.columns.mapping'=':key, filtre, value_1')
  16. LOCATION
  17. 'hdfs://localhost:54310/user/hive/warehouse/light_column'
  18. TBLPROPERTIES (
  19. 'cassandra.ks.name'='pns_fr',
  20. 'cassandra.cf.name'='light_column',
  21. 'transient_lastDdlTime'='1377457665')
  22. Time taken: 4.817 seconds
  23. hive> select * from light_column;
  24. OK
  25. xxxx 2 54738
  26. yyyy 1 18504
  27. zzzz 2 3601
  28. cyril14 100 82
  29. Time taken: 0.983 seconds
  30. hive> show create table light_column_cql3;
  31. OK
  32. CREATE EXTERNAL TABLE light_column_cql3(
  33. ise string COMMENT 'from deserializer',
  34. filter smallint COMMENT 'from deserializer',
  35. value_1 smallint COMMENT 'from deserializer')
  36. ROW FORMAT SERDE
  37. 'org.apache.hadoop.hive.cassandra.serde.cql.CqlSerDe'
  38. STORED BY
  39. 'org.apache.hadoop.hive.cassandra.cql.CqlStorageHandler'
  40. WITH SERDEPROPERTIES (
  41. 'cassandra.cf.name'='light_column_cql3',
  42. 'serialization.format'='1',
  43. 'cassandra.columns.mapping'=':key, filter, value_1')
  44. LOCATION
  45. 'hdfs://localhost:54310/user/hive/warehouse/light_column_cql3'
  46. TBLPROPERTIES (
  47. 'cassandra.ks.name'='pns_fr',
  48. 'cassandra.cf.name'='light_column_cql3',
  49. 'transient_lastDdlTime'='1377455121')
  50. Time taken: 0.103 seconds
  51. hive> select * from light_column_cql3;
  52. OK
  53. Failed with exception java.io.IOException:java.lang.ClassCastException: org.apache.hadoop.io.MapWritable cannot be cast to org.apache.hadoop.io.WritableComparable
  54. Time taken: 0.39 seconds
  55.  
  56. 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
  57. java.io.IOException: java.lang.ClassCastException: org.apache.hadoop.io.MapWritable cannot be cast to org.apache.hadoop.io.WritableComparable
  58. at org.apache.hadoop.hive.ql.exec.FetchOperator.getNextRow(FetchOperator.java:521)
  59. at org.apache.hadoop.hive.ql.exec.FetchOperator.pushRow(FetchOperator.java:466)
  60. at org.apache.hadoop.hive.ql.exec.FetchTask.fetch(FetchTask.java:136)
  61. at org.apache.hadoop.hive.ql.Driver.getResults(Driver.java:1387)
  62. at org.apache.hadoop.hive.cli.CliDriver.processLocalCmd(CliDriver.java:270)
  63. at org.apache.hadoop.hive.cli.CliDriver.processCmd(CliDriver.java:216)
  64. at org.apache.hadoop.hive.cli.CliDriver.processLine(CliDriver.java:412)
  65. at org.apache.hadoop.hive.cli.CliDriver.run(CliDriver.java:755)
  66. at org.apache.hadoop.hive.cli.CliDriver.main(CliDriver.java:613)
  67. at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  68. at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
  69. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  70. at java.lang.reflect.Method.invoke(Method.java:601)
  71. at org.apache.hadoop.util.RunJar.main(RunJar.java:160)
  72. Caused by: java.lang.ClassCastException: org.apache.hadoop.io.MapWritable cannot be cast to org.apache.hadoop.io.WritableComparable
  73. at org.apache.hadoop.hive.ql.exec.FetchOperator.getRecordReader(FetchOperator.java:431)
  74. at org.apache.hadoop.hive.ql.exec.FetchOperator.getNextRow(FetchOperator.java:486)
  75. ... 13 more
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement