我用的是cdh集群。
在编写inputformat之后,我将其复制到所有hiveserver2 lib并重新启动hiveserver2。
当我使用inputformat创建一个表并编写一个像select*这样的公共查询时,它可以运行并且一切正常!
但是!
当我用mapreduce编写一个查询时 'where'
或者 'join'
或者 'count'
,它将抛出类未找到错误:
错误:java.io.ioexception:找不到类com.my.parquet.myparquetinputformat
在
org.apache.hadoop.hive.ql.io.combinehiveinputformat.getrecordreader(combinehiveinputformat)。java:714)
在org.apache.hadoop.mapred.maptask$trackedrecordreader.(maptask。java:169)
在org.apache.hadoop.mapred.maptask.runoldmapper(maptask。java:432)
在org.apache.hadoop.mapred.maptask.run(maptask。java:343)
在org.apache.hadoop.mapred.yarnchild$2.run(yarnchild。java:164)
位于java.security.accesscontroller.doprivileged(本机方法)
在javax.security.auth.subject.doas(subject。java:415)
在
org.apache.hadoop.security.usergroupinformation.doas(用户组信息。java:1693)
在org.apache.hadoop.mapred.yarnchild.main(yarnchild。java:158)
希望你能帮忙!
暂无答案!
目前还没有任何答案,快来回答吧!