初学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~ 所有， 如有侵权，请联系我们删除。
版权归原作者 pino~ 所有， 如有侵权，请联系我们删除。