问答 2024-05-20 来自:开发者社区

Flink CDC里目前遇到一个问题,rds扩缩容是 会导致binlog位点失效怎么办?

Flink CDC里目前遇到一个问题,rds扩缩容是 会导致binlog位点失效,从而引发作业一直重启失败,flinkcdc有什么 方法可以规避这种情况吗?没有用过gtid,是需要rds这边配置吗?确实是凌晨低峰进行的。

问答 2024-05-20 来自:开发者社区

Flink CDC里这种binlog问题大家遇到过吗,为什么时不时会出现这种情况失败?

$stringUtil.substring( $!{XssContent1.description},200)...

问答 2024-05-20 来自:开发者社区

Flink CDC里checkpoint状态进行恢复,根据报错是提示这个binlog文件已经不在了?

Flink CDC里checkpoint状态进行恢复,根据报错是提示这个binlog文件已经不在了。提示的建议方案是when_needed。这个有用吗?but this is no longer available on the server. Reconfigure the connector to use a snapshot when needed。

问答 2024-05-01 来自:开发者社区

Flink CDC里sink开启多个并行度,你是怎么保证binlog的顺序的?

Flink CDC里sink开启多个并行度,你是怎么保证binlog的顺序的?

问答 2024-05-01 来自:开发者社区

polardb-x 1.0版本 flink cdc链接读取binlog也可以配置一个链接么?

polardb-x 1.0版本 flink cdc链接读取binlog也可以配置一个链接么?底层是8个实例的话 也只需要配置一个域名链接么?但cdc的话不是得读取binlog?也是配置代理域名就行?

问答 2024-05-01 来自:开发者社区

Flink CDC里这个报错是因为有多个任务 读取了一个binlog 导致的吗?

Flink CDC里这个报错是因为有多个任务 读取了一个binlog 导致的吗?因为同时启动了多个任务 读取源库吗?

问答 2024-05-01 来自:开发者社区

Flink CDC里同样的代码 有的binlog返回了 schema 有的没返回为什么?

Flink CDC里同样的代码 有的binlog返回了 schema 有的没返回为什么?

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

Flink CDC读取binlog的速度是受什么影响的?

Flink CDC读取binlog的速度是受什么影响的?就是有点奇怪 这两个现在都没多大的负载 网络是内网 IO也不高。修改一个700W记录的表 同步速度大概是1秒4000-5000记录数。

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

Flink CDC GTID模式,源库主备切换后,无法定位到binlog,是什么原因?

Flink CDC GTID模式,源库主备切换后,无法定位到binlog,是什么原因? binlog文件是存在的,只是文件名称变了

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

Flink CDC里 mysql cdc 的op_ts 时间binlog是毫秒,是哪个参数控制的?

Flink CDC里 mysql cdc 的op_ts 时间binlog是毫秒,但是到kakfa里面变成了 秒,是哪个参数控制的? sql过去的 ,flink-cdc

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

产品推荐

阿里云实时计算Flink

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

+关注