【问题标题】:Apache Flink on WindowsWindows 上的 Apache Flink
【发布时间】:2019-02-15 15:17:26
【问题描述】:

首先,我是 Flink 的新手。我已经在 Windows 上安装了 Apache Flink。 我用 start-cluster.bat 启动 Flink。打印出来

使用一个 JobManager 进程和一个启动本地集群 任务管理器进程。您可以通过 CTRL-C 在 生成的外壳窗口。网页界面默认开启 http://localhost:8081/.

无论如何,当我提交作业时,我有一堆消息:

调试 org.apache.flink.runtime.rest.RestClient - 收到响应 {"status":{"id":"IN_PROGRESS"}}。

http://localhost:8081/ 的 Web UI 日志中,我看到了:

2019-02-15 16:04:23.571 [flink-akka.actor.default-dispatcher-4] 警告 akka.remote.ReliableDeliverySupervisor flink-akka.remote.default-remote-dispatcher-6 - 关联 远程系统 [akka.tcp://flink@127.0.0.1:56404] 失败,地址 现在门控 [50] 毫秒。原因:[解除关联]

如果我转到任务管理器选项卡,它是空的。

我试图查找 flink 需要的任何端口是否正在使用,但似乎没有。

有办法解决这个问题吗?

【问题讨论】:

  • 使用 bash shell 和 flink 自带的 bash 脚本在 windows 上会有更好的体验。

标签: windows apache-flink


【解决方案1】:

所以我使用 Intelij 在本地运行 Flink 使用 ArchType 为您提供准备好的示例

https://ci.apache.org/projects/flink/flink-docs-stable/dev/projectsetup/java_api_quickstart.html

除非您在集群上使用 Flink 作为服务,否则您不必安装它。 代码编辑器会为 Flink 的 Spot 实例编译一次代码运行。

【讨论】:

猜你喜欢
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2020-05-03
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2016-11-13
相关资源
最近更新 更多