无法部署 flink 应用程序
Can't deploy flink application
我正在使用 Hortonworks 2.4.0。
我开始 yarn-session ./bin/yarn-session.sh -n 1 -jm 768 -tm 768
那我要部署./bin/flink 运行 -m yarn-cluster -yn 1 -yjm 768 -ytm 768 ./examples/batch/WordCount.jar
当我部署我的应用程序时,我 运行 进入了一个无限循环。日志消息为:INFO org.apache.flink.yarn.FlinkYarnClient - 部署时间超过 60 秒。请检查请求的资源在YARN集群中是否可用
我已经将 n 1 -jm 768 -tm 的参数调整为各种值。包括以下推荐的那些:https://ci.apache.org/projects/flink/flink-docs-release-1.0/setup/yarn_setup.html
没有解决问题。
使用 ./bin/yarn-session.sh -n 1 -jm 768 -tm 768
命令,您将开始一个较长的 运行 YARN 会话。
然后您可以使用 ./bin/flink 客户端(不传递 -m yarn-cluster 参数)向会话提交作业
如果您想使用 Flink 将单个作业提交到 YARN,./bin/flink run -m yarn-cluster -yn 1 -yjm 768 -ytm 768
是提交作业的正确方法。
我正在使用 Hortonworks 2.4.0。
我开始 yarn-session ./bin/yarn-session.sh -n 1 -jm 768 -tm 768
那我要部署./bin/flink 运行 -m yarn-cluster -yn 1 -yjm 768 -ytm 768 ./examples/batch/WordCount.jar
当我部署我的应用程序时,我 运行 进入了一个无限循环。日志消息为:INFO org.apache.flink.yarn.FlinkYarnClient - 部署时间超过 60 秒。请检查请求的资源在YARN集群中是否可用
我已经将 n 1 -jm 768 -tm 的参数调整为各种值。包括以下推荐的那些:https://ci.apache.org/projects/flink/flink-docs-release-1.0/setup/yarn_setup.html 没有解决问题。
使用 ./bin/yarn-session.sh -n 1 -jm 768 -tm 768
命令,您将开始一个较长的 运行 YARN 会话。
然后您可以使用 ./bin/flink 客户端(不传递 -m yarn-cluster 参数)向会话提交作业
如果您想使用 Flink 将单个作业提交到 YARN,./bin/flink run -m yarn-cluster -yn 1 -yjm 768 -ytm 768
是提交作业的正确方法。