一. Flink 1.9 新特性 总的变更：https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=...
IP属地：北京
-
Flink源码阅读（13）--- Flink 不同版本新特性整理 -
Flink源码阅读（十）--- Flink 心跳机制
1. 背景 心跳机制通过定期向对方发送请求方式用于检测客户端或者服务端是否存活的一种机制，常见的心跳检测有两种： 1. socket 套接字 SO_KEEPALIVE 本...
-
Flink源码阅读（八）--- Flink SQL 整体执行流程为了批流统一，Flink提供了两种关系型API，Table API和SQL。Table API是一种语言集成的查询API，由多个比如selection，filter，join...
-
Flink源码阅读（七）--- Calcite 语法拓展Calcite主要是做SQL解析、校验、优化等工作，比如Flink、Hive底层都是使用的calcite。本文内容是基于Flink 1.12来讲解。 首先从整体上对Calci...
-
Flink源码阅读（五）--- checkpoint / savepoint恢复
Flink源码阅读（四）--- checkpoint制作[https://www.jianshu.com/p/539dbda544b0]这篇文章介绍了checkpoint制作...
-
Flink源码阅读（四）--- checkpoint制作本文内容是基于Flink 1.9来讲解。Flink使用checkpoint检查点来保证Exactly-Once语义的，这篇文章会从源码角度分析下checkpoint怎么触发的...
-
Flink作业提交（三）--- Job运行
源码分析JobMaster如何run起来[https://www.jianshu.com/p/24721c268141] 介绍到了JobMaster.start方法，这个方法...
-
Flink源码阅读（三）--- ExecutionGraph 的生成
本文内容是基于Flink 1.9来讲解。在执行Flink任务的时候，会涉及到三个Graph，分别是StreamGraph，JobGraph，ExecutionGraph。其中...
-
Flink源码阅读（二）--- JobGraph 的生成
本文内容是基于Flink 1.9来讲解。在执行Flink任务的时候，会涉及到三个Graph，分别是StreamGraph，JobGraph，ExecutionGraph。其中...