android源码编译下载-《Flink源码分析》--源码编译与执行

也想出现在这里？点击联系我~

立即下单

进入商城

进不了网站？换个网络试试！

《Flink源码分析》--源码编译与执行

我正在更新知识星球上的一篇源码分析文章。 我今年写的。 我周日录制了一个视频。 大家能看看有效吗？ 如果好的话我会把之前在知识星球上发表的其他源码分析文章贴出来。

前言

我将Flink源代码克隆到本地并编译，然后分享到GitHub。 我还在源码上写了一些英文注释，但是推送到了GitHub上。 这几天，阿里巴巴开源了宣传已久的Blink。 结果，我那种分支还能继续拉取新代码吗？ 另外，我研究Flink有一段时间了，所以我打算比较一下这两个东西。 这样一来，我可能会学到更多的东西，因为 Blink 是另一个分支，所以我干脆重新 fork 一份，拉到本地看源码。

叉

执行以下命令：

GitcloneGit@GitHub.com:apache/flink.Git

拉的时候，找一个网络比较好的地方，这样速度可能会快一些。

编译

因为想看Blink分支的代码，所以需要切换到blink分支，

Git 检查眨眼

这样就到达了blink分支，我们将编译blink源码并执行以下命令：

mvncleaninstall-Dmaven.test.skip=true-Dhadoop.version=2.7.6-Dmaven.javadoc.skip=true-Dcheckstyle.skip=true

maven编译时会跳过测试代码、javadoc和代码风格检测，这样可以节省很多时间。

注意：在你的maven settings.xml文件的镜像中添加以下内容：（这样下载依赖才能飞起来）

  nexus-aliyun
  *,!jeecg,!jeecg-snapshots,!mapr-releases
  Nexus aliyun
  http://maven.aliyun.com/nexus/content/groups/public
  mapr-public
  mapr-releases
  mapr-releases
  https://maven.aliyun.com/repository/mapr-public

执行该命令后，您可以拿出手机，打开陌陌，搜索微信ID：zhisheng_tian，然后点击添加好友。 欢迎讲解技术。

等待一段时间后，可能会遇到这个问题（听说很多童鞋都遇到过这个问题，之前编译Flink的时候也遇到过）：

[错误]无法在projectflink-mapr-fs上执行目标：无法解决projectcom.alibaba.blink的依赖关系：flink-mapr-fs：jar：1.5.1：无法找到com.mapr.hadoop：maprfs：jar：5.2.1-maprin被缓存在本地存储库中，直到nexus-aliyunhaselapsed的更新间隔之前，分辨率不会被尝试强制更新->[帮助1]

如果你尝试了两次都编译失败android源码编译下载，我在这里教你一个方法（如果执行编译命令后没有任何反应，请跳过，谁说你这么幸运）：

注释掉 flink-filesystems 中的 flink-mapr-fsmodule。

上图是我给你的建议，非常有用。

再次执行该命令，编译就不会出现错误了。 如果还有其他错误，我估计还是网络问题，导致一些美国maven依赖无法下载或者不完整。 由此造成的错误就是使用暴力。 像我一样，注释掉这些无法下载的依赖模块，也可以像编译好的童鞋一样，从Maven .m2文件中下载已经下载好的依赖，然后复制粘贴到自己的本地路径中。 注意路径包名不要写错。 这通常可以解决所有问题。 如果还有问题，我也无能为力。

如果编译成功，会如右图所示：

跑步

之后我们的目录将如下所示：

标记的就是我们的可执行文件，就像我们从Flink官网下载的一样。 我们可以运行一下看看效果。

我将其移至/usr/local/blink-1.5.1。 就我个人而言，我喜欢将一些已安装的软件安装在/usr/local/目录下。

目录结构和我之前的安装介绍文章类似，就是多了一个batch_conf目录，和conf目录一样。 不知道为什么有两个配置文件目录。 我问负责人也不理我，哈哈哈。

所以我们把它拿出来运行Blink，进入bin目录，执行可执行文件：

./start-cluster.sh

Windows可以通过点击start-cluster.bat来启动，对于Windows用户来说更加友好。

执行命令后，在浏览器中访问地址：8081/，出现如右图，说明Blink已经成功启动：

上图是开源版本的红色主题。 在学习了Flink组中如何改变激进的红色主题后，编译运行后的效果如下：

出于好奇，我执行了几次启动命令，发现只能正常运行。

启动后日志如下：

说明已经启动了9个TaskManager，然后我们在页面上可以看到监控信息如下：

可以看到，监控信息上已经有40个可用槽位。 这是因为 Blink 默认为具有 4 个插槽的 TaskManager。 我们总共启动了 10 个 TaskManager，因此将有 40 个可用槽。 注意：Flink 默认配置是一个 TaskManager 只丰富 1 个 slot，但是这个可以自己分配。

注意：打开多个TaskManager后，如果想关闭它们，必须执行相同次数的关闭命令：

./stop-cluster.sh

英文源码分析

支持视频分析

视频录制过程难免有错误，还请指教

相关的

更多源码分析文章和Flink资讯android源码编译下载，请添加知识星球！