当前位置: 首页 > 知识库问答 >
问题:

Windows上的Apache Flink

郭弘盛
2023-03-14

首先,我是Flink的新手。我已经在Windows上安装了Apache Flink。我开始使用Flinkstart-cluster.bat.它打印出来

使用一个JobManager进程和一个TaskManager进程启动本地群集。您可以在派生的shell窗口中通过CTRL-C终止进程。Web界面默认打开http://localhost:8081/.

无论如何,当我提交这份工作时,我有一大堆信息:

调试组织。阿帕奇。Flink。运行时。RestRestClient-收到响应{“status”:{“id”:“IN\u PROGRESS”}}。

web UI的日志中http://localhost:8081/,我明白了:

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

如果转到“任务管理器”选项卡,则该选项卡为空。

我试图找出Flink需要的任何港口是否在使用中,但事实似乎并非如此。

有办法解决这个问题吗?

共有1个答案

缪朝
2023-03-14

所以我在本地使用Intelij运行Flink,使用ArchType提供现成的示例

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

除非您在集群上使用Flink作为服务,否则无需安装它。对于Flink的spot实例,代码编辑器只需运行一次代码即可对其进行编译。

 类似资料:
  • 到目前为止,我已经尝试了三天,想知道如何在windows上安装和使用gRPC,但运气不好。我使用的是Visual Studio 2015,Win7 64位。为了安全起见,我会一步一步地写下我正在做的事情。这可能没有必要,但我是C和VS的初学者,所以我根本不确定我做得是否正确: (以下指南http://www.infopulse.com/blog/grpc-framework-by-google-t

  • 问题内容: 我正在尝试学习python,正在制作一个将输出脚本的程序。我想使用os.path.join,但是很困惑。根据文档,如果我说: 我懂了。根据文档,这是正常的,对吗? 但是,当我使用copytree命令时,Python将以所需的方式输出它,例如: 这是我得到的错误代码: 如果我用换行,则会得到相同的错误。 如果不能以这种方式使用它,那么我对其目的感到困惑。 根据Stack Overflow

  • 1.2. Windows 上的 Python 在 Windows 上, 安装 Python 有两种选择。 ActiveState 制作了一个 Windows 上的 Python 安装程序称为 ActivePython, 它包含了一个完整的 Python 发布; 一个适用于 Python 编程的 IDE 附加了一些 Python 的 Windows 扩展, 提供了全部的访问 Windows APIs

  • 问题内容: 我已经下载了最新的com4j jars,并且试图通过它们中最简单的示例进行分析。 我使用的是Windows 7 64位,并使用64位JVM。 当我运行命令时(来自com4j教程): 我得到: Java代码在jar旁边提取“ com4j-amd64.dll”。 问题答案: 最新版本刚刚发布: http://kohsuke.org/2012/04/27/com4j-updates/ htt

  • 问题内容: 与* nix机器相比,Windows上的Python通常会慢吗?Python似乎在Mac OS X机器上火起来,而在Window的Vista机器上 似乎 运行慢。这些机器的处理能力相似,而Vista机器则具有1GB以上的内存。 我在Mercurial中特别注意到了这一点,但我认为这可能只是Mercurial在Windows上打包的方式。 问题答案: 我想对此进行跟进,发现了一些我认为是

  • 问题内容: 如何在Windows上正确安装virtualenv? 我从这里下载virtualenv1.9.1并尝试使用以下命令安装它: 但它没有出现在MyPythonPath / Scripts中 我尝试以相同的方式安装virutalenvwrapper- win 并正确安装。但是我不能使用它,因为我没有virtualenv python.exe:无法打开文件“ MyPythonPath \ Sc