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

Flink CDC中我的业务不太适合使用lookup join,同步的可以理解为,用户信息表,部门?

Flink CDC中我的业务不太适合使用lookup join,同步的可以理解为,用户信息表,部门表,权限表、角色表,jion后给整理成一个大宽表。这个有啥好的办法吗?

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

请问大佬Flink CDC双流join能同步删除吗? 我是直接flink mysql cdc ->

请问大佬Flink CDC双流join能同步删除吗? 我是直接flink mysql cdc -> reguler join -> mysql jdbc,表都有主键?

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

flink sql 双流regular join关联后结果输出到mysql, 不能同步删除,有大佬?

flink sql 双流regular join关联后结果输出到mysql, 不能同步删除,有大佬知道解决方案吗?

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

Flink CDC做join和聚合会对源数据库照成压力吗?look up 和 join 啥区别?

Flink CDC做join和聚合会对源数据库照成压力吗?look up 和 join 啥区别?

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

flink sql任务有三个mysql cdc 源表通过left join关联写入目标表,没更新?

flink sql任务有三个mysql cdc 源表通过left join关联写入目标表。过了半天之后,更新源表中的记录,发现目标表没更新。这是flink SQL不支持吗,还是要做什么特殊设置,或者使用什么语法?就是更新了where条件对应的记录,另外,大表join,是如何做实时记录匹配的,应该是需要流内存拦截吧,不然怎么做到实时匹配呢?假如关联的两张表的记录一个在最开始就来了,另一个迟了很久才....

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

请问flink mysql cdc 双流left join后再入库在目标表c没有删除呢?

"请问flink mysql cdc 双流left join后再入库mysql,insert into c select from a left join b,源表a某些数据删了,在目标表c没有删除呢?三个表都设置了主键。请问怎么解决?测试删除trans_detail的数据,在结果表里没有被删除,没有left join的话,能同步删除。INSERT INTO tr_flow_base_info_....

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

Flink CDC中,如果要join多张维表,for system-time as of要写多次?

Flink CDC中,如果要join多张维表,那个for system-time as of也是要写多次?

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

Flink CDC中维表join时候, 两个表join的字段类型不一致这个有解决方案吗?

问题1:Flink CDC中维表join时候, 两个表join的字段类型不一致这个有解决方案吗,改数据库字段类型肯定不行,已经是生产库了;org.apache.flink.table.api.TableException: implicit type conversion between VARCHAR(2147483647) and INTEGER is not supported on jo....

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

Flink CDC直接查数据库,是相当于普通的join了吗?

Flink CDC直接查数据库,是相当于普通的join了吗?

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

Flink CDC中多表join的原理是什么?

Flink CDC中多表join的原理是什么?是否是把所有的数据发送到flink内存之后在内存里做的关联?看了一下四张表总共22.09G,那就是需要内存比这还大的服务器才能做到全量同步?

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

产品推荐

阿里云实时计算Flink

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

+关注