Hi > 通过sql查hbase时,有时查到数据,有时候查不到数据。是不是group操作,会有下游算子 发送撤回消息,导致在delete > hbase的某条rowkey数据,导致客户端查不到数据? > 我理解 hbase sink 应该是upsert数据吧。会不会先delete 再put 导致这样的现象 ?
是的,group by 算子会像下游 hbase sink发retract消息,hbase sink处理retract消息的实现就是先delete再insert,所以去查hbase的时候就会碰到你说的有时查不到的情况。 祝好 Leonard