windows上的apache flink

roqulrg3  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(388)

首先,我对Flink完全是个新手。我已经在windows上安装了apache flink。我用start-cluster.bat启动flink。打印出来
使用一个jobmanager进程和一个taskmanager进程启动本地群集。您可以在派生的shell窗口中通过ctrl-c终止进程。默认打开web界面http://localhost:8081/.
不管怎样,当我提交这份工作时,我有一堆信息:
debug org.apache.flink.runtime.rest.restclient-收到的响应{“status”:{“id”:“in\u progress”}。
在web ui的日志中http://localhost:8081/,我明白了:
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需要的端口是否在使用中,但似乎不是这样。
有什么办法解决这个问题吗?

ql3eal8s

ql3eal8s1#

所以我在本地使用intelij和archtype运行flink,它提供了现成的示例
https://ci.apache.org/projects/flink/flink-docs-stable/dev/projectsetup/java_api_quickstart.html
除非在集群上使用flink作为服务,否则不必安装它。代码编辑器只需运行一次代码就可以将它编译成flink的spot示例。

相关问题