问答 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能使用jdbc模式读hologres的binlog吗?

问题1:简单权限模式下,Flink能使用jdbc模式读hologres的binlog吗? 我们表的owner是prod_developer,这个角色没有Replication Role权限。(hologres2.0版本)问题2:cannot alter or drop reserved roles in SPM (Simple Permission Mode)

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

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

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

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

Flink CDC中增量监听binlog日志同步的时候也会把全部数据都加载到内存吗?

Flink CDC中增量监听binlog日志同步的时候也会把全部数据都加载到内存吗?有没有试过?我现在还在全量同步阶段,如果单独的增量同步不存在全部加载到内存的问题的话,可不可以先用维表的方式做完全量同步。然后再全部流表,但是启动时跳过快照阶段,直接指定位点启动一个新的任务做后续更新同步。

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

Flink CDC中这个怎么解决?我是在创建表之后,才开启的binlog,这样操作是不是不行?

Flink CDC中这个怎么解决?我是在创建表之后,才开启的binlog,这样操作是不是不行?

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

Flink CDC有没有办法只同步全量一次,不读binlog?

Flink CDC有没有办法只同步全量一次,不读binlog?

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