在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 <chengyanan1...@foxmail.com> 于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