Flink背压原理以及解决优化

由于进行双11压测,遇到了Flink的背压问题。 1.背压的监控 如果看到任务的背压警告(如 High 级别),这意味着 生成数据的速度比下游算子消费的的速度快。以一个简单的 Source -> Sink 作业为例。如果能看到 Source 有警告,这意味着 Sink 消耗数据的速度比 Source 生成速度慢。Sink 正在向 Source 施加反压。 许多情况都会导致背压。例如,GC导致传入数
相关文章
相关标签/搜索