· 8 years ago · Jan 23, 2018, 09:14 PM
1CREATE EXTERNAL TABLE IF NOT EXISTS test_messages
2 PARTITIONED BY (dt string)
3 ROW FORMAT SERDE
4 "com.twitter.elephantbird.hive.serde.ProtobufDeserializer"
5 WITH serdeproperties (
6 "serialization.class"="path.to.my.java.class.ProtoClass")
7 STORED AS SEQUENCEFILE;
8
9ALTER TABLE test_messages_20180116_20180116 ADD PARTITION (dt = '20171117') LOCATION '/test/20171117'
10
11select * from test_messages limit 1;
12
13Failed with exception java.io.IOException:java.lang.IllegalArgumentException: FieldDescriptor does not match message type.