官网地址:https://ci.apache.org/projects/flink/flink-docs-release-1.7/tutorials/flink_on_windows.html
如果想在 Windows 机器本地运行 Flink,首先需要下载 并解压 Flink 的安装包。然后可以用 Windows 批处理文件 (.bat
)或 Cygwin 来运行 Flink JobManager。
通过 Windows 批处理文件启动
从 Windows 命令行打开命令窗口,切换到 Flink 安装包解压后的 /bin
目录下,然后运行 start-cluster.bat
。
注意:Windows 必须已经配置了 JRE 环境变量。JRE 环境变量配置方法 参考此文。
$ 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/.
然后,你需要再开一个终端窗口通过 flink.bat
运行任务。
通过Cygwin 和 Unix 脚本启动
打开 Cygwin 终端并切换到 Flink 安装包路径下,运行脚本 start-cluster.sh
:
$ cd flink
$ bin/start-cluster.sh
Starting cluster.
通过 Git 安装 Flink
如果你要用 Windows Git shell 的方式从 Git 仓库安装 Flink,Cygwin 会产生类似下面的这个错误:
c:/flink/bin/start-cluster.sh: line 30: $'\r': command not found
错误原因是在 Windows 中运行时,Git 会自动将 UNIX 行结尾转换为 Windows 样式行结尾。问题是 Cygwin 只能处理 UNIX 样式的行结尾。解决方案是通过以下三个步骤调整 Cygwin 设置来处理正确的行结尾:
- 启动一个 Cygwin shell;
- 确认Cygwin 目录;
cd; pwd
这句命令会返回 Cygwin 的根目录。
- 使用 NotePad,WordPad 或其他文本编辑器打开主目录中的
.bash_profile
c文件并在末尾加入以下内容(如果文件不存在,就自己建一个):
export SHELLOPTS
set -o igncr
保存文件并打开一个新的 bash shell。