Flink是可以支持本地调试的,本地调试的方式非常简单,就是在创建environment时创建localEnvironment即可。
代码如下所示:
创建localEnvironent之后,在IDEA里直接运行程序,默认会以多线程形式的本地JVM运行程序。
官方文档里还推荐说,也可以直接用:
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
来获取environment,Flink会自动的根据你的运行环境,来判断是需要返回localEnvironment。试了一下,确实也是可以的。
在本地运行时,可以就像普通Java程序一样,打印输出:
甚至进行单步debug:
都是可以的,十分方便。
发表评论