官網(wǎng)地址:https://ci.apache.org/projects/flink/flink-docs-release-1.7/tutorials/flink_on_windows.html
如果想在 Windows 機(jī)器本地運(yùn)行 Flink,首先需要下載 并解壓 Flink 的安裝包涌韩。然后可以用 Windows 批處理文件 (.bat
)或 Cygwin 來(lái)運(yùn)行 Flink JobManager序六。
通過(guò) Windows 批處理文件啟動(dòng)
從 Windows 命令行打開(kāi)命令窗口硼端,切換到 Flink 安裝包解壓后的 /bin
目錄下,然后運(yùn)行 start-cluster.bat
软能。
注意:Windows 必須已經(jīng)配置了 JRE 環(huán)境變量仆百。JRE 環(huán)境變量配置方法 參考此文。
$ cd flink
$ cd bin
$ start-cluster.bat
Starting a local cluster with one JobManager process and one TaskManager process.
You can terminate the processes via CTRL-C in the spawned shell windows.
Web interface by default on http://localhost:8081/.
然后企量,你需要再開(kāi)一個(gè)終端窗口通過(guò) flink.bat
運(yùn)行任務(wù)。
通過(guò)Cygwin 和 Unix 腳本啟動(dòng)
打開(kāi) Cygwin 終端并切換到 Flink 安裝包路徑下亡电,運(yùn)行腳本 start-cluster.sh
:
$ cd flink
$ bin/start-cluster.sh
Starting cluster.
通過(guò) Git 安裝 Flink
如果你要用 Windows Git shell 的方式從 Git 倉(cāng)庫(kù)安裝 Flink梁钾,Cygwin 會(huì)產(chǎn)生類似下面的這個(gè)錯(cuò)誤:
c:/flink/bin/start-cluster.sh: line 30: $'\r': command not found
錯(cuò)誤原因是在 Windows 中運(yùn)行時(shí),Git 會(huì)自動(dòng)將 UNIX 行結(jié)尾轉(zhuǎn)換為 Windows 樣式行結(jié)尾逊抡。問(wèn)題是 Cygwin 只能處理 UNIX 樣式的行結(jié)尾姆泻。解決方案是通過(guò)以下三個(gè)步驟調(diào)整 Cygwin 設(shè)置來(lái)處理正確的行結(jié)尾:
- 啟動(dòng)一個(gè) Cygwin shell;
- 確認(rèn)Cygwin 目錄冒嫡;
cd; pwd
這句命令會(huì)返回 Cygwin 的根目錄拇勃。
- 使用 NotePad,WordPad 或其他文本編輯器打開(kāi)主目錄中的
.bash_profile
c文件并在末尾加入以下內(nèi)容(如果文件不存在孝凌,就自己建一個(gè)):
export SHELLOPTS
set -o igncr
保存文件并打開(kāi)一個(gè)新的 bash shell方咆。