[FLINK-24529] flink sql job cannot use custom job name

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Not A Problem
• Affects Version/s: 1.14.0
• Fix Version/s: 1.14.3
• Component/s: Table SQL / API
• Assignee: Unassigned
• Reporter: simenliuxing
• Created: 13/Oct/21 03:21
• Updated: 15/Dec/21 01:44
• Resolved: 14/Oct/21 01:34

Description

In the 1.14.0 branch, I set the configuration of StreamTableEnvironment as follows:

Configuration configuration = tEnv.getConfig().getConfiguration();
configuration.setString(PipelineOptions.NAME, jobName);

It is not displayed on flink dashboard but the default insert-into_xxx name,But it is displayed normally in the 1.13.2 branch

I found that the jobname is set in line 756 of the class TableEnvironmentImpl in the source code of 1.13.2：

String jobName = getJobName("insert-into_" + String.join(",",sinkIdentifierNames));

private String getJobName(String defaultJobName) { 
  return tableConfig.getConfiguration().getString(PipelineOptions.NAME,defaultJobName); 
} 

But in the 1.14.0 branch, there is no getJobName method. Is there any other setting way here? Or the method should be added.