3.2 分阶段采用Flink