Windowsマシーン上でFlinkをローカルで実行したい場合は、バイナリのFlink配布物をダウンロードし解凍する必要があります。その後で、Flinkジョブマネージャーを実行するために、Windows Batch ファイル (.bat
)、あるいは Cygwin を使うことができます。
Windows バッチからローカルモードのFlinkを開始するには、コマンドウィンドウを開き、Flinkのbin/
ディレクトリに行き、start-local.bat
を実行します。
注意: Javaランタイム環境のbin
フォルダが Windowの %PATH%
変数に含まれていなければなりません。Javaを%PATH%
変数に追加するには、このガイド に従ってください。
$ cd flink
$ cd bin
$ start-local.bat
Starting Flink job manager. デフォルトでは、http://localhost:8081/ 上にWebインタフェースがあります。
このバッチウィンドウを閉じないでください。Ctrl+Cを押すことでジョブマネージャーが停止します。
その後で、flink.bat
を使ってジョブを実行するために2つ目のターミナルを開く必要があります。
Cygwinを使ってCygwinターミナルを開始し、Flinkディレクトリに移動し、start-local.sh
スクリプトを実行する必要があります:
$ cd flink
$ bin/start-local.sh
Starting jobmanager.
gitリポジトリからFlinkをインストールし、Windowsのgitシェルを使っている場合は、Cygwinは以下のような失敗を生成するかも知れません:
c:/flink/bin/start-local.sh: line 30: $'\r': command not found
このエラーは、gitはWindows上で実行する時にUNIXの行の終了が自動的にWindows形式の行の終了に変換されるために起こります。問題は、CygwinはUNIX形式の行の終了のみ取り扱うことができるという事です。解決方法は、以下の3つのステップに従うことで正しい行末を扱うようにCygwinの設定を調整することです。
Cygwinシェルを開始します。
以下を入力することでホームディレクトリを決定します
~~~bash cd; pwd ~~~
これはCygwinルートパスの下のパスを返すでしょう。
NotePad、WordPadあるいは異なるテキストエディタを使って、ホームディレクトリ内のファイル.bash_profile
を開き、以下を追加します: (ファイルが存在しない場合はそれを作成する必要があるでしょう)
export SHELLOPTS
set -o igncr
ファイルを保存し、新しいbashシェルを開きます。