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