WSC Blog
首页
分类
源码分析
12
技术
39
标签
归档
传送
Github
关于
关于
更多
友链
推荐阅读
Flink V1.20源码阅读笔记(1)- StreamGraph 的生成
在编写Flink的程序的时候,核心的要点是构造出数据处理的拓扑结构,即任务执行逻辑的DAG。我们先来看一下Flink任务的拓扑在逻辑上是怎么保存的。StreamGraph相关的代码主要在 org.apache.flink.stre...
Flink
源码分析
5个月前
Flink V1.20源码阅读笔记(2)- JobGraph 的生成
前面的文章我们介绍了StreamGraph的生成,这个实际上只对应Flink作业在逻辑上的执行计划图。Flink会进一步对StreamGraph进行转换,得到另一个执行计划图,即JobGraph。以此段代码为例,env.fromData(1...
Flink
源码分析
5个月前
Flink V1.20源码阅读笔记(3)- ExecutionGraph 的生成
我们前面已经分析过StreamGraph,JobGraph的生成过程,这两个执行图都是在client端生成的。接下来我们将把目光头投向FlinkJob运行时调度层核心的执行图-ExecutionGraph。以此段代码为例,env.fromD...
Flink
源码分析
4个月前
Flink V1.20源码阅读笔记(4)- RPC通信
作为一个分布式系统,Flink内部不同组件之间通信依赖于RPC机制。这篇文章将对Flink的RPC框架加以分析。 主要抽象RpcEndpoint是对RPC框架中提供具体服务的实体的抽象,所有提供远程调用方法的组件都需要继承该抽象类...
Flink
源码分析
4个月前
Flink V1.20源码阅读笔记(5)- 集群启动流程之HA
在这篇文章中,我们将对 Flink HA加以分析...
Flink
源码分析
3个月前
说说
3周前
尝试参与开源贡献
2个月前
雪花算法使用不当造成ID重复
5个月前
优化文章取消发布后,未取消分享问题
5个月前
开始Flink源码学习
10个月前
将博客迁移至云服务器
推荐阅读
🔥
Flink V1.20源码阅读笔记(1)- StreamGraph 的生成
🔥
Flink V1.20源码阅读笔记(2)- JobGraph 的生成
🔥
Flink V1.20源码阅读笔记(3)- ExecutionGraph 的生成
🔥
Flink V1.20源码阅读笔记(4)- RPC通信
🔥
Flink V1.20源码阅读笔记(5)- 集群启动流程之HA
阿财
漫漫优化路,总会错几步!
GitHub
邮件
公告
本网站转载的文章、图片、音视频等资料,均来源于互联网和媒体,转载目的在于个人记录。如涉及作品内容、版权和其它问题,请在30日内与本网站联系,我们将在第一时间删除内容!
最新评论
加载中...