Flink CDC中mysql-cdc遇到这个错误?

Flink CDC中mysql-cdc遇到这个错误?是cdc的问题还是mysql的问题呢?

Flink CDC服务器上要单独部署mysql-cdc 包?

Flink CDC服务器上要单独部署mysql-cdc 包?

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

1 课时 |
404 人已学 |
免费

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

1 课时 |
204 人已学 |
免费

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

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

Flink CDC有测试过mysql-cdc的吞吐率么? 单线程每秒大概能获取多少的mysql数据?

Flink CDC有测试过mysql-cdc的吞吐率么? 单线程每秒大概能获取多少的mysql数据?主要就是看增加薄荷额吞吐量吧

Flink CDC通过mysql-cdc就可以动态监听数据的变动?

Flink CDC通过mysql-cdc就可以动态监听数据的变动?

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

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

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

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

Flink CDC我这边建立一张mysql-cdc的表,这个应该怎么处理啊?

Flink CDC我这边建立一张mysql-cdc的表,因为表涉及到insert delete数据,我这边只要拿到insert的信息 这个应该怎么处理啊?

Flink CDC2.2.1的mysql-cdc有bug么 有用过的么 ?

Flink CDC2.2.1的mysql-cdc有bug么 有用过的么 ?这图片是在sql-client里执行的

请问Flink CDC这个mysql-cdc输出的op列(黄框,代表数据的增删改)能否捕获使用?

问题1:请问Flink CDC这个mysql-cdc输出的op列(黄框,代表数据的增删改)能否捕获使用(比如写入临时表进行使用)?现在这样写能够print出op列,但不能写入数据库?问题2:加上这个op_ts列吗?这个似乎是本地时间戳,不是 +U,+I,-U这一类型呀。能否指教更多一点?

请问Flink CDC这个mysql-cdc输出的op列(黄框,代表数据的增删改)能否写入临时表?

请问Flink CDC这个mysql-cdc输出的op列(黄框,代表数据的增删改)能否写入临时表进行使用?现在这样能够print,但不能写入数据库?

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

产品推荐

社区圈子

阿里云实时计算Flink
阿里云实时计算Flink
一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。
199201+人已加入
加入
相关电子书
更多
基于 Flink SQL + Paimon 构建流式湖仓新方
基于 Flink CDC 打造 企业级实时数据集成方案
李劲松|Flink Table Store 典型应用场景
立即下载 立即下载 立即下载