本地執行時設定
-
確保你有 java 6 或更高版本並且設定了
JAVA_HOME
環境變數。 -
在這裡下載最新的 flink 二進位制檔案 :
wget flink-XXXX.tar.gz
如果你不打算使用 Hadoop,請選擇 hadoop 1 版本。另外,請注意你下載的 scala 版本,以便在程式中新增正確的 maven 依賴項。
-
開始 flink:
tar xzvf flink-XXXX.tar.gz ./flink/bin/start-local.sh
Flink 已配置為在本地執行。要確保 flink 正在執行,你可以檢查
flink/log/
中的日誌或開啟在http://localhost:8081
上執行的 flink jobManager 的介面。 -
停止 flink:
./flink/bin/stop-local.sh