14篇文章 · 35308字 · 3人关注
-
Flink源码阅读（13）--- Flink 不同版本新特性整理一. Flink 1.9 新特性 总的变更：https://issues.apache.org/jira/secure/ReleaseNote....
-
Flink源码阅读（11）--- Flink Task重启时机
本篇文章简单总结下Flink Task重启时机 1. Flink 集群正常 在Flink集群正常的情况下，只有Task出现异常才会依据重启...
-
Flink源码阅读（十）--- Flink 心跳机制
1. 背景 心跳机制通过定期向对方发送请求方式用于检测客户端或者服务端是否存活的一种机制，常见的心跳检测有两种： 1. socket 套接字...
-
Flink源码阅读（八）--- Flink SQL 整体执行流程为了批流统一，Flink提供了两种关系型API，Table API和SQL。Table API是一种语言集成的查询API，由多个比如select...
-
Flink源码阅读（七）--- Calcite 语法拓展Calcite主要是做SQL解析、校验、优化等工作，比如Flink、Hive底层都是使用的calcite。本文内容是基于Flink 1.12来讲...
-
Flink源码阅读（六）--- Flink 内存模型本篇文章主要介绍下FLink的内存模型，在介绍Flink内存模型之前，我们首先学习下JVM内存结构 1. JVM内存结构 Java7 升级为 J...
-
Flink源码阅读（五）--- checkpoint / savepoint恢复
Flink源码阅读（四）--- checkpoint制作[https://www.jianshu.com/p/539dbda544b0]这篇文章...
-
Flink源码阅读（四）--- checkpoint制作本文内容是基于Flink 1.9来讲解。Flink使用checkpoint检查点来保证Exactly-Once语义的，这篇文章会从源码角度分析下...
-
Flink作业提交（三）--- Job运行
源码分析JobMaster如何run起来[https://www.jianshu.com/p/24721c268141] 介绍到了JobMast...
文集作者