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

[Zou Dan]

据我所知，这种执行方式目前没法设置 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);