1.1　环境准备

在下载、导入和阅读Flink源代码之前，需要准备好所需的环境。

1. JDK环境

根据计算机的操作系统类型，下载相应版本的JDK并安装。注意，需要保证JDK的版本在1.8及以上，原因是Flink使用了JDK 1.8中新增的lambda特性。JDK的下载地址为https://www.oracle.com/technetwork/java/javase/downloads/index.html。

执行以下命令配置环境：

$ vi ~/.bash_profile

添加Java环境配置：

export JAVA_HOME=/usr/local/java
export CLASSPATH=$:CLASSPATH:$JAVA_HOME/lib/
export PATH=$PATH:$JAVA_HOME/bin

环境配置设置完成后，执行source命令，让配置立即生效。

$ source ~/.bash_profile

最后，使用java -version命令确认安装正常，如图1-1所示。

2. Git

Flink源代码使用Git作为版本控制工具。访问Git的下载地址https://git-scm.com/downloads下载最新版本的Git并安装。

下面介绍如何配置SSH公钥。

1）生成GitHub使用的SSH公钥。输入下面的ssh-keygen命令，再按3次回车键即可。（注：-C后面跟的是GitHub账号的关联邮箱。）

$ ssh-keygen -t rsa -C 'xx@xx.com' -f ~/.ssh/id-rsa-github

2）将SSH公钥添加到GitHub。复制生成的公钥~/.ssh/id-rsa-github.pub的内容，再登录GitHub账号，在Account settings中单击New SSH key按钮，在新页面中将刚才复制的内容填入Key字段，并单击Add SSH key按钮进行保存，如图1-2所示。

3）通过下面的命令测试SSH公钥是否生效。

ssh -T git@github.com

4）出现GitHub欢迎界面，则配置成功，如图1-3所示。

对于一些开发者来说，除了个人的Git仓库外，公司也有Git仓库，因此需要配置多个SSH公钥。公司的Git仓库生成SSH公钥的方式与GitHub类似，只需创建一个ssh config配置即可。

$ vi ~/.ssh/config

ssh config配置内容如下：

#GitLab
Host gitlab.company.com
    HostName gitlab.company.com
    PreferredAuthentications publickey
    IdentityFile ~/.ssh/id-rsa-company
# GitHub
Host github.com
    HostName github.com
    PreferredAuthentications publickey
    IdentityFile ~/.ssh/id-rsa-github
host *
ControlMaster auto
ControlPath ~/.ssh/master-%r@%h:%p

3. Maven

Flink源代码使用Maven作为构建工具。Flink官方推荐使用Maven 3.2.5版本，Maven的下载地址为https://maven.apache.org/download.cgi#。注意，如果你下载的是Maven 3.3.x版本，则需注意Shade存在问题。

4. IntelliJ IDEA

Eclipse和IDEA都是流行的Java IDE，但由于Eclipse存在对Scala的兼容性问题，因此Flink官方推荐使用IntelliJ IDEA作为IDE。

（1）下载IntelliJ IDEA

读者可以通过IntelliJ IDEA的官方网站，根据自己的计算机操作系统进行下载和安装。下载地址为https://www.jetbrains.com/idea/download/。

（2）Scala

Scala是面向函数式编程的语言，在大数据的流式开发方面，相比Java，Scala开发更简洁方便。Flink主要用到的有Scala API、Flink SQL和Akka通信。IntelliJ IDEA默认不支持Scala开发环境，阅读源代码时需要安装Scala插件。

（3）Scala插件安装

在IntelliJ IDEA的菜单栏选择Preferences选项，然后选择Plugins选项，在搜索框中输入scala，如图1-4所示。在搜索出来的结果列表中选择Scala插件并安装，安装后重启IDEA，Scala插件即安装完毕。