Windows上的Apache Flink

Question

首先，我是Flink的一个完全的新手。我已经在Windows上安装了Apache。我开始用开始-集群。蝙蝠。印出来

使用一个JobManager进程和一个TaskManager进程启动本地集群。您可以通过生成的shell窗口中的CTRL终止进程。默认情况下，在http://localhost:8081/上使用Web接口。

不管怎么说，当我提交这份工作的时候，我有一堆信息：

调试org.apache.flink.runtime.rest.RestClient -接收到的响应{“状态”：{“id”：“IN_PROGRESS”}}。

在http://localhost:8081/的web日志中，我看到：

2019年-02-15 16:04:23.571 flink-akka.actor.Default-4警告akka.remote.ReliableDeliverySupervisor flink-akka.remote.default- remote -dispatcher-6 -关联远程系统akka.tcp://flink@127.0.0.1:56404已失败，地址现在关闭50 ms。原因:不相关

如果我转到选项卡，它是空的。

我试图找出flink所需的端口是否在使用中，但情况似乎并非如此。

有办法解决这个问题吗？

Answer 1

因此，我在本地运行Flink，使用Intelij使用ArchType，这为您准备了示例

quickstart.html

除非您使用Flink作为集群上的服务，否则您不必安装它。对于一个代码运行的Flink实例，代码编辑器将非常好地编译它。