[
https://issues.apache.org/jira/browse/FLINK-20919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266160#comment-17266160
]
Till Rohrmann commented on FLINK-20919:
---------------------------------------
Hi [~Janze], I was able to reproduce your problem. The problem is that SQL
operations are asynchronous and per default, they don't block until the job has
been executed. Therefore, the job result is not queried from the cluster. What
you have to do in order to change it is to explicitly wait on the returned
{{TableResult}} via
{code}
tableEnv.from("t").executeInsert("print_table").get().getJobExecutionResult(Thread.currentThread().getContextClassLoader()).get();
{code}
Unfortunately, this is not very explicitly documented or at least I couldn't
find a reference for it.
cc [~twalthr], [~jark] if it is not documented, then we could update the docs
accordingly.
> After the flink batch job is completed, the yarn application cannot be
> completed.
> ---------------------------------------------------------------------------------
>
> Key: FLINK-20919
> URL: https://issues.apache.org/jira/browse/FLINK-20919
> Project: Flink
> Issue Type: Bug
> Components: Deployment / YARN
> Affects Versions: 1.11.2
> Reporter: Wu
> Priority: Major
> Attachments: flink-Overview.png, flink-completed.png,
> flink-jobManager.png, jobmanager.log, kaLr8Coy.png
>
>
> I submit flink batch job in yarn-cluster mode. After the flink batch job is
> completed, the yarn application cannot be completed. The yarn application
> still occupies a vcore. How to automatically close the yarn application.
>
> {code:java}
> //代码占位符
> EnvironmentSettings settings =
> EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build();
> TableEnvironment tableEnv = TableEnvironment.create(settings);
> tableEnv.executeSql("create table file_table");
> tableEnv.executeSql("create table print_table");
> String sql = "select count(1) from file_table";
> Table table = tableEnv.sqlQuery(sql);
> tableEnv.createTemporaryView("t", table);
> tableEnv.from("t").executeInsert("print_table");
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
