调用mapreduce时在配置单元上找不到我的inputformat

aoyhnmkz  于 2021-05-29  发布在  Hadoop
关注(0)|答案(0)|浏览(206)

我用的是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)
希望你能帮忙!

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题