问答 2023-06-29 来自:开发者社区

你好,想问下,Flink CDC这个问题怎么解决,binlog文件在。?

$stringUtil.substring( $!{XssContent1.description},200)...

问答 2023-06-28 来自:开发者社区

老师,Flink读holo binlog作源表效率低,有什么优化的方法吗?

老师,Flink读holo binlog作源表效率低,有什么优化的方法吗?

问答 2023-06-24 来自:开发者社区

使用flink来消费hologres的binlog的自定义连接器的源码在哪儿了?

问题1:使用flink来消费hologres的binlog的自定义连接器的源码在哪儿了?想了解下。我看到官网有个HologresSource类,但是在github上搜不到这个类的源码。看hologres-connector-flink也没有对binlog来做特殊的处理?问题2:那可以理解为商业版的connetor里面有特殊处理binlog的source?

问答 2023-06-18 来自:开发者社区

哪位大佬可以指导一下,Flink CDC中这两个参数是可以从某个binlog文件名开始读取数据,通?

哪位大佬可以指导一下,Flink CDC中这两个参数是可以从某个binlog文件名开始读取数据,通过指定binlog位置开始同步数据呢?

问答 2023-06-18 来自:开发者社区

大佬们知道这个报错 如何解决吗?测试 我只是用IDEA把Flink cdc作为一个监听binlog的

$stringUtil.substring( $!{XssContent1.description},200)...

问答 2023-06-13 来自:开发者社区

请问使用实时计算Flink消费Hologres binlog时提示有不支持的数据类型,怎么处理?

请问使用实时计算Flink消费Hologres binlog时提示有不支持的数据类型“默认的Binlog源表不支持SMALLINT等数据类型,仅支持INTEGER、BIGINT、TEXT、REAL、DOUBLE PRECISION、BOOLEAN、NUMERIC(38,8)、DATE、TIMESTAMPTZ类型。” 该如何处理?是不是这条路就走不通了?

问答 2023-06-13 来自:开发者社区

在Flink我的hostname是 rr开头的 所以 binlog只能读10s以内的吗 ?

在Flink我的hostname是 rr开头的 所以 binlog只能读10s以内的吗 超过就会异常?场景四: 通过只读实例消费 CDC 数据,RDS的只读实例不保证binlog(本地最短可能只保留10s,上传oss),所以 MySQL CDC 侧不建议连接 RDS 的只读实例。 只读实例一旦作业 Failover 10s 内恢复不过来,就会有这个异常 只读实例判定,hostname 是...

问答 2023-06-11 来自:开发者社区

有一个问题,我可以如何确认Flink CDC任务消费 binlog 的延迟呢?就像 kafka 的

问题1:有一个问题,我可以如何确认Flink CDC任务消费 binlog 的延迟呢?就像 kafka 的 lag一样?大家有什么方法么?这个的确可以。 问题2:这个是看 debezium 的指标么?

问答 2023-06-11 来自:开发者社区

flink cdc在收到mysql binlog event时,是会等待其对应的被提交才下发这条?

flink cdc在收到mysql binlog event时,是会等待其对应的transaction被提交才下发这条binlog,还是会立即下发呢?

问答 2023-06-11 来自:开发者社区

Flink CDC后面想了另外一个思路,这里面大多是历史的,所以binlog消费增量; 手动统计一?

Flink CDC后面想了另外一个思路,这里面大多是历史的,所以binlog消费增量; 手动统计一个整数给历史 再历史+增量 = 全量,后面新数据,听您的建议。用维度建模拆分表,然后分别做统计?

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