在Windows上运行Flink

如果要在Windows计算机上本地运行Flink，则需要下载并解压缩二进制Flink分发。之后，您可以使用Windows批处理文件（.bat），或使用Cygwin运行FlinkJobManager。

从Windows批处理文件开始

要从Windows命令行启动Flink ，请打开命令窗口，导航到bin/Flink目录并运行start-cluster.bat。

注意：binJava Runtime Environment 的文件夹必须包含在Window的%PATH%变量中。按照本指南将Java添加到%PATH%变量中。

  1. $ cd flink
  2. $ cd bin
  3. $ start-cluster.bat
  4. Starting a local cluster with one JobManager process and one TaskManager process.
  5. You can terminate the processes via CTRL-C in the spawned shell windows.
  6. Web interface by default on http://localhost:8081/.

之后，您需要打开第二个终端来运行作业flink.bat。

从Cygwin和Unix Scripts开始

使用Cygwin，您需要启动Cygwin终端，导航到您的Flink目录并运行start-cluster.sh脚本：

  1. $ cd flink
  2. $ bin/start-cluster.sh
  3. Starting cluster.

从Git安装Flink

如果您正在从git存储库安装Flink并且您正在使用Windowsgit shell，则Cygwin可能会产生类似于以下的故障：

  1. c:/flink/bin/start-cluster.sh: line 30: $'\r': command not found

发生此错误是因为在Windows中运行时，git会自动将UNIX行结尾转换为Windows样式行结尾。问题是Cygwin只能处理UNIX样式的行结尾。解决方案是通过以下三个步骤调整Cygwin设置以处理正确的行结尾：

  • 启动一个Cygwinshell。

  • 输入确定您的主目录

  1.     cd; pwd
  2.     
  1. This will return a path under the Cygwin root path.
  • 使用NotePad，写字板或其他文本编辑器打开.bash_profile主目录中的文件并附加以下内容:(如果文件不存在，则必须创建它）
  1. export SHELLOPTS
  2. set -o igncr

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