开发者社区 问答 正文

Flink 1.12 中,Shuffling有哪些优化?

已解决

Flink 1.12 中,Shuffling有哪些优化?

展开
收起
詹姆斯邦德00 2022-06-30 15:25:30 468 分享 版权
1 条回答
写回答
取消 提交回答
  • 推荐回答

    为了消除不必要的序列化反序列化开销、数据 spilling 开销,提升 Table API / SQL 上批作业和流作业的性能, planner 当前会利用上一个版本中已经引入的N元算子(FLIP-92),将由 forward 边所连接的多个算子合并到一个 Task 里执行。

    以上内容摘自《开源大数据前瞻与应用实战》电子书,点击https://developer.aliyun.com/topic/download?id=1153可下载完成版

    2022-06-30 16:13:02
    赞同 展开评论