Re:flink实时双流驱动join问题

Mon, 19 Sep 2022 09:20:40 -0700 

Hi， 看上去这种情况只能使用inner join来实现，state很大的话有考虑过用FsStateBackend或者RocksDB 
StateBackend来存储state么?




--

    Best！
    Xuyang





在 2022-09-17 10:59:16，"casel.chen" <casel_c...@126.com> 写道：
>请教一个flink实现实时双流驱动join问题：
>
>
>order cdc流字段：order_id, order_status, order_time, user_id （order_id是主键）
>user cdc流字段：user_id, user_name, user_phone, user_address（user_id是主键）
>关联结果流字段：order_id, order_status, order_time, user_name, user_phone, 
>user_address（order_id是主键）
>期望当order流数据更新或user流数据更新时，关联结果流数据都会得到更新。inner join不满足是因为两条流distinct 
>id都很大，状态会很大，且不能TTL，因为user流更新时间不定，短的几小时，长达上月。
>
>
>请问这种场景下要如何使用flink实现实时双流驱动join？

回复