Flink安裝及使用

1、官網下載Flink
## 官網地址
$ https://flink.apache.org/downloads.html

## 下載地址
$ wget http://mirror.bit.edu.cn/apache/flink/flink-1.9.2/flink-1.9.2-bin-scala_2.11.tgz
文件保存在/root/soft目錄下

2、安裝

$ cd /root/soft $ sudo tar -zxf flink-1.9.2-bin-scala_2.11.tgz

 

3、添加環境變量

$ vim /etc/profile export FLNK_HOME=/root/soft/flink-1.9.2 export PATH=$FLINK_HOME/bin:$PATH

 

4、啟動Flink

$ /root/soft/flink-1.9.2/bin $ ./start-cluster.sh $ jps 19489 jar 24595 StandaloneSessionClusterEntrypoint 25189 Jps 25039 TaskManagerRunner

 

可以通過觀察logs目錄下的日志來檢測系統是否正在運行了

$ tail log/flink-*-standalonesession-*.log

JobManager同時會在8081端口上啟動一個web前端，通過http://localhost:8081來訪問

可以發現flink已經正常啟動

5、運行示例——官方示例
使用Maven創建Flink項目，在pom.xml中添加以下依賴：

<dependencies>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-java</artifactId>
        <version>1.9.2</version>
    </dependency>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-streaming-java_2.11</artifactId>
        <version>1.9.2</version>
    </dependency>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-clients_2.11</artifactId>
        <version>1.9.2</version>
    </dependency>
</dependencies>

5.1、批處理運行WordCount
可以直接在/root/soft/flink-1.9.2/examples/batch中運行WordCount程序，並且這里還有更多示例：

$ cd /root/soft/flink-1.9.2/examples/batch $ /root/soft/flink-1.9.2/bin/flink run WordCount.jar