谢谢两位，我尝试一下。
也希望 flink sql client 本身支持这样的模式。
--
Sent from: http://apache-flink.147419.n8.nabble.com/
hi Evan,
感谢反馈，目前已经有一个issue [1]在跟踪该问题，可以关注后续进展
[1] https://issues.apache.org/jira/browse/FLINK-18545
在zeppelin中你可以指定insert 语句的job name，如下图，（对Zeppelin感兴趣的，可以加入钉钉群：32803524）
%flink.ssql(jobName="my job")
insert into sink_kafka select status, direction, cast(event_ts/10
as timestamp(3)) from source_kafka where status <> 'foo'
[image: image.png]
Evan 于2020年7月18日周六 下午5:47写道：
>
代码大概是这样子的，一张kafka source表，一张es Sink表，最后通过tableEnv.executeSql("insert into
esSinkTable select ... from kafkaSourceTable")执行
任务提交后任务名称为“inset-into_某某catalog_某某database.某某Table”
这样很不友好啊，能不能我自己指定任务名称呢？
