[
https://issues.apache.org/jira/browse/FLINK-21476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17289730#comment-17289730
]
jjiey commented on FLINK-21476:
-------------------------------
It's a duplicate issues, you can specify in this way:
val tabConf = tableEnv.getConfig
onf.setString("pipeline.name", Common.jobName)
refer to: [FLINK-18545|https://issues.apache.org/jira/browse/FLINK-18545]
> How to appoint jobname
> -----------------------
>
> Key: FLINK-21476
> URL: https://issues.apache.org/jira/browse/FLINK-21476
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / API
> Affects Versions: 1.12.0
> Environment: java 1.8
> flink 1.12.0
> Reporter: ranqiqiang
> Priority: Minor
>
> when I use：
> {code:java}
> //代码占位符
> Env.executeSql(sourceTableSql);
> Env.executeSql(printTableSql);
> Env.executeSql(insertTableSql);
> // This will throw exception,and unuseful
> // bsEnv.execute("test"){code}
>
>
> then,job-name not place to apppointed ?
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
