【发布时间】: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