想请教个问题。背景:目前HBaseSinkFunction中数据是先放BufferM#Flink-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

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

2020-07-06 20:17:18 903 1

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

取消 提交回答
全部回答(1)
  • 黄二刀
    2020-07-06 20:18:20

    job restart 后,hbase sink 会重新 flush 这部分数据(上游会重发这些数据)。

    0 0
相关问答

1

回答

flink sink 如何做到数据准确性?

2018-10-18 13:59:26 2885浏览量 回答数 1

1

回答

Flink CDC 在生产环境项目背景是怎么样的?

2022-01-19 16:34:13 1333浏览量 回答数 1

1

回答

Flink CDC项目运行环境与现状是什么样的?

2022-01-19 16:35:29 1336浏览量 回答数 1

1

回答

Flink CDC 区别于其他数据集成框架的一个核心点是什么?

2022-01-19 16:18:49 504浏览量 回答数 1

1

回答

《Flink CDC:新一代数据集成框架》这本书可以在哪里下载?

2022-01-19 15:14:52 3946浏览量 回答数 1

1

回答

Flink CDC 的出现为数据入湖架构提供了哪些新思路?

2022-01-19 16:16:53 495浏览量 回答数 1

1

回答

Flink CDC 数据入湖的挑战有哪些?

2022-01-19 16:19:54 438浏览量 回答数 1

1

回答

Flink CDC中的CDC是什么意思?

2022-01-19 15:15:09 4354浏览量 回答数 1

1

回答

Flink CDC 中使用最多且最重要的是什么?

2022-01-19 15:24:00 2517浏览量 回答数 1

1

回答

Flink SQL中的CDC格式是什么?

2021-12-08 21:55:34 209浏览量 回答数 1
+关注
黄一刀
Java菜鸟一只,基层法律工作者。
0
文章
1270
问答
问答排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载