Flink CDC里有没有遇到pg使用 sys_dump 命令备份后,会导致报错的?

Flink CDC里有没有遇到pg使用 sys_dump 命令备份后,会导致requested wAl segment 00000001000004A700000080 has already been removed 这个错误的啊?

Flink CDC里有个问题,之前的mysql cdc 还能获得更新的u命令 ,现在怎么回事?

Flink CDC里有个问题,之前的mysql cdc 还能获得更新的u命令 , 现在全是是d+c命令。 是有什么参数控制吗?我现在cdc的数据去kafka里面 更新变成两条 一个d 一个c两条记录 没有u。是有其他配置吗 很奇怪, 我记得之前看到过u命令 现在全是c和d。这个我知道 这个op 是u...

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
404 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
204 人已学 |
免费

大数据知识图谱系列—基于ELK+Flink日志全观测最佳实践

1 课时 |
174 人已学 |
免费
开发者课程背景图

Flink CDC用命令起要怎么指定哈?

Flink CDC用命令起要怎么指定哈?我自己没找到,我刚才就想着说指定一个路径。我只知道,关闭的时候可以指定savepoint

Flink CDC 里我这边本地跑代码没有问题,但是在flink上执行sql命令,错误怎么办?

Flink CDC 里我这边本地跑代码没有问题,但是在flink上执行sql命令,就如下错误:Flink CDC,cdc2.4,flink1.17.2,mysql8;Flink SQL> select * from mysql_binlog;[ERROR] Could not execute ...

Flink CDC 里我想把算子链断开,但是在提交命令中加上了这个参数发现不起作用怎么办?

Flink CDC 里我想把算子链断开,但是在提交命令中加上了这个参数发现不起作用,是我的写法上有问题吗?

Flink CDC产品常见问题之flink集群jps命令报错如何解决

Flink CDC产品常见问题之flink集群jps命令报错如何解决

问题一:有人用过Flink CDC 3.0版本的整库同步吗? 有人用过Flink CDC 3.0版本的整库同步吗?我用Flink CDC3.0整库同步mysql到starRock提交任务异常,有人遇到过这个问题吗? ...

Flink CDC 里这个命令不报错 但是没有获取到数据 是为什么?

./bin/flink run lib/paimon-flink-action-0.8-20240301.002155-30.jar mongodb_sync_database --warehouse 'hdfs://10.67.78.243:8020/paimon/mongodb' --datab...

flink cdc的job可以开启gc日志吗?是否是在启动job命令追加jvm参数?

flink cdc的job可以开启gc日志吗?是否是在启动job命令追加jvm参数?

Flink CDC里有办法yarn-session提交吗?提交的命令要怎么写啊?

Flink CDC里有办法yarn-session提交吗?提交的命令要怎么写啊?我一起启动了yarn-session,但是启动他找的还是8081 [hadoop@hadoop165 flink-cdc-3.0.1]$ bash bin/flink-cdc.sh mysql-to-doris.yaml...

Flink CDC里为什么per-job模式,用这个命令启动,会报连不上?

Flink CDC里为什么per-job模式,用这个命令启动,会报连不上?

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

产品推荐

社区圈子

阿里云实时计算Flink
阿里云实时计算Flink
一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。
199202+人已加入
加入
相关电子书
更多
基于 Flink CDC 打造 企业级实时数据集成方案
任庆盛|Flink CDC + Kafka 加速业务实时化
Flink CDC Meetup PPT - 龚中强
立即下载 立即下载 立即下载

实时计算 Flink版cdc相关内容

实时计算 Flink版更多cdc相关