我的困惑:
1.上图中JVM heap 中的 Maximum 我设置了3400,但是没有其作用,在哪里能修改这个Maximum呢?
2.flink on yarn 运行的时候,在对应的服务器上,是看不到程序运行的进程的,只能看到YarnApplicationMasterRunner进程和日志相关的进程,无法使用jstat或者jmap等分析jvm中的信息,从而定位代码中需要优化的部分,请问这种情况下,应该如何分析呢?或者先通过flink 单机或集群的方式调试优化好之后,再放到yarn去运行。有处理过相关情况的朋友,还请不吝赐教!谢谢
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
问题1:
看你的启动命令应该是要 Run a Flink job on YARN(https://ci.apache.org/projects/flink/flink-docs-release-1.6/ops/deployment/yarn_setup.html#run-a-flink-job-on-yarn),通过 -ytm就可以了,另外如果是通过-yD,对应的参数是 taskmanager.heap.size (https://ci.apache.org/projects/flink/flink-docs-release-1.6/ops/config.html#taskmanager-heap-size-1),最后那里是size不是mb
问题2:
可以按以下流程试一下
1 找到想要查询的JM或TM的container id以及所在机器
2 登录到机器上执行 ps -lef | grep java | grep container_id
3 其中的java进程一般就是所要找的进程