返回介绍

在 Windows 上运行 Flink

发布于 2025-05-02 18:19:12 字数 1832 浏览 0 评论 0 收藏 0

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

从 Windows 批处理文件开始

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

注意: bin Java Runtime Environment 的文件夹必须包含在 Window 的 %PATH% 变量中。按照本 指南 将 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 和 Unix Scripts 开始

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

$ cd flink
$ bin/start-cluster.sh
Starting cluster.

从 Git 安装 Flink

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

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

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

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

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

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。
列表为空,暂无数据
    我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。