java - 由于无法找到或加载主类错误，Flink 集群未启动

Question

我正在尝试设置 flink 并运行集群，尽管我得到以下输出，看起来集群已启动:

$ ./bin/start-cluster.sh
Starting cluster.
Starting standalonesession daemon on host LAPTOP-HRAHBL24.
Starting taskexecutor daemon on host LAPTOP-HRAHBL24.

当我转到 localhost:8081 时，连接被拒绝，因此我检查了 flink 日志，并在任务执行器日志中看到以下错误:

Error: Could not find or load main class org.apache.flink.runtime.taskexecutor.TaskManagerRunner

在独立日志中我得到这个:

Error: Could not find or load main class org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint

我一直在互联网上搜索，但没有找到任何东西。我的 java env 和系统变量是正确的，因为我可以看到 java -version 和 javac -version 的输出。我使用的是 java 8，特别是 jdk1.8.0_251。我用 Flink 1.10.1 和 1.5.0 尝试了上述方法，都给了我同样的错误。知道如何解决这个问题吗？

Answer 1

我遇到了同样的问题，但现在我可以启动集群并看到 localhost:8081 UI。

在 Windows 10 操作系统上运行集群 - Apache Flink 1.11.2 for Scala 2.11

这是我采取的步骤:

1. 激活Windows 版 WSL:https://www.thewindowsclub.com/how-to-run-sh-or-shell-script-file-in-windows-10 (第 1 部分使用 WSL 执行 Shell 脚本文件)
2. 让 Ubuntu for win 10 运行 Linux 命令(运行 .sh 文件)，这可以通过进入 Microsoft Store 并下载首选的 Linux 发行版来实现。 (或者在 Windows 中打开 PowerShell，输入 bash 以获得简单信息)
3. 在 Ubuntu 上安装 OpenJDK，如下所示: https://askubuntu.com/questions/746413/trying-to-install-java-8-unable-to-locate-package-openjdk-8-jre (首先打开Linux shell，然后按照说明进行操作)

<小时/>

完成这些步骤后，您应该能够在 Apache Flink 1.11.2 文件夹中打开 Linux Shell 并运行 ./bin/start-cluster.sh ，没有任何问题。