大佬们，问一个flink运行问题，集群因为网络问题，flink的JM、TM通信超时后挂掉，这种挂掉应
大佬们，问一个flink运行问题，集群因为网络问题，flink的JM、TM通信超时后挂掉，这种挂掉应该不属于cancel吧？那么即使程序中没有设置cancel时保存checkpoint，也是会保留checkpoint吧？
Apache Flink 进阶（七）：网络流控和反压剖析
作者：张俊整理：张友亮（Apache Flink 社区志愿者） 本文共 4745字，预计阅读时间 15min。 本文根据 Apache Flink 系列直播整理而成，由 Apache Flink Contributor、OPPO 大数据平台研发负责人张俊老师分享。主要内容如下： 网络流控的概念与背景 TCP的流控机制 Flink TCP-based 反压机制（before V1.5） Flin.....
咱们从头到尾讲一次 Flink 网络流控和反压剖析
作者：张俊整理：张友亮（Apache Flink 社区志愿者） 本文共 4745字，预计阅读时间 15min。 本文根据 Apache Flink 系列直播整理而成，由 Apache Flink Contributor、OPPO 大数据平台研发负责人张俊老师分享。主要内容如下： 网络流控的概念与背景 TCP的流控机制 Flink TCP-based 反压机制（before V1.5） Flin.....
深入了解 Flink 网络栈（二）：监控、指标和处理背压
作者 | Nico Krube译者 | 王强 在之前的文章中，我们从高级抽象到底层细节各个层面全面介绍了 Flink 网络栈的工作机制。作为这一系列的第二篇文章，本文将在第一篇的基础上更进一步，主要探讨如何监视与网络相关的指标，从而识别背压等因素带来的影响，或找出吞吐量和延迟的瓶颈所在。本文将简要介绍处理背压的手段，而之后的文章将进一步研究网络栈微调的话题。如果你不是很熟悉网络栈的知识，强烈建议....
Flink 网络传输优化技术
5万人关注的大数据成神之路，不来了解一下吗？ 5万人关注的大数据成神之路，真的不来了解一下吗？ 5万人关注的大数据成神之路，确定真的不来了解一下吗？ 作为工业级的流计算框架，Flink 被设计为可以每天处理 TB 甚至 PB 级别的数据，所以如何高吞吐低延迟并且可靠地在算子间传输数据是一个非常重要的课题。此外，Flink 的数据传输还需要支持框架本身的特性，例如反压和用于测量延迟的 latenc....
原理解析 | 深入了解 Apache Flink 的网络协议栈
作者：Nico Kruber 翻译：曹英杰 Flink 的网络协议栈是组成 flink-runtime 模块的核心组件之一，是每个 Flink 作业的核心。它连接所有 TaskManager 的各个子任务(Subtask)，因此，对于 Flink 作业的性能包括吞吐与延迟都至关重要。与 TaskManager 和 JobManager 之间通过基于 Akka 的 RPC 通信的控制通道不同，Ta....
Flink运行时之网络通信NetworkEnvironment分析
网络环境（NetworkEnvironment）是TaskManager进行网络通信的主对象，主要用于跟踪中间结果并负责所有的数据交换。每个TaskManager的实例都包含一个网络环境对象，在TaskManager启动时创建。NetworkEnvironment管理着多个协助通信的关键部件，它们是： NetworkBufferPool：网络缓冲池，负责申请一个TaskManager的所有的内.....
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
