请问下 FLINKCDC SQL 能获取到 数据的状态么?

请问下 FLINKCDC SQL 能获取到 数据的状态么 ,我需要把状态写入到表里 INSERT UPDATE DELETE。

flinkcdc两个flink-sql同时运行,使用的是mysql-cdc表,这些问题怎么解决?

flinkcdc两个flink-sql同时运行,使用的是mysql-cdc表,日志显示发生了server id冲突:Caused by: io.debezium.DebeziumException: A slave with the same server_uuid/server_id as thi...

如何在 PolarDB-X 中优化慢 SQL

2 课时 |
113 人已学 |
免费

SQL完全自学手册

61 课时 |
3601 人已学 |
免费

SQL Server on Linux入门教程

14 课时 |
4329 人已学 |
免费
开发者课程背景图

FlinkCDC 支持基于 sql 查询的数据同步吗?

FlinkCDC 支持基于 sql 查询的数据同步吗?

我使用flinkcdc的sql形式进行全量同步,4张表,有两张表数据没进去,看日志,id怎么是null呢?

这个问题可能是由于以下原因导致的: 表结构不一致:请检查四张表的结构是否一致,包括字段名、数据类型等。如果有任何不一致,需要修改表结构以保持一致。 数据转换问题:在使用Flink CDC进行全量同步时,可能需要对源表中的数据进行一些转换操作,例如将日期字符串转换为日期对象等。请检查这些转换操作是否正...

我使用flinkcdc的sql形式进行全量同步,4张表,有两张表数据没进去,,id怎么是null呢?

我使用flinkcdc的sql形式进行全量同步,4张表,有两张表数据没进去,看日志,id怎么是null呢?

flinkcdc 整库同步是不是不能用sql形式只能用DataStream API 啊?

flinkcdc 整库同步是不是不能用sql形式只能用DataStream API 啊?

flinkcdc的sql或者是api的方式能增量获取sqlserver2008版本的嘛 ?

flinkcdc的sql或者是api的方式能增量获取sqlserver2008版本的嘛 ? cdc mysql 2.3版本为啥老是出现这个问题

flinkcdc的sql或者是api的方式能增量获取sqlserver2008版本的嘛 ?

flinkcdc的sql或者是api的方式能增量获取sqlserver2008版本的嘛 ?

用flinkcdc的sql进行同步数据, 开始的时候增删改都是可以的, 但是删除不可以,?

用flinkcdc的sql进行同步数据, 开始的时候增删改都是可以的, 突然就新增编辑可以同步, 但是删除不可以,?

需要用flinkcdc 实时同步几千个表,有方法 多个表合并成一个任务吗?

老师们 问个问题, 需要用flinkcdc 实时同步几千个表, 通过 sql_client 实现, 一个表提交一个任务,这样占用资源很大,有方法 多个表合并成一个任务吗?

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

产品推荐

社区圈子

数据库
数据库
分享数据库前沿,解构实战干货,推动数据库技术变革
253177+人已加入
加入
相关电子书
更多
PolarDB NL2SQL: 帮助您写出准确、优化的SQL
基于 Flink SQL + Paimon 构建流式湖仓新方
SQL智能诊断优化产品SQLess蚂蚁最佳实践
立即下载 立即下载 立即下载