欢迎光临
我们一直在努力

第 09 篇:「网络栈与数据交换」—— Credit-based 反压如何把流控从 TCP 提前到应用层

仓库:https://github.com/apache/flink 官方文档:https://nightlies.apache.org/flink/flink-docs-lts/ 技术栈:Java 11 / Netty / Credit-based Flow Control / ResultPartition / InputChannel / BufferPool 解读版本:release-1.20.5(commit 0980485) 解读视角:总架构师评审(架构 / 源码 / 生产 / 进阶)

第 09 篇:「网络栈与数据交换」—— Credit-based 反压如何把流控从 TCP 提前到应用层

阅读本文你将了解:

  • Flink 网络栈是两层抽象:ShuffleEnvironment(NettyShuffleEnvironment)管\”全局资源与连接\”,ResultPartition/InputGate 管\”单个 Task 的读写端点\”(flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NettyShuffleEnvironment.java:82)。
  • 反压的真正落点是一行代码:写端拿
  • 赞(0)
    未经允许不得转载:171主机测评 » 第 09 篇:「网络栈与数据交换」—— Credit-based 反压如何把流控从 TCP 提前到应用层
    分享到: 更多 (0)

    评论 抢沙发

    • 昵称 (必填)
    • 邮箱 (必填)
    • 网址