Flink任务如何跑起来之 1.DataStream和Transformation 在使用Flink完成业务功能之余，有必要了解下我们的任务是如何跑起来的。知其然，知其所以然。 既然重点是学习应用程序如何跑起来，那么应用程序的内容不重要，越简单越好。 WordCount示例作为学习数据引擎时hello word程序，再合适不过。接下来便以任务执行顺序为线索开启对源码逐步学习。 public class WordCount { public static void main(String[] args) throws Exception { Configuration configuration = new Configuration(); configuration.setString("rest.port", "9091"); StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(configuration);...
