问答 2023-08-09 来自:开发者社区

Flink CDC中第一次启动的时候需要全量后面就是监听binlog增量这个怎么设置?中间存在宕机。

Flink CDC中第一次启动的时候需要全量 后面就是监听binlog增量这个怎么设置?中间存在宕机重启了。

问答 2023-08-01 来自:开发者社区

老师请教一个Flink CDC中binlog的问题这两个ts_ms有什么区别?

老师请教一个Flink CDC中binlog的问题这两个ts_ms有什么区别?

问答 2023-08-01 来自:开发者社区

Flink CDC中现在能在不改变binlog_format=ROW的前提下,解决这个问题么?

Flink CDC中现在能在不改变binlog_format=ROW的前提下,解决这个问题么?org.apache.flink.table.api.validationexception: The MySQL server is configured with binlog_format MIXED rather than ROW, which is required for this conn....

问答 2023-08-01 来自:开发者社区

Flink cdc读取 mysql 5.7 binlog 文件时,能控制拉取速度吗?

Flink cdc读取 mysql 5.7 binlog 文件时,能控制拉取速度吗?

问答 2023-08-01 来自:开发者社区

我想问下flink cdc在运行的时候可以限制Binlog大小吗?Binlog一直读取占了带宽

我想问下flink cdc在运行的时候可以限制Binlog大小吗?Binlog一直读取占了带宽

问答 2023-08-01 来自:开发者社区

咨询一下,Flink CDC读取Mysql binlog的时候是在哪里将binlog的数据转换成?

问题1:咨询一下,Flink CDC读取Mysql binlog的时候是在哪里将binlog的数据转换成RowData的呢,想看看varchar等字符型数据的编码转换逻辑?问题2:这里的转换和io.debezium.connector.mysql.MySqlValueConverters里的转换有什么关联吗?

问答 2023-08-01 来自:开发者社区

使用flink cdc 读取mysql binlog,一堆问题怎么解决啊。?

使用flink cdc 读取mysql binlog,一堆问题怎么解决啊。。。Data row is smaller than a column index, internal schema representation is probably out of sync with real database schema?

问答 2023-08-01 来自:开发者社区

大佬们,Flink CDC中采集tidb的数据,是否需要开启binlog日志呀?

大佬们,Flink CDC中采集tidb的数据,是否需要开启binlog日志呀?

问答 2023-07-31 来自:开发者社区

问下:Flink CDC中查一遍数据库的数据,是基于表查还是基于日志文件? 如果binlog是后面加

问下:Flink CDC中查一遍数据库的数据,是基于表查还是基于日志文件? 如果binlog是后面加的,没有历史数据,应该查不到吧?

问答 2023-07-26 来自:开发者社区

Flink CDC中,是写完snapshot后再读最新binlog吗?

Flink CDC中mysql cdc设置scan.startup.mode = initial时,是写完snapshot后再读最新binlog吗?这里最新是啥意思,启动时候开始的binlog,还是snapshot读完后的开始的binlog?

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注