阿里云文档 2024-06-04

Flink产品公告(2022年及之前)

本文为您介绍实时计算Flink版2022年及之前产品公告,包括平台升级、API版本升级等。

文章 2024-03-09 来自:开发者社区

Flink CDC产品常见问题之flink-cdc任务抓取全量的mysql数据不生效如何解决

问题一:Flink CDC里我部署的flink-cdc任务抓取全量的mysql数据,不生效怎么办? Flink CDC里我部署的flink-cdc任务抓取全量的mysql数据,checkpoint目前是持久化到oss上,我希望每次重启任务的时候不要从头开始抓取所有的消息。我的想法是在任务里面直接获取oss上最新进度的checkpoint目录,然后通过SavepointResto...

Flink CDC产品常见问题之flink-cdc任务抓取全量的mysql数据不生效如何解决
文章 2024-03-09 来自:开发者社区

Flink CDC产品常见问题之 Oraclecdc JdbcIncrementalSource 捕获不到数据如何解决

问题一:Flink CDC里有没有遇到这些情况,啊? Flink CDC里有没有遇到这些情况,啊? 如果任务不重启, 不管是新增删除编辑都是没有问题的, 只要有一端的flink任务重启了, 就会出现以下问题: mysql同步到kafka(采集数据), 再由kafka同步kafka(搬运数据), 再由kafka同步到mysql(数据落库), 当停止采集或者落库任务后, 再次启动采...

Flink CDC产品常见问题之 Oraclecdc JdbcIncrementalSource 捕获不到数据如何解决
文章 2024-03-09 来自:开发者社区

Flink CDC产品常见问题之upsert-kafka增加参数报错如何解决

问题一:Flink CDC里请问upsert-kafka增加参数报错是为什么? Flink CDC里请问upsert-kafka增加参数: 'sink.buffer-flush.interval' = '5', 'sink.buffer-flush.max-rows' = '100'后报错是什么原因? ...

Flink CDC产品常见问题之upsert-kafka增加参数报错如何解决
文章 2024-03-09 来自:开发者社区

Flink CDC产品常见问题之从EARLIEST_OFFSET启动就报错如何解决

问题一:Flink CDC里有一张表,从EARLIEST_OFFSET启动就报这个错是为什么? Flink CDC里有一张表,从EARLIEST_OFFSET启动就报这个错,但是从最新位置消费就可以,这个是binlog文件的问题么? ...

Flink CDC产品常见问题之从EARLIEST_OFFSET启动就报错如何解决
文章 2024-03-09 来自:开发者社区

Flink CDC产品常见问题之CDC首次启动跑数据后再次启动就报错如何解决

问题一:Flink CDC里再跑又不会报错怎么回事? Flink CDC里A slave with the same server_uuid/server_id as this slave has connected to the master; the first event 'itpuxdb-binlog.003370' at 350718958, the last eve...

文章 2024-03-09 来自:开发者社区

Flink CDC产品常见问题之SQLserver cdc 开启 cdc表没有记录如何解决

问题一:Flink CDC里SQLserver cdc 开启 cdc表没有记录啥原因? Flink CDC里SQLserver cdc 开启 cdc表没有记录啥原因? 参考回答: 在Flink CDC从SQL Server捕获数据变更(CDC)的过程中,如果开启CDC功能后对应的表中没有记录变化数据,可能存在以下几种原因: CDC启...

Flink CDC产品常见问题之SQLserver cdc 开启 cdc表没有记录如何解决
文章 2024-03-09 来自:开发者社区

Flink CDC产品常见问题之flink1.18同步mysql-starrocks pipeline时报错如何解决

问题一:Flink CDC里flink1.18同步mysql-starrocks pipeline什么问题? Flink CDC里flink1.18同步mysql-starrocks pipeline这是什么问题? ...

Flink CDC产品常见问题之flink1.18同步mysql-starrocks pipeline时报错如何解决
文章 2024-03-09 来自:开发者社区

Flink CDC产品常见问题之flinkcdc3同步mysql到doris的时候语句不同步如何解决

问题一:Flink CDC里StarRocks是否支持oracle的外部表?怎么创建?添加到fe或be? Flink CDC里StarRocks是否支持oracle的外部表?怎么创建?添加到fe嘛 还是be? 参考回答: 支持。 https://docs.starrocks.io/zh/docs/2.2/data_source/External...

Flink CDC产品常见问题之flinkcdc3同步mysql到doris的时候语句不同步如何解决
文章 2024-03-09 来自:开发者社区

Flink CDC产品常见问题之Lookup Join之后再分组聚合部分数据从零开始如何解决

问题一:Flink CDC里Lookup Join之后,再分组聚合,为什么跑了两天之后有点数据开始从0聚合? Flink CDC里Lookup Join之后,再分组聚合,为什么跑了两天之后,有点数据开始从0开始聚合了啊?有的数据是正常的,有的数据的清0了,我这边没有设置TTL,状态也会过期吗? 参考回答: 在Flink CDC中进行Lookup Joi...

Flink CDC产品常见问题之Lookup Join之后再分组聚合部分数据从零开始如何解决

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问