Storm-hbase集成问题

Question

我在Storm的spout里面遍历hbase的整个表的数据作为数据源，可是一运行，就报io中断导致获取的hbase数据为空，具体实现是这样的。

划红线的地方一直报io中断异常。

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

Answer 1

提问者 慕函数7570418 2019-10-30 21:55:57

还有这样

Answer 2

提问者 慕函数7570418 2019-10-30 21:43:58

就像这样

Answer 3

Michael_PK 2019-10-30 16:41:04

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

• 提问者 慕函数7570418 #1

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