Storm-hbase集成问题

来源：6-10 -Storm集群部署之Storm集群部署及启动

慕函数7570418

2019-10-30

我在Storm的spout里面遍历hbase的整个表的数据作为数据源，可是一运行，就报io中断导致获取的hbase数据为空，具体实现是这样的。
图片描述
划红线的地方一直报io中断异常。

这个是不是这两个for循环导致的啊
如果是的话那又如何才能获取hbase中数据呢

写回答

3回答

慕函数7570418

提问者

2019-10-30

//img1.sycdn.imooc.com/szimg/5db9966609bfc4db12830738.jpg 还有这样

慕函数7570418

提问者

2019-10-30

//img.mukewang.com/szimg/5db9938c09aa094313430686.jpg 就像这样

Michael_PK

2019-10-30

空的东西，先判断一下再处理

慕函数7570418

你好，我想问一下。我有个整合hbase的storm。从hbase中拿数据到storm进行处理之后再放回hbase；但是就像上面示例一样。一直报io中断异常。我以为读取hbase行键的for循环有问题。然后用迭代器获取；但还是在迭代器的while(it.hasnext)报java.io.InterruptedIOException 在通过表获取数据对象rolesRs1 = userRoleTable1.getScanner(scan11);这行也报java.io.InterruptedIOException；请问这该怎么解决啊

2019-10-30

共1条回复

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

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

518 学习 · 143 问题

查看课程

相似问题

storm和hbase整合巨坑

回答 2

storm读取数据问题

回答 1

关于storm里面的对象生存周期问题

回答 1

一个很重要业务上的问题？

回答 1

storm的worker自动重启

回答 1

打开慕课网App查看更多内容