在生产环境中，flink on yarn通常是以哪种方式运行？个人感觉小数据量batch任务使用session模式会增加任务运行速率同时节省资源。而对于batch大任务还是使用per-job或者Application mode会更好一些。而流式任务使用per-job或者Application mode会好一些。

老师：在第二章11 节| flink on yarn 老师你教学演示的客户端叫什么，集成等很不错

我部署的flink 11 on yarn，执行yarn-session.sh启动时 后面跟的-tm jm nm 等参数没生效

跟着老师的脚步走

per-job模式 一个作业好像也可以写多个execute吧 相当于提交多个作业job

老师，我在按照你的演示运行per job的时候，运行不成功，等了半天，然后看日志，错误是这样的 2021-10-26 18:20:49,650 ERROR org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor [] - Caught exception while executing runnable in main thread. java.lang.IllegalStateException: The RMClient's and YarnResourceManagers internal state about the number of pending container requests for resource <memory:2048, vCores:1> has diverged. Number client's pending container requests 1 != Number RM's pending container requests 0. 请问这是怎么回事，是一步一步根据你的步骤来的。

老师，您好。我想问一下，standalone 多机部署和on yarn session都有web端可以看到job运行情况，那么 per-job模式和application mode模式 有web端可以查看job运行情况吗？ 还有一个问题，on yarn session每次启动的对外web 地址都不一样，这个可以通过配置固定吗？

请教下老师： 我执行命令后得到的下列错误信息，网上检索未找到相关解决方案，还不知道问题出在哪了 ./bin/flink run ./examples/batch/WordCount.jar --input hdfs://nameservice1:8020/flink-training/frostroad.txt --output hdfs://nameservice1:8020/flink-training/wordcount-result.txt Caused by: org.apache.hadoop.ipc.RemoteException(org.apache.hadoop.yarn.exceptions.ApplicationNotFoundException): Application with id 'application_1615874066610_0060' doesn't exist in RM. Please check that the job submission was successful. at org.apache.hadoop.yarn.server.resourcemanager.ClientRMService.getApplicationReport(ClientRMService.java:370) at org.apache.hadoop.yarn.api.impl.pb.service.ApplicationClientProtocolPBServiceImpl.getApplicationReport(ApplicationClientProtocolPBServiceImpl.java:224) at org.apache.hadoop.yarn.proto.ApplicationClientProtocol$ApplicationClientProtocolService$2.callBlockingMethod(ApplicationClientProtocol.java:529) at org.apache.hadoop.ipc.ProtobufRpcEngine$Server$ProtoBufRpcInvoker.call(ProtobufRpcEngine.java:523) at org.apache.hadoop.ipc.RPC$Server.call(RPC.java:991) at org.apache.hadoop.ipc.Server$RpcCall.run(Server.java:870) at org.apache.hadoop.ipc.Server$RpcCall.run(Server.java:816) at java.security.AccessController.doPrivileged(Native Method) at javax.security.auth.Subject.doAs(Subject.java:422) at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1875) at org.apache.hadoop.ipc.Server$Handler.run(Server.java:2680) at org.apache.hadoop.ipc.Client.getRpcResponse(Client.java:1499) at org.apache.hadoop.ipc.Client.call(Client.java:1445) at org.apache.hadoop.ipc.Client.call(Client.java:1355) at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:228) at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:116) at com.sun.proxy.$Proxy31.getApplicationReport(Unknown Source) at

flink on yarn模式，对于CDH集群集成flink 有相关文档吗？

老师，每秒100万次的流量数据，使用基于yarn的flink集群应该如何设计，目前有的资源是8核32G机器，应该搭建几台