[帮助文档] Source修改的可兼容性和不可兼容性详情是什么

本文为您介绍Source变更的可兼容性和不可兼容性详情。

rabbitmq为source的情况下 如果反序列化失败,Flink会一直消费数据,一直错误下去,?

rabbitmq为source的情况下 如果反序列化失败,Flink会一直消费数据,一直错误下去,这个有参数可以配置吗 ?

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

1 课时 |
404 人已学 |
免费

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

1 课时 |
204 人已学 |
免费

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

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

我发现如果一个source对应的collection没有数据变更,flink任务的checkpoin

我发现如果一个source对应的collection没有数据变更,flink任务的checkpoint会卡住。看源码感觉和这一段代码有关,这个continue感觉比较疑惑,我的理解等待完成后应该继续判断心跳,往下游发送心跳记录?

请问有没人知道mysql-cdc里面把source注册到flink-table这一块的源码实现在哪?

请问有没人知道mysql-cdc里面把source注册到flink-table这一块的源码实现在哪?

使用Flink-sql-cdc-mysql-2.1.1作为source,Flink-sql-cdc-

使用Flink-sql-cdc-mysql-2.1.1作为source,Flink-sql-cdc-tidb-2.2.0作为sink。想要做全增量一体化数据库同步,出现以下情况 :任务启动后会将数据库存量数据一次性导入,但是增量数据要过20分钟才会开始同步,这是什么原因呢?

这种数据,怎么设置kafka source,才能让flink 继续消费?

源端脏数据(日期为1899年),debezium 解析完为负数(EFF_DATE:-2211696000000),这种数据,怎么设置kafka source,才能让flink 继续消费

[帮助文档] 修改SQL除Query、Source和Sink之外的其他限制

本文为您介绍修改SQL除Query、Source和Sink之外的其他限制。

为什么要对Source API-Flink接口进行合并呢?

为什么要对Source API-Flink接口进行合并呢?

Source API-Flink有几个接口?

Source API-Flink有几个接口?

我用hivecatalog建了张kafka的source表,那么我有两个job都需要从这#Flink

我用hivecatalog建了张kafka的source表,那么我有两个job都需要从这张source表取数据写到不同的 数据库,那么怎么保证group.id 不同的啊 #Flink

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

产品推荐

热门帮助文档

社区圈子

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