开发者社区> 问答> 正文

想请教个问题。背景:目前HBaseSinkFunction中数据是先放BufferM#Flink

想请教个问题。 背景:目前HBaseSinkFunction中数据是先放BufferMutator里的,满足条件后批量flush。 问题:如果某个时间数据未进行flush,但是应用挂掉了,这部分数据是否就丢失了?#Flink

展开
收起
黄一刀 2020-07-06 20:17:18 1334 0
1 条回答
写回答
取消 提交回答
  • job restart 后,hbase sink 会重新 flush 这部分数据(上游会重发这些数据)。

    2020-07-06 20:18:20
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载