第一章:Flink 是怎么跑起来的?——从入口点开始扒源码Flink 项目那么大,要看源码从哪儿开始?别慌,带你一点点扒。一般来说,我们提交一个 Flink 程序,大多是通过 StreamExecutionEnvironment.getExecutionEnvironment().execute() 这句熟得不能再熟的代码。那么我们今天就从这条链开始撸,看看底下藏了多少妖魔鬼怪。StreamExecutionEnvironment 背后是个啥?这货是用户入口类,不管你是写批的还是流的,基本都绕不过去它。我们直接看 getExecutionEnvironment() 这个方法: public s...