IP属地：北京
-
Flink源码阅读（13）--- Flink 不同版本新特性整理一. Flink 1.9 新特性 总的变更：https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=...
-
FlinkSQL 语法扩展
FlinkSQL 语法扩展 参考flink-sql-parser模块了解下Flink如何扩展Calcite语法，创建空项目进行语法扩展。首先，拷贝codegen文件夹下的内容...
-
Flink源码阅读（11）--- Flink Task重启时机
本篇文章简单总结下Flink Task重启时机 1. Flink 集群正常 在Flink集群正常的情况下，只有Task出现异常才会依据重启策略发生Task重启。 2. ...
-
Flink源码阅读（十）--- Flink 心跳机制
1. 背景 心跳机制通过定期向对方发送请求方式用于检测客户端或者服务端是否存活的一种机制，常见的心跳检测有两种： 1. socket 套接字 SO_KEEPALIVE 本...
-
深入理解JVM-内存模型（jmm）和GC1 CPU和内存的交互 了解jvm内存模型前，了解下cpu和计算机内存的交互情况。【因为Java虚拟机内存模型定义的访问操作与计算机十分相似】 有篇很棒的文章，从cpu讲到内...
-
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源码阅读（六）--- Flink 内存模型本篇文章主要介绍下FLink的内存模型，在介绍Flink内存模型之前，我们首先学习下JVM内存结构 1. JVM内存结构 Java7 升级为 Java8的时候，JVM内存结构...
-
嗯，是的，学习并记录下
Flink源码阅读（四）--- checkpoint制作
本文内容是基于Flink 1.9来讲解。Flink使用checkpoint检查点来保证Exactly-Once语义的，这篇文章会从源码角度分析下checkpoint怎么触发的...
-
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。其中...
-
Flink源码阅读（一）--- StreamGraph 的生成
本文内容是基于Flink 1.9来讲解。在执行Flink任务的时候，会涉及到三个Graph，分别是StreamGraph，JobGraph，ExecutionGraph。其中...
-
go-gin源码(一)
hello world 使用Gin实现Hello world非常简单，创建一个router，然后使用其Run的方法： Default函数 函数返回一个默认的框架引擎，从函数实...
