BlackC

关于Flink-1.11中SqlClient的Bug

发表于 2020-06-03 更新于 2021-03-21 分类于大数据

在使用SqlClient时出现的一些问题整理

发表于 2020-06-01 更新于 2021-03-21 分类于大数据

等不及官网出包了,自己动手编译

发表于 2020-05-29 更新于 2021-03-21 分类于大数据

此流程是基于1.10.x版本的,对于1.11.x来说存在许多不足;所以根据问题去看源码

发表于 2020-05-28 更新于 2021-03-21 分类于大数据

介绍JobGraph被提交之后,JobManager如何接收到该请求,以及如何生成ExecutionGraph

发表于 2020-05-28 更新于 2021-03-21 分类于大数据

在Client端生成的两个Graph都已经生成完毕,这时候需要实现客户端到服务端的一个过渡

发表于 2020-05-26 更新于 2021-03-21 分类于大数据

基于Flink-1.10.0,此版本只能在flink-conf.yaml中控制source并行度

发表于 2020-05-25 更新于 2021-03-21 分类于大数据

并没有涉及Flink的本身使用的序列化器的改动,只是flink使用的kryo依赖等级过低

发表于 2020-05-11 更新于 2021-03-21 分类于大数据

接着上一篇StreamGraph已经被生成出来了,根据Flink的四层图结构,接下来就是JobGraph的生成

发表于 2020-05-09 更新于 2021-03-21 分类于大数据

记录描述不清楚的内容,系列完成后进行删除

发表于 2020-05-09 更新于 2021-03-21 分类于大数据

在之前的文章中介绍过FlinkSQL底层是怎么实现的，以及Flink的一些概念性知识。一直想整理Flink执行层面的源码，但是因为过于庞大，不知道如何下手，只能一步一步来。