首先,我是一个完整的新手。我已经在窗户上安装了Apache Flink。我从start-cluster.bat开始flink。它打印出
使用一个Jobmanager流程开始本地群集和一个 TaskManager进程。您可以通过CTRL-C终止该过程 产卵的外壳窗户。默认情况下Web界面 http://localhost:8081/。
无论如何,当我提交工作时,我有很多消息:
debug org.apache.flink.runtime.rest.restclient-接收回复 {"状态":{" id":" in_progress"}}。
在http://localhost的Web UI中的日志中:8081/,我看到:
2019-02-15 16:04:23.571 [FLINK-AKKA.ACTOR.DEFAULT-DISPATCHER-4]警告 akka.remote.reliabledeliverysuperypervisor flink-akka.remote.default-remote-dispatcher-6与与 远程系统[akka.tcp://flink@127.0.0.1:56404]失败了,地址 现在是[50] MS的门控。原因:[分离]
如果我转到"任务管理器"选项卡,它是空的。
我试图找到使用Flink所需的任何端口,但似乎并非如此。
解决这个问题的想法?
,所以我使用intelij在本地运行flink使用ArchType可以让您准备去示例
https://ci.apache.org/projects/flink/flink/flink-docs-stable/dev/projectsetup/java_api_quickstart.html
除非您将Flink用作群集上的服务,否则不必安装它。代码编辑器将对运行一个代码的Flink的点斑点实例进行编译。