Flink源码阅读(1.7.2)
目录 Client提交任务 flink的图结构 StreamGraph OptimizedPlan JobGraph ExecutionGraph flink部署与执行模型 Single Job ...
原文：flink源码阅读（概览）
clone官方 . . 版本flink，成功编译。 一般PC还真跑不动，我是用服务器编译的 编译完后，略微修改了一下启动脚本后，成功跑起来。 sh bin start cluster.sh 红色部分是我改过的地方： vimstart cluster.sh bin dirname bin cd bin pwd FLINK BIN DIR bincd bin . config.sh 启动成功后就可以看 ...
2018-10-30 18:33 0 1311 推荐指数：
相关推荐
flink源码阅读（2）
Flink面试--源码篇 1、Flink Job的提交流程？ 2、Flink所谓"三层图"结构是哪几个"图"？ 3、JobManger在集群中扮演了什么角色？ 4、JobManger在集群启动过程中起到什么作用 ...
Flink源码阅读（二）——checkpoint源码分析
前言 在Flink原理——容错机制一文中，已对checkpoint的机制有了较为基础的介绍，本文着重从源码方面去分析checkpoint的过程。当然本文只是分析做checkpoint的调度过程，只是尽量弄清楚整体的逻辑，没有弄清楚其实现细节，还是有遗憾的，后期还是努力去分析实现细节。文中 ...
Flink源码阅读（一）--Checkpoint触发机制
Checkpoint触发机制 Flink的checkpoint是通过定时器周期性触发的。checkpoint触发最关键的类是CheckpointCoordinator，称它为检查点协调器。 CheckpointCoordinator主要作用是协调operators ...
Flink源码阅读（一）——Flink on Yarn的Per-job模式源码简析
一、前言 个人感觉学习Flink其实最不应该错过的博文是Flink社区的博文系列，里面的文章是不会让人失望的。强烈安利：https://ververica.cn/developers-resources/。 本文是自己第一次尝试写源码阅读的文章，会努力将原理和源码实现流程结合起来 ...
Flink源码阅读（一）——Per-job之Yarn的作业调度（一）
1、前言 Flink作业提交到Yarn上之后，后续的AM的生成、Job的处理过程和Flink基本没什么关系了，但是为大致了解Flink on yarn的Per-Job模式的整体过程，这里还是将这系列博客归到Flink源码阅读系列了，本系列博客计划三篇。 本文着重分析 ...
groupcache源码解析-概览
接下来讲什么 今天开始讲groupcache！ Memcached大家应该都不陌生，官网的介绍是： Free & open source, high-performance, ...
Flink源码阅读 - K8s上部署session模式的集群(入口配置)
启动主类 KubernetesSessionCli KubernetesSessionCli#mian 主类入口 // org.apache.flink.kubernetes.cli.KubernetesSessionCli#main public static void main ...