Flink是可以支持本地调试的，本地调试的方式非常简单，就是在创建environment时创建localEnvironment即可。

代码如下所示：

创建localEnvironent之后，在IDEA里直接运行程序，默认会以多线程形式的本地JVM运行程序。

官方文档里还推荐说，也可以直接用：

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

来获取environment，Flink会自动的根据你的运行环境，来判断是需要返回localEnvironment。试了一下，确实也是可以的。

在本地运行时，可以就像普通Java程序一样，打印输出：

甚至进行单步debug:

都是可以的，十分方便。