问答 2024-04-02 来自:开发者社区

Flink CDC里遇到过设置了任务的并发数量后,任务执行几分钟就会停止为什么?

Flink CDC里遇到过设置了任务的并发数量后,任务执行几分钟就会停止,返回Database connection failed when starting copy,数据库日志提示插槽重复,重复的是下划线_1、_2、_3、...的插槽名字,单线程就不会出现这个问题怎么办?指定slot,每次出现这个报错,我都更换插槽名称,用雪花算法生成的,应该不存在和现有其他任务重复。

问答 2024-04-02 来自:开发者社区

Flink的任务取消之后,检查点目录直接被删除了,该如何避免呢?

Flink的任务取消之后,检查点目录直接被删除了,该如何避免呢?

问答 2024-04-02 来自:开发者社区

问下 我的flink任务 全是loading是哪儿没有配置或者包的问题吗?

问下 我的flink任务 全是loading是哪儿没有配置或者包的问题吗?

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

flink任务重启 从最新状态恢复 有2个task 一直在初始化状态很久才能启动 是什么原因?

flink任务重启 从最新状态恢复 有2个task 一直在初始化状态很久才能启动 是什么原因?

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

Flink CDC里昨天我从polardb-mysql 做CDC同步任务,这是什么问题?

Flink CDC里昨天我从polardb-mysql 做CDC同步任务,用的是只读从库地址运行了3个小时 binlog 好像被清除了怎么回事?主库的任务一直都在运行,从库的跑了3个小时就找不到binlog,是需要哪里设置一下吗?

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

.Flink cdc任务在同步过程中 新增同步表后选择全量初始化历史数据,初始化什么时候开始?

Flink cdc任务在同步过程中新增同步表后选择全量初始化历史数据,会阻塞原先其余表的增量同步么?

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

Flink cdc任务运行中,日志出现这种情况,然后任务的checkpoint一直是成功状态,为啥?

锁表会导致 flink任务的GC吗?

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

Flink CDC里任务都停了,内存资源不释放是什么情况?

Flink CDC里任务都停了,内存资源不释放是什么情况?

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

flink cdc到doris,如果mysql中的表被删除或者rename,同步任务会报错么?

flink cdc到doris,如果mysql中的表被删除或者rename,同步任务会报错么?

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

Flink CDC里任务启动后一直处于starting是咋回事儿?

Flink CDC里任务启动后一直处于starting是咋回事儿?内存占用也还有。启动了大概400个任务,内存三台机器还剩300g。

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

产品推荐

阿里云实时计算Flink

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

+关注