[jira] [Created] (FLINK-24529) flink sql job cannot use custom job name

["simenliuxing (Jira)" <ji...@apache.org>]

simenliuxing created FLINK-24529:
------------------------------------

             Summary: flink sql job cannot use custom job name
                 Key: FLINK-24529
                 URL: https://issues.apache.org/jira/browse/FLINK-24529
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / API
    Affects Versions: 1.14.0
            Reporter: simenliuxing
             Fix For: 1.14.1


In the 1.14.0 branch, I set the configuration of StreamTableEnvironment as follows:
{code:java}
Configuration configuration = tEnv.getConfig().getConfiguration();
configuration.setString(PipelineOptions.NAME, jobName);{code}
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：
{code:java}
String jobName = getJobName("insert-into_" + String.join(",",sinkIdentifierNames));
private String getJobName(String defaultJobName) { 
  return tableConfig.getConfiguration().getString(PipelineOptions.NAME,defaultJobName); 
} 
{code}
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.

 

 

 

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)