如果您想在Windows机器上本地运行Flink,您需要download并解包二进制Flink发行版。之后,您可以使用Windows批处理文件(.bat
),或者使用Cygwin来运行Flink Jobmanager。
要从 Windows命令行启动 Flink,打开命令窗口,导航到Flink的bin/
目录并运行start-cluster.bat
。
注意:Java运行时环境的bin
文件夹必须包含在窗口的%PATH%
变量中。按照这个 guide将Java添加到%PATH%
变量中。
$ 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,您需要启动Cygwin终端,导航到Flink目录并运行start-cluster.sh
脚本:
$ cd flink
$ bin/start-cluster.sh
Starting cluster.
如果您正在从git存储库中安装Flink,并且正在使用Windows git shell, Cygwin可能会产生类似于下面这样的故障:
c:/flink/bin/start-cluster.sh: line 30: /figure>\r': command not found
发生此错误是因为git在Windows中运行时自动将UNIX行结束符转换为Windows样式的行结束符。问题是Cygwin只能处理UNIX样式的行尾。解决方案是调整Cygwin设置来处理正确的行尾,方法如下三个步骤:
cd; pwd
这将返回Cygwin根路径下的路径。
.bash_profile
。在主目录中添加并附加以下内容:(如果文件不存在,则必须创建它)export SHELLOPTS
set -o igncr
保存文件并打开一个新的bash shell。
转自https://github.com/apachecn/flink-doc-zh/
内容来源于网络,如有侵权,请联系作者删除!