初学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表达式方法体中（实际上也是算子内）文章来源：https://www.toymoban.com/news/detail-842467.html
四、造数据、Debug启动flink项目、向source发送数据，观察是否进入断点处
以kafka为例，直接往source topic发数据
数据来了
文章来源地址https://www.toymoban.com/news/detail-842467.html
结束语：分享让人快乐，欢迎交流！
到了这里，关于Flink本地Debug调试的方法和注意点的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
