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?