Hi
> 通过sql查hbase时,有时查到数据,有时候查不到数据。是不是group操作,会有下游算子 发送撤回消息,导致在delete 
> hbase的某条rowkey数据,导致客户端查不到数据?
> 我理解 hbase sink 应该是upsert数据吧。会不会先delete 再put 导致这样的现象 ?

是的,group by 算子会像下游 hbase sink发retract消息,hbase 
sink处理retract消息的实现就是先delete再insert,所以去查hbase的时候就会碰到你说的有时查不到的情况。

祝好
Leonard

回复