问答 2024-03-11 来自:开发者社区

Flink CDC 里我的任务又全局挂了 flink设置的5次重试怎么办?

Flink CDC 里我的任务又全局挂了 flink设置的5次重试 akka timeout设置的2min 数据是mysql到cdc再sink到kafka 。 这个异常还出现 是说明mysql到cdc之间通信异常么?还是cdc 到下游kafka之间的subtask没搞完?现在不知道根因是在哪里 ?或是参数配的还有问题?

问答 2024-03-11 来自:开发者社区

如果我没有给FlinkCDC单独指定并行度,它的并行度是1,还是跟整个Flink任务的并行度一致?

如果我没有给FlinkCDC单独指定并行度,它的并行度是1,还是跟整个Flink任务的并行度一致?

问答 2024-03-11 来自:开发者社区

flinkcdc为什么从savepoint启动后发现新加的表是从最新的binlog开始同步数据的?

做flink cdc2doris的操作时,新建一个任务,设置从最早的 binlog 开始同步(scan.startup.mode=earliest-offset)没有问题,然后新加一张表,从savepoint启动后发现新加的表是从最新的binlog开始同步数据的。是正常现象么?

问答 2024-03-11 来自:开发者社区

Flink CDC 里这是什么问题?

Flink CDC 我这个任务运行很长时间了,突然报这个错,是因为其他任务的id与它的重复了吗?那我是不是要指定一个范围啊,比如我的并行度是 10, 指定 10 - 19. 另外一个任务指定 20-29........

问答 2024-03-11 来自:开发者社区

Flink CDC 里启动flink yarn application任务,任务超时怎么办?

在 Flink CDC 中,当启动 Flink Yarn Application 任务过程中,在第 68 个任务之后,接下来的第 69 和 70 个任务遭遇启动超时,进而呈现 pending 状态。这个问题是否由于我将 yarn.scheduler.capacity.maximum-am-resource-percent 的参数设置调整到了 0.5 引起的?此外,我也更改了 yarn.nodem....

问答 2024-03-11 来自:开发者社区

Flink cdc快照初始化中经常出现这样的异常 , 这个要配置哪些参数?

Flink cdc快照初始化中经常出现这样的异常 subtask任务就fail重启 这个要配置哪些参数可以解决吗?;如果是网络问题 有什么办法能有效避免这种异常么?

问答 2024-03-11 来自:开发者社区

flink cdc 3.0 使用pipeline方式同步数据,中断任务后怎么继续之前的任务断点?

flink cdc 3.0 使用pipeline同步数据时,如果改动yaml文件已增加新的同步表,取消了之前的同步任务,修改后的任务怎么继续之前的检查点。现在是每次重新提交任务都会重新处理一遍之前同步过程。

问答 2024-03-11 来自:开发者社区

在同一个tm里面,flink cdc的任务超过20个后就显示连接池满,这个问题如何修改配置解决?

在同一个tm里面,flink cdc的任务超过20个后就显示连接池满,连不上数据库了,这个问题如何修改配置解决?

问答 2024-03-11 来自:开发者社区

有用springboot框架开发flink任务的朋友吗?

有用springboot框架开发flink任务的朋友吗?

文章 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数据不生效如何解决

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

产品推荐

实时计算 Flink

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

+关注