开发者社区> 问答> 正文

Flink 有支持类似MR一样支持opts参数的变量替换么?

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

*来自志愿者整理的flink邮件归档

展开
收起
游客nnqbtnagn7h6s 2021-12-06 20:44:31 1296 0
1 条回答
写回答
取消 提交回答
  • 支持配置 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

    *来自志愿者整理的flink邮件归档

    2021-12-06 21:57:46
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载