Hi Si-li,
Just a reminder that it is not the right way to get JobId because the
`StreamTask` is actually an internal class. For more discussion about
it, please refer to [1] and [2]. You could get JobId through this way
at the moment. Please keep in mind that it is not a stable contract.
[1]
I figure out another way, wrapper my function in a custom StreamOperator
that extends AbstractUdfStreamOperator, then I can use
this.getContainingTask.getEnvironment.getJobId
Congxian Qiu 于2020年7月21日周二 上午11:49写道：
> Hi Sili
>
> I'm not sure if there are other ways to get this value properly.
Hi Sili
I'm not sure if there are other ways to get this value properly. Maybe
you can try
`RuntimeContext.getMetricGroup().getAllVariables().get("")`.
Best,
Congxian
Si-li Liu 于2020年7月20日周一 下午7:38写道：
> Hi
>
> I want to retrieve flink JobId in runtime, for example, during
>
Hi
I want to retrieve flink JobId in runtime, for example, during
RichFunction's open method. Is there anyway to do it?
I checked the methods in RuntimeContext and ExecutionConfig, seems I can't
get this information from them.
Thanks!
--
Best regards
Sili Liu
