hbase写入时会有buffer [1],按照时间或者数据量写入 [2],可以看下是不是调整过?



1. 
https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/sink/HBaseSinkFunction.java
2. 
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/hbase.html
 







在 2020-09-23 17:55:44,"kandy.wang" <kandy1...@163.com> 写道:
>insert into hive.temp_dw.day_order_index select rowkey, ROW(orderN,)
>from
>(
>    select order_date as rowkey,
>    count(distinct parent_sn) as orderN,
>    ....
>    group by order_date
>)
>
>
>通过sql查hbase时,有时查到数据,有时候查不到数据。是不是group操作,会有下游算子 发送撤回消息,导致在delete 
>hbase的某条rowkey数据,导致客户端查不到数据?
>我理解 hbase sink 应该是upsert数据吧。会不会先delete 再put 导致这样的现象 ?

Reply via email to