请教一个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?

回复