Re: 1.11版本，关于TableEnvironment.executeSql("insert into ...")，job名称设置的问题

[Benchao Li]

FYI： 有一个issue[1] 正在跟进和解决这个问题

[1] https://issues.apache.org/jira/browse/FLINK-18545

Zou Dan <zoud...@163.com> 于2020年8月23日周日 下午2:29写道：

> 据我所知，这种执行方式目前没法设置 jobName
>
> > 2020年8月21日 上午11:11，Asahi Lee <978466...@qq.com> 写道：
> >
> > 你好！
> > &nbsp; &nbsp; &nbsp;我通过表环境执行insert into语句提交作业，我该如何设置我的job名称呢？
> >
> >
> > 程序：
> > EnvironmentSettings bbSettings =
> EnvironmentSettings.newInstance().useBlinkPlanner().build();
> > TableEnvironment bsTableEnv = TableEnvironment.create(bbSettings);
> >
> > String sourceDDL = "CREATE TABLE datagen (  " +
> >        " f_random INT,  " +
> >        " f_random_str STRING,  " +
> >        " ts AS localtimestamp,  " +
> >        " WATERMARK FOR ts AS ts  " +
> >        ") WITH (  " +
> >        " 'connector' = 'datagen',  " +
> >        " 'rows-per-second'='10',  " +
> >        " 'fields.f_random.min'='1',  " +
> >        " 'fields.f_random.max'='5',  " +
> >        " 'fields.f_random_str.length'='10'  " +
> >        ")";
> >
> > bsTableEnv.executeSql(sourceDDL);
> > Table datagen = bsTableEnv.from("datagen");
> >
> > System.out.println(datagen.getSchema());
> >
> > String sinkDDL = "CREATE TABLE print_table (" +
> >        " f_random int," +
> >        " c_val bigint, " +
> >        " wStart TIMESTAMP(3) " +
> >        ") WITH ('connector' = 'print') ";
> > bsTableEnv.executeSql(sinkDDL);
> >
> > System.out.println(bsTableEnv.from("print_table").getSchema());
> >
> > Table table = bsTableEnv.sqlQuery("select f_random, count(f_random_str),
> TUMBLE_START(ts, INTERVAL '5' second) as wStart from datagen group by
> TUMBLE(ts, INTERVAL '5' second), f_random");
> > bsTableEnv.executeSql("insert into print_table select * from " + table);
>
>
>

-- 

Best,
Benchao Li