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)
