目錄

• Ubuntu下flink的安裝
  • 安裝
  • 運行Demo

Ubuntu下flink的安裝

PreRequest: Java

安裝

1. 下載軟件包：

wget https://mirror.bit.edu.cn/apache/flink/flink-1.10.0/flink-1.10.0-src.tgz

2. 解壓軟件包

tar xzf flin-*.tgz
cd flink-1.10.0

3. 啟動 flink

./bin/start-cluster.sh

驗證：打開頁面 localhost:8081

或 查看日志

tail log/flink-*-standlonession-*.log

運行Demo

1. 使用 netcat

nc -l 9000

2. 提交Flink程序

./bin/flink run examples/streaming/SocketWordCount.jar --port 9000

測試

nc -l 9000
hello world flink
flink is the best
hello again

查看輸出：

tail -f log/flink-*-taskexecutor-*out
world 1
flink 2
is 1
the 1
best 1
hello 2
again 1

3. 關閉cluster

./bin/stop-cluster.sh

參考鏈接：官網教程