大数据IDEA调试flink程序

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了大数据IDEA调试flink程序相关的知识,希望对你有一定的参考价值。

Flink在IDEA中开发是一件比较困难的事情,网上没有参考资料,就算就业说的太过笼统,不知道是会了不说还是不会瞎说,为了解决flink这个问题,本人特别做了一遍开发的简单说明。主要考虑两个问题,1、语言环境的搭建。2、flink代码编译通过并运行

获取更多大数据视频资料请加QQ群:947967114 首先解决第一个问题:

创建一个maven环境,maven的配置方式不在介绍。也就是说看本文之前首先应该确保IDEA下的maven正常:

[if !supportLists]1、[endif]创建一个maven工程:file-new-project-Maven(拉到最下变找到scala-archetype-simple)如图:技术分享图片

[if !supportLists]2、[endif]设置GroupId和ArtifacId:

技术分享图片

[if !supportLists]3、[endif]注意选择自己下载的maven环境:

技术分享图片

继续 获取更多大数据视频资料请加QQ群:947967114

技术分享图片

配置完成之后看到的环境条件是这样的

技术分享图片

[if !supportLists]2、[endif]配置scala的环境,本人多添加了spark的环境:

File-Project Structure-Libraries-+Scala SDK:选择自己安装的windows的scala版本:
技术分享图片

添加spark环境(可以不加):File-Project Structure-Libraries-+---java
技术分享图片

[if !supportLists]3、[endif]重点来了,配置flink环境:File-Project Structure-Libraries-+---java选择自己下载的flink,这里需要加入两个包:一个是lib包一个是opt包,之后OK确定:

技术分享图片

我们看到我们选择好的环境是这样的:

技术分享图片

此时我们看到我们的工程的环境和依赖包是这样的:

技术分享图片

但是现在还不能进行开发,要进行目录的设置才行:main右键,Make Drectory As--Source Root 获取更多大数据视频资料请加QQ群:947967114

现在就可以在main包中创建flink程序了:
技术分享图片

一段测试程序及运行结果如下:

技术分享图片

小伙伴们如果你也成功了,请为自己鼓掌吧!!IT永无止境,加油加油!!!!!!! 获取更多大数据视频资料请加QQ群:947967114

以上是关于大数据IDEA调试flink程序的主要内容,如果未能解决你的问题,请参考以下文章

入门大数据---Flink开发环境搭建

Flink入门宝典(详细截图版)

2.3 基于IDEA开发第一个MapReduce大数据程序WordCount

flink入门实例-Windows下本地模式跑SocketWordCount

从入门到入土 大数据学习 最简单windows下idea运行调试spark程序

大数据:Windows下配置flink的Stream