Re: Fwd: Is it possible to get Flink job name in an operator?

2019-10-16 Thread Chesnay Schepler
If you have control over the job you can modify it to use 
ExEnv#execute(String jobName), and üass this explicitly to your 
functions in some form (like the global job parameters).


Beyond that there is no way to access the job name from within a 
function/operator.


On 15/10/2019 08:53, 马阳阳 wrote:
As the title. Is it possible now? Or if we can do something to achieve 
this. I tried to put the job name into the 
ExecutionConfig.GlobalJobParameters. But it is not possible to get the 
job name before Environment.execute() is called.


Best regards,
mayangyang





Fwd: Is it possible to get Flink job name in an operator?

2019-10-15 Thread 马阳阳
As the title. Is it possible now? Or if we can do something to achieve 
this. I tried to put the job name into the 
ExecutionConfig.GlobalJobParameters. But it is not possible to get the 
job name before Environment.execute() is called.


Best regards,
mayangyang