对于一个新框架的学习,第一步往往是对源码初步了解和DEBUG。这些都是学习的套路。

       本文主要是讲讲flink的源码编译,案例运行,flink源码调试过程。调试flink的源码及案例,需要先clone工程,编一下源码,去掉规范检查,修改工程,最后才是调试运行。

一、clone源代码

git clone https://github.com/apache/flink.git

  

二、切换分支

 使用idea打开,并切换分支即可。

 

三、编译源码

     源码编译可以直接用idea的maven插件。

 

      报错如下:

      可以采用不改代码,直接修改命令即可。

      采用命令直接编译:mvn clean install -Dcheckstyle.skip=true -DskipTests

      仍然报错:

     修改命令为: mvn clean install -Dcheckstyle.skip=true -Drat.skip=true -DskipTests 

     大功告成!!!!

 

四、运行demo

       点开工程栏,找到flink-examples模块,然后找到wordCount案例,如下:

       直接运行即可跑起来。

      关于debug,只要run运行成功之后,直接可以debug的。。。

 

 

 

 

 

 

 

 

 

Logo

瓜分20万奖金 获得内推名额 丰厚实物奖励 易参与易上手

更多推荐