Flink消费Kafka source显示作业延迟为52年

Flink消费Kafka source显示作业延迟为52年

flink cdc pipeline source和sink 做过了怎么办?

flink cdc pipeline source和sink 做过了,由于flink kafka sink 不支持schema event,目前是是直接把schema event 直接json 存储写入kafka,且在Data change event 的kafka header 头重添加了 sch...

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
404 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
204 人已学 |
免费

大数据知识图谱系列—基于ELK+Flink日志全观测最佳实践

1 课时 |
174 人已学 |
免费
开发者课程背景图

flink sql 用doris作为source和sink 跑起任务后为什么不是流计算?

flink sql 用doris作为source和sink 跑起任务后为什么不是流计算?数据跑完任务就结束了

Flink Source/Sink如何才能支持端到端严格一次

Flink Source/Sink如何才能支持端到端严格一次

实时计算 Flink版产品使用合集之实现自定义 Flink Source和控制数据的下发如何解决

问题一:请教个Flink问题:如果从历史某个时间点进行重新消费,是不是只能将kafka设置为单分区? 请教个Flink问题:如果从历史某个时间点进行重新消费,要保证数据全局有序,是不是只能将kafka设置为单分区? 参考回答: 在Flink从历史某个时间点进行重新消费的情况下,要保证数据全局有序,并...

实时计算 Flink版产品使用合集之提高 MongoDB Source的消费速率如何解决

实时计算 Flink版产品使用合集之提高 MongoDB Source的消费速率如何解决

问题一:控制 Flink CDC mongo source 的消费速率,这个有朋友了解吗? 控制 Flink CDC mongo source 的消费速率,这个有朋友了解吗? 参考回答: Flink CDC MongoDB Source 提供了一些参数来控制消费速率。具体来说,你可以通过配置 fli...

实时计算 Flink版产品使用合集之source多并发导致时序问题如何解决

实时计算 Flink版产品使用合集之source多并发导致时序问题如何解决

问题一:Flink CDC的source 多并发 会有时序问题吗?如何解决? Flink CDC的source 多并发 会有时序问题吗?如何解决?增量数据呢,不是历史的,通过正则匹配 配了多张表 会有时序问题吗?分库分表以后 每个库有自己的 log 参考回答: Flink CDC的source多并发...

实时计算 Flink版产品使用合集之将多个表的数据导入到一个 source table中如何解决

问题一:Flink CDC项目组内最近遇到一个flink cdc的技术难点,谁有相关经验的,有空帮忙看看? Flink CDC项目组内最近遇到一个flink cdc的技术难点,谁有相关经验的,有空帮忙看看? (1技术实现:oracle:11g/19c,java jdk:17,flink:1.14.2...

实时计算 Flink版产品使用合集之web ui能否在线管理数据source和处理数据

实时计算 Flink版产品使用合集之web ui能否在线管理数据source和处理数据

问题一:FlinkCDC支持Oracle的表结构变更同步吗? 1.FlinkCDC支持Oracle的表结构变更同步吗? 2.源表Oracle支持断点续传吗? 3.源表Oracle支持整库同步吗? 4.源表Oracle,如果想要同步多张表的数据,是需要起多个任务去同步吗?如果表比较多,那么多个任务是否...

Flink CDC里source端的表名配置可以不按正则匹配,用什么分隔符写多个表名吗?

Flink CDC里source端的表名配置可以不按正则匹配,用什么分隔符写多个表名吗?cdc可以同步部分字段吗?会不会增只同步表的部分字段功能

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

社区圈子

阿里云实时计算Flink
阿里云实时计算Flink
一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。
199202+人已加入
加入
相关电子书
更多
基于 Flink SQL + Paimon 构建流式湖仓新方
基于 Flink CDC 打造 企业级实时数据集成方案
李劲松|Flink Table Store 典型应用场景
立即下载 立即下载 立即下载