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
|
- Naming sql_statment job lan tran
-