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

Flink CDC中四张表做leftjoin关联然后sink。flinkCDC是怎么做join?

Flink CDC中四张表做leftjoin关联,然后sink到一张表。flinkCDC是怎么做join的?是把所有数据发送到flink内存里,在内存里做的关联?造了一千万数据,MySQL显示有两张表的数据已经全部发送了。

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

Flink CDC中关于维表join这种情况下flinksql咋写呢 ?

Flink CDC中关于维表join,假如我的动态表是A,我要补充的数据在表C,但是两者需要通过表B才能关联起来,这种情况下flinksql咋写呢 ?lookup join。动态表A,要取的补充字段在表C,表A和表C需要表B才能关联上,这种属于多流join?

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

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

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

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

Flink CDC中维表join支持多个吗?

Flink CDC中维表join支持多个吗?

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

大佬们,我想请问下,Flink中我是用flinksql进行批处理操作,在left join的时候会?

大佬们,我想请问下,Flink中我是用flinksql进行批处理操作,在left join的时候会产生回撤流,这是不是flink批处理不是特别友好呀?我这边也是使用的execution.runtime-mode=BATCH,但是还是会产生回撤流

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

Flink中FLINK-SQL,两个千万级的表join,并行度12,tm=4096m,慢得扣卡,?

Flink中FLINK-SQL,两个千万级的表join,并行度12,tm=4096m,慢得扣卡,有没大佬知道哪个环节出了问题?

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

flink lookup join

select table_A.user_id ,max(table_B.end_time) as last_timefrom table_Aleft join table_B FOR SYSTEM_TIME as of table_A.process_time as table_Bon table_A.user_id=table_B.user_idand table_B.status='0'...

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

大佬们,Flink中双流join,要全量join,状态无限增长,这种有什么好的解决方案么??cdc打

大佬们,Flink中双流join,要全量join,状态无限增长,这种有什么好的解决方案么??cdc打宽表a是啥意思呀这个方案没看懂,不能维表join,数据不能过期不能设置ttl

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

Flink CDC中flink interval join 默认效果是inner join吗,支不?

Flink CDC中flink interval join 默认效果是inner join吗,支不支持left join效果

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

looup join时,Flink维表发生变化,会重新下发join后的数据嘛?还是说只有主流来了,才

looup join时,Flink维表发生变化,会重新下发join后的数据嘛?还是说只有主流来了,才会触发join

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

产品推荐

阿里云实时计算Flink

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

+关注