Flink 1.5.X 初體驗之殤

來自專欄神奇的軟體技術

前言

最近正好想要研究一下實時日誌流分析。調研來調研去，覺得Flink還不錯，就想拿來玩玩。

結果碰到坑爹的問題，Flink的Web UI Dashboard默認是在8081埠上的，但是由於本人的電腦8081埠被McAfee（邁克菲）霸佔了，不得已要換埠啟動Flink集群，折騰了許久才搞定，為此特意記錄一下。

環境

Mac OSX 10.12.6

Java HotSpot 1.8.0_131

安裝

$ brew update # 最好先更新一下軟體源$ brew install apache-flink$ flink --versionVersion: 1.5.1, Commit ID: 3488f8b$ brew info apache-flinkapache-flink: stable 1.5.1, HEADScalable batch and stream data processinghttps://flink.apache.org//usr/local/Cellar/apache-flink/1.5.1 (130 files, 323.5MB) * # Flink安裝位置 Built from source on 2018-08-05 at 16:11:06From: https://github.com/Homebrew/homebrew-core/blob/master/Formula/apache-flink.rb==> RequirementsRequired: java = 1.8 ?==> Options--HEAD Install HEAD version

啟動

由於要在不同的埠啟動，所以要把啟動腳本./bin/start-cluster.sh改一下才可以（這個腳本沒有執行參數，不得已才該腳本）

bin/start-cluster.sh

else echo "Starting cluster." # Start single JobManager on this machine "$FLINK_BIN_DIR"/jobmanager.sh start localhost 9999 # 選擇在localhost 9999上啟動fi

另外還要把配置文件改一下才可以，

conf/flink-conf.yaml

# The port under which the web-based runtime monitor listens.# A value of -1 deactivates the web server.rest.port: 9999

conf/masters

localhost:9999

接下來按著教程走就可以了，只不過web ui是啟動在http://localhost:9999上面

最後，還有個暴力辦法，grep一下8081的字眼，然後全部替換就好了

Good Luck！

參考

Apache Flink 1.5 Documentation: Quickstart?

ci.apache.org
推薦閱讀：