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

Flink CDC 里生产突然就报这个了,然后,重启任务还是抓不到变动了怎么办?

Flink CDC 里生产突然就报这个了,然后,重启任务还是抓不到变动了怎么办?

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

Flink CDC 里怎么发现从ck恢复后的任务不再自动做ck了啊?

Flink CDC 里怎么发现从ck恢复后的任务不再自动做ck了啊?

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

flink cdc在全量快照初始化阶段 如果任务异常自动从ck restore后 会这样吗?

flink cdc在全量快照初始化阶段 如果任务异常自动从ck restore后 会从上次binlog断点续传么?

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

Flink CDC 里这个任务启动时间是从哪里拿的?相差8小时,不知道去哪里修改?

Flink CDC 里这个任务启动时间是从哪里拿的?相差8小时,不知道去哪里修改?我看了容器中的时间,还有 k8 node 机器时间都是对的。

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

现在flink-cdc 的任务经常 exception 退出, 请问有什么方法 监控任务状态么?

现在flink-cdc 的任务经常 exception 退出, 请问有什么方法 监控任务状态么?

问答 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....

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

产品推荐

阿里云实时计算Flink

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

+关注