回复:flink-metrics如何获取applicationid

2023-08-30 文章 allanqinjy
多谢了,明天改一下代码试试 回复的原邮件 | 发件人 | Feng Jin | | 发送日期 | 2023年08月30日 19:42 | | 收件人 | user-zh | | 主题 | Re: flink-metrics如何获取applicationid | hi, 可以尝试获取下 _APP_ID 这个 JVM 环境变量. System.getenv(YarnConfigKeys.ENV_APP_ID);

回复:flink-metrics如何获取applicationid

2023-08-30 文章 allanqinjy
多谢,明天修改一下代码试试 回复的原邮件 | 发件人 | Feng Jin | | 发送日期 | 2023年08月30日 19:42 | | 收件人 | user-zh | | 主题 | Re: flink-metrics如何获取applicationid | hi, 可以尝试获取下 _APP_ID 这个 JVM 环境变量. System.getenv(YarnConfigKeys.ENV_APP_ID);

Re: flink-metrics如何获取applicationid

2023-08-30 文章 Feng Jin
hi, 可以尝试获取下 _APP_ID 这个 JVM 环境变量. System.getenv(YarnConfigKeys.ENV_APP_ID); https://github.com/apache/flink/blob/6c9bb3716a3a92f3b5326558c6238432c669556d/flink-yarn/src/main/java/org/apache/flink/yarn/YarnConfigKeys.java#L28 Best, Feng On Wed, Aug 30, 2023 at 7:14 PM allanqinjy wrote: > hi,

flink-metrics如何获取applicationid

2023-08-30 文章 allanqinjy
hi, 请教大家一个问题,就是在上报指标到prometheus时候,jobname会随机生成一个后缀,看源码也是new Abstract ID(),有方法在这里获取本次上报的作业applicationid吗?

Re:Re: Re: K8s Appliaction模式无法支持flinkjar中Java动态编译?

2023-08-30 文章 周坤
是的我的任务的jar包里包含动态编译所有依赖的, 任务的jar是通过 k8s Apllication模式 userJar 方式进行动态加载的; 在 2023-08-30 12:14:18,"孙路昊" 写道: >依赖的jar包,有编译到启动jar包里面吗 > >周坤 <18679131...@163.com>于2023年8月30日 周三11:15写道: > >> >> 你好!在K8s模式中,动态编译缺失运行在UserJar中,启动的时候通过RIch算子的Open方法从第三方拉取原始class文件,然后进行动态编译进行缓存内存中, >> 按照YARN

退订

2023-08-30 文章 喻凯