Flink debug

tammypi tammypi
2019-01-15 13:50
435
0

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

代码如下所示:

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

官方文档里还推荐说,也可以直接用:

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

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

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

甚至进行单步debug:

都是可以的,十分方便。

发表评论

验证码: