0


Flink本地Debug调试的方法和注意点

初学flink可能会疑惑flink项目如何本地调试,毕竟和后端项目不同。本文介绍flink项目本地debug方法和注意点。

以IDEA Maven项目(java开发语言)为例,步骤如下:
一、设置执行环境为Local

StreamExecutionEnvironment env =StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(configuration);

公司封装后如下:
在这里插入图片描述
注意,调试完后需要修改回集群环境:

StreamExecutionEnvironment env =StreamExecutionEnvironment.getExecutionEnvironment();

**二、设置参数
在这里插入图片描述
在这里插入图片描述
注意:
1、如果环境变量依各自公司情况进行修改,一般配置文件需要配置进来,如,我的Programme arguments为

–nacos.cover.config true --config_path C:\workspace\flink-app-data-warehouse\streaming-app-fd-first-project-online6\src\main\resources\application.properties
2、maven项目中有运行环境提供依赖,则需要设置 add dependencies with “provided” scope to calsspath,否则会报错NoClassDefFoundError,配置如下:
在这里插入图片描述
三、打断点

在合适的地方打断点,否则不会弹出debug界面!!!!
一般为:
1、算子的function函数中,比如processElement方法内;
在这里插入图片描述

2、main方法中算法的lambda表达式方法体中(实际上也是算子内)

在这里插入图片描述
在这里插入图片描述
四、造数据、Debug启动flink项目、向source发送数据,观察是否进入断点处
以kafka为例,直接往source topic发数据
在这里插入图片描述数据来了
在这里插入图片描述

结束语:分享让人快乐,欢迎交流!


本文转载自: https://blog.csdn.net/weixin_44883450/article/details/132882057
版权归原作者 pino~ 所有, 如有侵权,请联系我们删除。

“Flink本地Debug调试的方法和注意点”的评论:

还没有评论