hi Evan, 感谢反馈，目前已经有一个issue [1]在跟踪该问题，可以关注后续进展
[1] https://issues.apache.org/jira/browse/FLINK-18545 <https://issues.apache.org/jira/browse/FLINK-18545?jql=project%20%3D%20FLINK%20AND%20resolution%20%3D%20Unresolved%20AND%20text%20~%20%22job%20name%22%20ORDER%20BY%20priority%20DESC%2C%20updated%20DESC> Best, Godfrey Jeff Zhang <[email protected]> 于2020年7月18日周六 下午9:52写道： > 在zeppelin中你可以指定insert 语句的job name，如下图，（对Zeppelin感兴趣的，可以加入钉钉群：32803524） > > %flink.ssql(jobName="my job") > > insert into sink_kafka select status, direction, cast(event_ts/1000000000 > as timestamp(3)) from source_kafka where status <> 'foo' > > [image: image.png] > > Evan <[email protected]> 于2020年7月18日周六 下午5:47写道： > >> 代码大概是这样子的，一张kafka source表，一张es Sink表，最后通过tableEnv.executeSql("insert into >> esSinkTable select ... from kafkaSourceTable")执行 >> 任务提交后任务名称为“inset-into_某某catalog_某某database.某某Table” >> >> >> 这样很不友好啊，能不能我自己指定任务名称呢？ > > > > -- > Best Regards > > Jeff Zhang >
