【Flink基础】-- 源码中的注解
1.Flink自定义注解级别 在升级 Flink版本至 1.15.3时，偶然遇到了一个异常，然后就准备详细了解下源码中的注解。设计注解的初衷：为了更好地进行代码和版本管理，Flink使用了Java的注解特性自定义了注解，对代码进行增强说明。注解的使用场景：提供信息给编译器：编译器可以利用注解来探测错...
Flink 源码解析 —— 项目结构一览
Flink 源码项目结构一览https://t.zsxq.com/MNfAYne博客1、Flink 从0到1学习 —— Apache Flink 介绍2、Flink 从0到1学习 —— Mac 上搭建 Flink 1.6.0 环境并构建运行简单程序入门3、Flink 从0到1学习 —— Flink ...
Flink执行流程与源码分析
本篇的主题是"Flink架构与执行流程",做下小结，Flink on Yarn的提交执行流程，整体的流程与架构可能三两张图或者三言两语就可以勾勒出画面，但是背后源码的实现是艰辛的。源码的复杂度和当初设计框架的抓狂感，我们只有想象。
Flink SQL 知其所以然：在 Flink 中还能使用 Hive Udf？（附源码）
本文主要介绍 flink sql 流任务中，不能使用 create temporary function 去引入一个用户自定义的 hive udf。因此博主只能通过 flink sql 提供的 module 插件能力，自定义了 module，来支持引入用户自定义的 hive udf。