Hi team,

When I was using Table API to submit the SQL job using execute_query(), the name is created by Flink. However, I wonder there is a way to config that name.

I see that in the SQL-Client they have this statement
SET 'pipeline.name' = '{job_name}'. Wonder that if it can execute this using execute_query (throw exception), sql_query (throw exception) or something else ?

 

Thank team.
Best,
Quynh

 

Sent from Mail for Windows

 

Reply via email to