Flink 案例实战演练 Flink维表Join实践 常见的维表Join方式有四种: 预加载维表 热存储维表 广播维表 Temporal tab...
1 、顺序保证难点 Kafka 作为一款性能优秀的消息队列,在分布式事务中有着广泛地应用,其为了做到水平扩展,达到提高并发的目的,将一个 top...
背景 在电商、金融、银行、支付等涉及到金钱相关的领域,为了安全起见,一般都有对账的需求。 比如,对于订单支付事件,用户通过某宝付款,虽然用户支付...
CDC 变更数据捕获技术可以将源数据库的增量变动记录,同步到一个或多个数据目的。本文基于腾讯云 Oceanus 提供的 Flink CDC 引擎...
前言 工具的进化一直是人类生产力进步的标志,合理使用工具能大大提高我们的工作效率,遇到问题时,合理使用工具更能加快问题排查的进度。这也是我为什么...
一、Checkpoint 简介 Flink 的 Checkpoint 机制是其可靠性的基石。当一个任务在运行过程中出现故障时,可以根据 Chec...
1.前言 2.状态原理 2.1. 状态、状态后端、Checkpoint 三者之间的区别及关系? 结论:拿五个字做比喻:"铁锅炖大鹅",铁锅是状态...
1.前言 解决问题的能力:生产环境中,如何快速判断哪个算子存在反压呢? 解决问题的能力:反压有哪些危害? 解决问题的能力:经常碰到哪些问题会任务...
前言 通常我们在需要输出Table表数据时需要转换成DataStream流进行输出,然后转换流有两种模式toAppendStream追加模式、t...
文集作者