storm整合hive报错,麻烦老师您帮忙看下,是什么地方出现了问题?

来源:4-9 -Storm词频案例编程之Spout功能实现

mybatis

2018-10-13

17982 [Thread-22-HiveBolt-executor[1 1]] ERROR o.a.s.h.b.HiveBolt - Failed to create HiveWriter for endpoint: {metaStoreUri=‘thrift://192.168.10.108:9083’, database=‘mission’, table=‘test_table’, partitionVals=[] }
org.apache.storm.hive.common.HiveWriter$ConnectFailure: Failed connecting to EndPoint {metaStoreUri=‘thrift://192.168.10.108:9083’, database=‘mission’, table=‘test_table’, partitionVals=[] }
at org.apache.storm.hive.common.HiveWriter.(HiveWriter.java:80) ~[storm-hive-1.1.2.jar:1.1.2]

写回答

8回答

mybatis

提问者

2018-10-13

storm是通过ambari安装的,如何重新编译?

0
1
Michael_PK
那需要问你们运维团队了,如何自定义修改源码升级
2018-10-13
共1条回复

mybatis

提问者

2018-10-13

我看了下storm-hive中依赖的hive hcatelog是0.14.0版本,是否可以通过添加依赖hive-storm依赖的时候通过exclusion排除掉相应的依赖, 然后再通过单独添加高版本的依赖进行解决~

0
0

mybatis

提问者

2018-10-13

metastore的端口9083处于监听状态

0
1
Michael_PK
那你启动一个hive看下成功执行SQL不
2018-10-13
共1条回复

Michael_PK

2018-10-13

版本是一定要要求的

0
0

Michael_PK

2018-10-13

这个他们两能否兼容是个问题。尝试storm重新编译,用hive新的版本,如果还不兼容,就不好整了

0
0

mybatis

提问者

2018-10-13

启动了

0
0

mybatis

提问者

2018-10-13

对了,storm-hive版本是1.1.2, 线上hive版本是3.0.0,是使用hdp3.0安装的整个生态,初步判断版本问题, 请老师指点一下相应的解决方案~

0
0

Michael_PK

2018-10-13

meta store启动没

0
0

Java大数据实战,巧用Storm快速切入实时流处理领域

深入Storm内部机制,logstash+kafka,快速切入大数据实时流处理

518 学习 · 143 问题

查看课程