我们在https://www.cnblogs.com/dongxiao-yang/p/9403427.html文章里分析了flink提交single job到yarn集群上的代码,flink在1.5版
dispatcherGatewayFuture = getDispatcherGatewayFuture(); // we have to allow queued scheduling in Flip
2.9 删除Flink的传统模式 FLINK-10392 Apache Flink 1.7.0 标志着 Flip-6 工作已经完全完成并且与传统模式达到功能奇偶校验。
10.删除Flink的传统模式 Apache Flink 1.7.0标志着Flip-6工作已完全完成并且与传统模式达到功能奇偶校验的版本。 因此,此版本删除了对传统模式的支持。
dispatcherGatewayFuture = getDispatcherGatewayFuture(); // we have to allow queued scheduling in Flip
新版本对底层的一些基础组件进行了改进,包括: 重新设计并实现了 Flink 的大部分处理模型(FLIP-6)。
“一开始我完全看不懂他们在说什么,当时正在做 FLIP-6 提案即集群管理大重构,每天在邮件列表上拼命地看,从邮件里提到的链接一个跳过一个地去了解背景,直到加入阿里开始接受实习任务改过几行代码,这个祛魅的过程才完成
Kubernetes Deployment 创建好后,包含了 FLIP-6 新架构里指定的多项组件,例如 Dispatcher、ResourceManager、JobMaster(也叫做 JobManager
Flink 将原生支持 Kubernetes Flink 有着非常活跃的开源社区,他们不断改进自身设计(FLIP-6),以适应现今的云原生环境。
different category for apply different failover strategy [FLINK-10288] Failover Strategy improvement FLIP
FLINK-12122[40]:在 Flink 1.5.0 中,FLIP-6[41] 改变了 slot 在 TaskManager 之间的分布方式。
删除Flink的传统模式 Apache Flink 1.7.0 标志着 Flip-6 工作已经完全完成并且与传统模式达到功能奇偶校验。因此,此版本删除了对传统模式的支持。 FLINK-12122[40]:在 Flink 1.5.0 中,FLIP-6[41] 改变了 slot 在 TaskManager 之间的分布方式。 FLINK-12122[40]:在 Flink 1.5.0 中,FLIP-6[41] 改变了 slot 在 TaskManager 之间的分布方式。
FLINK-12122[40]:在 Flink 1.5.0 中,FLIP-6[41] 改变了 slot 在 TaskManager 之间的分布方式。
FutureUtils.completedExceptionally(e); } // we have to allow queued scheduling in Flip 关于事件时间模型,更多内容可以参考Stream 101 和谷歌的这篇论文:Dataflow Model paper 7.2 FLIP-6 部署及处理模型演进 就在老白写这篇blog的时候,Flink发布了其 1.5 RELEASE版本,号称实现了其部署及处理模型(也就是FLIP-6),所以打算简略地说一下FLIP-6的主要内容。
return FutureUtils.completedExceptionally(e); } // we have to allow queued scheduling in Flip