发简信
IP属地：江苏
概述 根据上一篇文章 DataStream API 可以得知每一个方法生成的Transformation和实际运行中对Task的影响。事实上从Transformation到实...
概述 因为自己在阅读源码的过程中曾经遇到过很多问题，现在稍微有一点点的经验希望分享给很多从零开始的人。Apache的项目代码量很大，很难做到彻底通读，我也是一步一步的先从整体...
概述 这篇文章侧重于分析JobManager和TaskManager的启动过程以及注册，还有Flink的implementation中所用到的设计模式。本文从本地与stand...
杂谈 有一段时间没有写技术博客了，正好之前花了一周的时间解决了一个Flink在Yarn上部署的问题，也将Flink在Yarn上运行的机制与源码了解了个大概。Flink在Yar...
杂谈 首先声明一下，这篇文章很杂，涉及到了挺多的模块，其实应该分为几篇来写更为合理，不过一口气写完了也就先发出来了，后续有空看看能不能改一下。 概述 本文介绍了Flink在Y...
概述 以Flink算子的视角为入口，解析它们是如何设计和工作的。 重点在AbstractStreamOperator 实现StreamOperator的接口和抽象类 首先是S...
概述 这篇文章是但不仅仅是官方文档的中文翻译，还有里面每一个方法对应的Transformation和运行时对Task的影响。 Prerequisites 关于算子想说的有很多...
