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

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

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

问答 2024-07-15 来自:开发者社区

flink cdc 能捕获 mysql 的如下的数据变化吗?

flink cdc 能捕获 mysql 的 ALTER TABLE table_name drop PARTITION PARTITION ${f}${p_3} ;的数据变化吗?

问答 2024-06-14 来自:开发者社区

企业版Flink CDC能从Hologress捕获变更数据到kafka或datahub吗

企业版Flink CDC能从Hologress捕获变更数据到kafka或datahub吗

问答 2024-05-20 来自:开发者社区

Flink cdc=3.0 , Streaming API 为什么捕获不到新增数据?

Flink cdc=3.0 , Streaming API 通过incremental snapshot的方式采集数据,为什么配置startupOptions(StartupOptions.latest())就捕获不到新增数据呢? 我上周测还是可以捕获的。

问答 2024-05-01 来自:开发者社区

Flink CDC里可以一次捕获一个事物提交的数据吗?

Flink CDC里可以一次捕获一个事物提交的数据吗,这样在入库的时候可以批量入库。

文章 2024-03-17 来自:开发者社区

Flink CDC产品常见问题之flink Oraclecdc 捕获19C数据时报错错如何解决

问题一:Flink CDC里有人了解mysql binlog生成机制吗 ? Flink CDC里有人了解mysql binlog生成机制吗 ? flink cdc为什么有时候能读到binlog 有时候不能啊? 参考回答: MySQL Binlog(二进制日志)是MySQL数据库用于记录所有更改数据的逻辑日志,包括数据的增删改操作。MySQL通过启用二进...

Flink CDC产品常见问题之flink Oraclecdc 捕获19C数据时报错错如何解决
文章 2024-03-09 来自:开发者社区

Flink CDC产品常见问题之 Oraclecdc JdbcIncrementalSource 捕获不到数据如何解决

问题一:Flink CDC里有没有遇到这些情况,啊? Flink CDC里有没有遇到这些情况,啊? 如果任务不重启, 不管是新增删除编辑都是没有问题的, 只要有一端的flink任务重启了, 就会出现以下问题: mysql同步到kafka(采集数据), 再由kafka同步kafka(搬运数据), 再由kafka同步到mysql(数据落库), 当停止采集或者落库任务后, 再次启动采...

Flink CDC产品常见问题之 Oraclecdc JdbcIncrementalSource 捕获不到数据如何解决
问答 2024-03-05 来自:开发者社区

Flink CDC可以通过正则.*捕获新增表的数据了, 但是可以过滤掉DML操作吗?

Flink CDC用来master分支后, 可以通过正则.*捕获新增表的数据了, 但是可以过滤掉DML操作吗?建表语句这些我不想要

问答 2024-02-06 来自:开发者社区

Flink CDC里设置这个参数,没有捕获到新增字段的数据,其他数据也异常怎么回事?

Flink CDC里sqlserver-cdc设置这个参数,没有捕获到新增字段的数据,其他数据也异常是怎么回事?

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等