Blink 源码编译

傷城~ 2022-01-07 08:25 375阅读 0赞

参考：[http://fetching118.com/article/5.html][http_fetching118.com_article_5.html]

帮助文档:[http://fetching118.com/blink\_doc/quickstart/scala\_shell\_quickstart.html][http_fetching118.com_blink_doc_quickstart_scala_shell_quickstart.html]

1、 从GitHub 官网下载Blink源码

[https://codeload.github.com/apache/flink/zip/blink][https_codeload.github.com_apache_flink_zip_blink]

2、搭建maven 环境，安装maven 3.1.1 版本.

[root@es ~]# mvn -v 
    Apache Maven 3.1.1 (0728685237757ffbf44136acec0402957f723d9a; 2013-09-17 23:22:22+0800)
    Maven home: /root/apache-maven-3.1.1
    Java version: 1.8.0_192, vendor: Oracle Corporation
    Java home: /usr/local/java/jdk1.8.0_192/jre
    Default locale: en_US, platform encoding: UTF-8
    OS name: "linux", version: "3.10.0-229.el7.x86_64", arch: "amd64", family: "unix"

** **为加快编译速度，可以修改maven的settings.xml配置文件，添加阿里云仓库.

<mirrors>
    
      <mirror>
        <id>nexus-aliyun</id>
        <mirrorOf>*,!jeecg,!jeecg-snapshots,!mapr-releases</mirrorOf>
        <name>Nexus aliyun</name>
        <url>http://maven.aliyun.com/nexus/content/groups/public</url>
      </mirror>
    
      <mirror>
        <id>mapr-public</id>
        <mirrorOf>mapr-releases</mirrorOf>
        <name>mapr-releases</name>
        <url>https://maven.aliyun.com/repository/mapr-public</url>
      </mirror>
    
    <mirrors>

## ##

### **scala 环境版本为2.11.12  ** ###

[root@es ~]# scala -version 
    Scala code runner version 2.11.12 -- Copyright 2002-2017, LAMP/EPFL

3、执行如下命令，编译Blink

因为我的hadoop 版本是第三方HDP版本的，所以需要执行如下命令.

mvn clean  package  -DskipTests   -Denforcer.skip=true  -Drat.skip=true      -Pvendor-repos    -Dhadoop.version=2.7.3.2.6.5.0-292

编译后的结果如下：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l1bGVpX3Fx_size_16_color_FFFFFF_t_70][]

4、BLink 界面如下图：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l1bGVpX3Fx_size_16_color_FFFFFF_t_70 1][]

[http_fetching118.com_article_5.html]: http://fetching118.com/article/5.html
[http_fetching118.com_blink_doc_quickstart_scala_shell_quickstart.html]: http://fetching118.com/blink_doc/quickstart/scala_shell_quickstart.html
[https_codeload.github.com_apache_flink_zip_blink]: https://codeload.github.com/apache/flink/zip/blink
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l1bGVpX3Fx_size_16_color_FFFFFF_t_70]: /images/20211227/82930b0aece643ca8d4f1b1fbc0423c7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l1bGVpX3Fx_size_16_color_FFFFFF_t_70 1]: /images/20211227/6830ef60efb24f49b28dffbba16d7415.png