开发者社区> 问答> 正文

flink多表延迟可以实现关联吗?

上游有多个流需要经过flink作近实时关联,数据流有先到和后到问题,为了尽可能关联上,有什么办法可以实现延迟关联吗?每个流开个1分钟窗口再关联相同key的元素可以吗?用flink sql如何实现?谢谢*来自志愿者整理的flink邮件归档

展开
收起
彗星halation 2021-12-02 11:34:01 692 0
1 条回答
写回答
取消 提交回答
  • 我们是改造了kakfa-sql-connector实现的,用优先队列缓存数据 到达一定时间再发出来

    datastream可以用窗口+side output来实现,但是sql没有side output实现,所以存在丢数据的情况*来自志愿者整理的FLINK邮件归档

    2021-12-02 11:48:47
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载