开发者社区> 问答> 正文

flinksql关联维表延迟

我目前使用Flinksql构建了一个应用,数据源是kafka,关联了一张23w数据的维表(存放在Tidb),该维表和流中的数据关联会有一些发散(业务逻辑),使用了lookup.cache.maxprows=250000tel:250000,ttl=3600s,目前输出到kafka,延迟很严重,处理时间会领先事件时间几十分钟并且还会持续扩大,请问有什么好的解决办法吗?*来自志愿者整理的flink邮件归档

展开
收起
彗星halation 2021-12-02 16:56:27 749 0
1 条回答
写回答
取消 提交回答
  • “处理时间会领先事件时间几十分钟”是说延迟几十分钟吗?

    作业延迟的原因可能有很多,需要看到比较具体的作业才能有比较好的推测。一个自检的方法是打开 Flink web UI,观察 busy

    值比较高的节点,看看是否并发度不够,或者有倾斜,或者是否 checkpoint 时间太长等等。*来自志愿者整理的FLINK邮件归档

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

相关电子书

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