阿里云文档 2025-03-28

Flink CDC写入MaxCompute

MaxCompute为您提供对接Flink CDC的新版插件Connector连接器。您可以通过对接Flink CDC,将数据源(例如MySQL)数据实时同步至MaxCompute的目标表(普通表或Delta表)。本文为您介绍MaxCompute新版插件的能力支持情况与主要操作流程。

问答 2024-12-28 来自:开发者社区

Flink CDC中如果MySQL 字段设置了默认值,字段值为空时,捕获到的变更数据为默认值??

这个问题我在本地复现是偶现问题,字段值为空时,捕获的值有时候是默认值,有时候又是空。 这个问题困扰我几天了,社区里也没找到完整可行的方案:目前看到两种解决方法,描述不太清楚看不明白。期待大佬指导下。1、回答:这个之前也有其他人反馈过,我是重写了SchemaBuilder,默认值直接指定为null,此回答整理自钉群“Flink CDC 社区”2023-11-16 08:43:19链接:https:....

问答 2024-10-29 来自:开发者社区

flink cdc paimon设置了file.format为parquet但生成的文件依然是orc

问题描述 我在使用Flink + Flink cdc + Paimon + oss 做数据同步,在cdc的yaml里指定了paimon的文件格式是parquet,但生成的文件依然是默认的文件格式orc,请问是什么原因? 软件版本 Flink :1.18.1Flink CDC : 3.1.0Paimon: 0.8.0 cdc yaml source: type: mysql name: M...

问答 2024-08-18 来自:开发者社区

flink cdc现在大表的初始化全量同步,还是只能把checkpoint时间设置长点吗?

flink cdc现在大表的初始化全量同步,还是只能把checkpoint时间设置长点,防止checkpoint失败吗?

问答 2024-08-18 来自:开发者社区

Flink CDC 里ttl可以根据业务时间设置吗?

Flink CDC 里ttl可以根据业务时间设置吗?

问答 2024-08-13 来自:开发者社区

在Flink CDC中,cdc3.1 pipeline同步到doris可以设置tinyint1is?

在Flink CDC中,cdc3.1 pipeline同步到doris可以设置tinyint1isBit=false吗?字段都变成布尔

问答 2024-08-13 来自:开发者社区

在Flink CDC中,总是报找不到对应的库表。有人遇到过么?这个方式需要怎么设置了?

mysql的数据库和生成的binlog不在同一个服务器,现在想用flinkcdc抽取mysql的数据,配置的连接信息是binlog服务器的,在Flink CDC中,总是报找不到对应的库表。有人遇到过么?这个方式需要怎么设置了?官方文档没找到相应的信息。

问答 2024-08-13 来自:开发者社区

在Flink CDC中,副本数设置的跟表的是匹配的吗?

在Flink CDC中,副本数设置的跟表的是匹配的吗?

问答 2024-08-12 来自:开发者社区

在Flink CDC中,关键是这2个参数要设置,怎么解决? '

'debezium.log.mining.strategy'='online_catalog','debezium.log.mining.continuous.mine'='true' 在Flink CDC中,关键是这2个参数要设置,怎么解决?

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注