Flink CDC在代码里面集成cdc的时候,是不是也要用上面这个胖包flink-sql-connector-mysql-cdc,不要去用瘦包flink-connector-mysql-cdc? com.ververica flink-sql-connector-mysql-cdc 2.4.0

在Flink CDC中,如果你使用的是Flink SQL来定义和执行CDC任务,那么通常需要使用包含SQL支持的“胖包”(fat jar),即flink-sql-connector-mysql-cdc。这是因为这个胖包包含了运行Flink SQL所需的全部依赖项,包括连接器、序列化器等。 相反,如果...

Flink CDC中mongo版本4.4,cdc胖包版本2.4.2,按照文档里这么配置的?

Flink CDC中mongo版本4.4,cdc胖包版本2.4.2,按照文档里这么配置的?mongodb集群1主1从CREATE TABLE ods_common_db.realtime_sync_logs( _id STRING PRIMARY KEY NOT ENFORCED, level ST...

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

1 课时 |
404 人已学 |
免费

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

1 课时 |
204 人已学 |
免费

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

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

Flink CDC在代码里面集成cdc的时候,是不是也要用上面这个胖包?

Flink CDC在代码里面集成cdc的时候,是不是也要用上面这个胖包flink-sql-connector-mysql-cdc,不要去用瘦包flink-connector-mysql-cdc? com.ververica flink-sql-connector-mysql-cdc 2.4.0

Flink CDC胖包瘦包,指的是flink运行环境里面的依赖使用的吗?

Flink CDC胖包瘦包,指的是flink运行环境里面的依赖使用的吗?

Flink CDC目前环境里的包列表,只有mysql的胖包报错如下是缺了什么包么?

Flink CDC目前环境里的包列表,只有mysql的胖包报错如下是缺了什么包么?

Flink CDC重新打一个sqlserver+mysql的胖包,这个有教程链接么?

Flink CDC重新打一个sqlserver+mysql的胖包,这个有教程链接么?

Flink CDC看起来像是找不到sql胖包中的类?

Flink CDC去掉flink-connector-mysql-cdc的包,就报这样的错误看起来像是找不到sql胖包中的类?Caused by: java.lang.ClassCastException: cannot assign instance of com.fasterxml.jackso...

Flink CDC中sqlserver mysql都用的胖包mysql报这个错?

Flink CDC中sqlserver mysql都用的胖包sqlserver的成功了,mysql报这个错?Caused by: java.io.StreamCorruptedException: unexpected block data at java.base/java.io.ObjectIn...

Flink CDC胖包是啥?

Flink CDC胖包是啥?

Flink CDC这个报错是不是应错cdc的包了?有知道这个胖包去哪里找吗?我在maven仓库找不到

Flink CDC这个报错是不是应错cdc的包了?有知道这个胖包去哪里找吗?我在maven仓库找不到

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

产品推荐

社区圈子

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