我第一次尝试在学校项目中使用apache flink,但安装后遇到了一些问题。我试着跟踪网站上的快速设置,但我总是遇到同样的问题(https://ci.apache.org/projects/flink/flink-docs-stable/quickstart/setup_quickstart.html)
控制台输出
brew的安装似乎运行良好,但这是我遇到的第一个不一致的地方。接下来向导告诉我执行以下命令
$./bin/start-cluster.sh#启动flink
如果不在这里安装一个二进制文件的话,这是行不通的https://flink.apache.org/downloads.html
所以我就这样做了(我用hadoop2.7二进制文件下载了flink1.6.2),然后就可以找到文件并执行它了。完成这项工作后,我应该进入web前端,并验证任务是否正在运行。然而,当我去那里什么都没有显示。控制台输出Web dashbord
我开始执行stop cluster文件,因为出于某种原因,我不断地得到info消息
[信息]moritzs-mbp.fritz.box上已运行1个standalonesession示例。
到目前为止,我已经尝试查看flink-conf.yaml文件,该文件将numberoftaskslots设置为1,因此问题似乎并不存在。否则,我真的不知道从那里看,但只是试图卸载和重新安装的一切没有结果。
抱歉,图片没有显示,以前我已经能够解决我所有的代码问题与现有的职位,因此我不能直接张贴他们尚未。任何帮助都将不胜感激,提前谢谢,
莫里茨
2条答案
按热度按时间fslejnso1#
我不知道为什么start-cluster.sh不能成功地启动taskmanager,但是您可以用它手动(尝试)启动另一个taskmanager
2wnc66cl2#
通过使用brew安装,start-cluster.sh应该可以在:/usr/local/cellar/apache flink/1.6.2/libexec/bin中找到