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

flink-cdc sql 可以直接读取mysql-cdc写入hive吗? SQL方式?

flink-cdc sql 可以直接读取mysql-cdc写入hive吗? SQL方式?

如何在 PolarDB-X 中优化慢 SQL

2 课时 |
113 人已学 |
免费

SQL完全自学手册

61 课时 |
3601 人已学 |
免费

SQL Server on Linux入门教程

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

Flink CDC用mysql-cdc连接2个流表做join操作,sql需要做什么调整吗?

Flink CDC用mysql-cdc连接2个流表做join操作,然后按某些维度group by求和值的时候会出现金额double的情况,sql需要做什么调整吗?表结构是这样的

请问flink sql 将mysql-cdc作为源表如何实现TTL?

请问flink sql 将mysql-cdc作为源表如何实现TTL,它不能定义水位线,也用不了窗口函数。只需要config.set("table.exec.state.ttl", "600000 ms")就可以了吗?还是还需要再别的地方设置下?

MYSQL-CDC FLINK SQL中 where 条件是不是在前期不起作用

MYSQL-CDC FLINK SQL中 where 条件是不是在前期不起作用,为何加了WHERE条件,还是在全表split?

怎么在执行sql的时候给每一个mysql-cdc表设置并发度啊?

怎么在执行sql的时候给每一个mysql-cdc表设置并发度啊,一个Job里面的所有的Source都是相同的并发度?

有没有flink sql mysql-cdc项目的模板啊?

有没有flink sql mysql-cdc项目的模板啊?

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

产品推荐

社区圈子

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

SQL mysql-cdc相关内容