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

Flink CDC中一张流表去关联多张维表的这效率太差,几分钟才跑了几千条,这怎么优化呀?

"问题1:Flink CDC中一张流表去关联多张维表的这效率太差,几分钟才跑了几千条,这怎么优化呀?其实我一张流表关联六张维表,而且数据都是一对一的,设置缓存也没用,全当流表效率很高,但是内存不够。当维表效率太差了。每张表都是一千万数据。我本来都是流表,只是流表join会全部加载到内存里,内存不够用。所以就改成流表关联维表。七张表各有一千万数据,都是一对一关联的,从MySQL库同步到starro....

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

Flink CDC中这种情况请问该如何优化?

问题1:Flink CDC中我这边规则维表有3万多记录,业务数据kafka 读取,lookup join 该规则维表,但关联字段不是规则维表的主键,关联后可能会输出多条记录现在偶尔出现 TIMED_WAITING on java.util.concurrent.locks.AbstractQueuedSynchronizer 的报错请问该如何优化?规则维表用jdbc 读取,设置了参数lookup....

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

Flink CDC中请问如果lookup join 提示 超时,锁问题,一般如何优化?

Flink CDC中请问如果lookup join 提示 超时,锁问题,一般如何优化?调整参数?lookup.cache.max-rowslookup.cache.ttl

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

Flink CDC差不多1s同步一条数据,效率很低,有没有优化方案?走的内网。

"问题1:Flink CDC差不多1s同步一条数据,效率很低,有没有优化方案?走的内网。我就是dinky上弄的。连接器版本checkpoint配的3000s问题2:这都20分钟了,是不是有点慢了,还没有数据写进去,写到KAfka。"

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

请问下 flink cdc 全量初始化mysql表时,主键是字符串类型同步很慢,这个需要咋优化配置?

请问下 flink cdc 全量初始化mysql表时,主键是字符串类型同步很慢,这个需要咋优化配置参数?目前我设置了 chunk size 4k-10w之间变化不明显,速度很慢1-2K/s,如果主键时bigiint 没啥问题?

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

Flink CDC中大佬你测过初始化时候的同步速度吗?我现在407w数据要同步14分钟,有优化办法吗

Flink CDC中大佬你测过初始化时候的同步速度吗?我现在407w数据要同步14分钟,有优化办法吗

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

Flink CDC这个版本oracle有优化吗?好慢啊,看了issue 感觉Oracle问题不少,

Flink CDC这个版本oracle有优化吗?好慢啊,看了issue 感觉Oracle问题不少,这个已经在优化了吗

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

有人用多表Flink CDC中left join吗?90多个g感觉都够呛,有好的优化方案啥的吗?

有人用多表Flink CDC中left join吗?90多个g感觉都够呛,有好的优化方案啥的吗?

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

有没有朋友做过Flink CDC目标端为mpp 列存数据库dml入库性能的优化?

有没有朋友做过Flink CDC目标端为mpp 列存数据库dml入库性能的优化?

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

Flink CDC es每天做的segment很大,有什么办法优化吗?

Flink CDC es每天做的segment很大,有什么办法优化吗?

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

产品推荐

阿里云实时计算Flink

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

+关注