抱歉,您的浏览器无法访问本站
本页面需要浏览器支持(启用)JavaScript
了解详情 >

Flink SQL 作业变慢后,最常见的动作是加并行度、调 managed memory、扩大 checkpoint timeout。这样有时能缓解问题,但也容易把一份错误的物理计划跑得更贵。

我接手一条 SQL 时,第一份材料不是 Web UI 截图,而是当时 Catalog、配置和 SQL 共同生成的 EXPLAIN。SQL 只是意图,真正消耗网络、状态和 CPU 的是优化后的物理节点。Join 选了广播还是 shuffle、聚合有没有两阶段、哪条边产生 Exchange、输出是 append 还是 retract,这些决定比一个笼统的“数据量大”更接近根因。

Flink SQL 从计划到运行证据的诊断链路