aiguang2016

flink的执行计划分为四层： 通过Stream API提交的文件，首先会被翻译成StreamGraph。StreamGraph的生成的逻辑是在StreamGraphGene...