[译] Windows 本地运行 Flink

2019-01-04  本文已影响99人  翼徳

官网地址: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 设置来处理正确的行结尾:

  1. 启动一个 Cygwin shell;
  2. 确认Cygwin 目录;
cd; pwd

这句命令会返回 Cygwin 的根目录。

  1. 使用 NotePad,WordPad 或其他文本编辑器打开主目录中的 .bash_profilec文件并在末尾加入以下内容(如果文件不存在,就自己建一个):
export SHELLOPTS
set -o igncr

保存文件并打开一个新的 bash shell。

上一篇 下一篇

猜你喜欢

热点阅读