我按照第一步安装Flink。 我可以毫无问题地启动集群
$ start-cluster.sh
Starting cluster.
Starting standalonesession daemon on host DESKTOP-....
Starting taskexecutor daemon on host DESKTOP-....
但我没有从
获得任何状态$ ps aux | grep flink
我也无法通过 localhost:8081 访问仪表板。
有一个较旧的post存在这些问题,但该解决方案对我不起作用,因为显然所描述的conf文件不再存在。
我的JAVA_HOME设置为C:\Progra~1\Java\jdk1.8.0_311以避免Program Files中的空间问题。
这看起来还是有问题的。我尝试从 Windows Subsystem for Linux (WSL) 运行。
我有以下版本:java 11.0.16和flink 1.15.2。
sudo apt-get update
sudo apt install openjdk-11-jre-headless
export FLINK_HOME=/mnt/c/Projects/Apache/flink-1.15.2
我在flink-conf.yaml中设置了以下内容
rest.port: 8081
rest.address: localhost
rest.bind-address: 0.0.0.0
我将 localhost 的绑定地址更改为 0.0.0.0 这似乎已经解决了问题。
$FLINK_HOME/bin/start-cluster.sh
现在我可以访问 Flink Web 仪表板了。
您可以检查
/logs
文件夹中的日志吗?我怀疑由于那里的空间,C:\Program Files\
仍然可能会导致问题。
去下载 Flink 文件夹并尝试 bash 命令
$./bin/start-cluster.sh --daemon bootstrap-server localhost:8081
并再次运行代码
$ ./bin/flink run examples/streaming/WordCount.jar
如果您运行完上面的代码但没有问题,请转到 localhost:8081