hi shangwen, flink
支持配置 env.java.opts,env.java.opts.jobmanager,env.java.opts.taskmanager
等来配置JVM
详细请见:
https://ci.apache.org/projects/flink/flink-docs-stable/ops/config.html#jvm-and-logging-options

Best,
Godfrey


shangwen <583767...@qq.com> 于2020年6月2日周二 下午9:03写道:

> 现在一个场景是我们假设Flink的TM出现了OOM,并希望收集Dump文件,配置HeapDumpOnOutOfMemoryError,让Flink出现oom时将文件dump出来,对于MR来说,我们可以这么配置mapreduce.map.java.opts为-XX:+HeapDumpOnOutOfMemoryError
> -XX:HeapDumpPath=<LOG_DIR&gt;/@taskid@.hprof,通过@taskid@在启动的时候替换的方式
> ,让收集的文件可以区分,目前对于Flink来说,有较好的方式能够做到这一点吗?

回复