FlinkSQL 任务提交后 任务名称问题

[Evan <ch...@foxmail.com>]

代码大概是这样子的，一张kafka source表，一张es Sink表，最后通过tableEnv.executeSql("insert into esSinkTable select ... from kafkaSourceTable")执行
任务提交后任务名称为“inset-into_某某catalog_某某database.某某Table”


这样很不友好啊，能不能我自己指定任务名称呢？

Re: FlinkSQL 任务提交后 任务名称问题

[LittleFall <15...@qq.com>]

谢谢两位，我尝试一下。

也希望 flink sql client 本身支持这样的模式。



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: FlinkSQL 任务提交后 任务名称问题

[godfrey he <go...@gmail.com>]

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 <zj...@gmail.com> 于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 <ch...@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
>

Re: FlinkSQL 任务提交后 任务名称问题

[Jeff Zhang <zj...@gmail.com>]

在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 <ch...@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