开发者社区大数据与机器学习实时计算 Flink 正文

有人帮忙解释下flink mongo cdc backfillStreamSplit这块的逻辑吗？

有人帮忙解释下flink mongo cdc backfillStreamSplit这块的逻辑吗？为啥要走streamfetchtask ?

展开

收起

wenti 2023-01-15 16:25:30 161 版权

1 条回答

写回答

取消提交回答

co63oc_

GitHub https://github.com/co63oc/cloud

如果不需要backfill，增加改变事件到队列，如果需要backfill，使用FetchTask处理

2023-01-17 19:08:09

赞同展开评论

问答分类：

流计算实时计算 Flink版

问答标签：

实时计算 Flink版CDC 实时计算 Flink版mongo 实时计算 Flink版逻辑实时计算 Flink版cdc逻辑实时计算 Flink版mongo cdc

问答地址：

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答

相关问答

实时计算 Flink版

Flink 使用维表加在 MC 的数据，MC中的某条数据变更了，sql统计的逻辑会变更吗？

121

在Flink定义了两个mongo table，这里的血缘展示两个mongo表是期望的吗？

Flink这个是sql方式有额外的处理逻辑么？

在Flink CDC中，pgsql备库cdc，wal_level不改成逻辑的有啥方案嘛？

在Flink CDC中，同步mongo数据到Doris，错误是什么原因吗？

167

如果我增加TM的数量那要提高作业并发度改为3 那TM就是3=3/1Flink是这个逻辑吗？

在Flink CDC中因为Mongo中数据存在删除操作，这种怎么处理呀？

159

flink作业逻辑非常复杂，启动时候超时失败怎么办？

120

有在产线上,通过flink-cdc 复制/同步数据嘛,类似逻辑复制包括:DDL(表结构)/DML？

flink1.18 cdc mongo数据同步到upset-kafka请问是什么原因呢?

大数据与机器学习

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问

收录在圈子:

阿里云实时计算Flink

199212

+ 订阅

实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。

构建高效的实时数据管道：Flink、Kafka、CnosDB 的完美结合

实现千表入湖之Apache Paimon篇

OBS特效与OBS美颜一步到位：专为新手主播打造的YY开播工具集成方案

【机器人路径规划】基于流场寻路算法(Flow Field Pathfinding)的机器人路径规划（Python代码实现）

【模型预测控制MPC】使用二次规划来模拟多输入多输出(MIMO)系统的模型预测控制（Matlab代码实现）

有人帮忙解释下flink mongo cdc backfillStreamSplit这块的逻辑吗？

实时计算 Flink

相关文章

热门讨论

热门文章