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 <qcx978132...@gmail.com> 于2020年7月21日周二 上午11:49写道：
> Hi Sili
>
> I'm not sure if there are other ways to get this value properly. Maybe
> you can try
> `RuntimeContext.getMetricGroup().getAllVariables().get("<job_id>")`.
>
> Best,
> Congxian
>
>
> Si-li Liu <unix...@gmail.com> 于2020年7月20日周一 下午7:38写道：
>
>> 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
>>
>
--
Best regards
Sili Liu
