[jira] [Commented] (FLINK-20919) After the flink batch job is completed, the yarn application cannot be completed.

[Wu (Jira)]

    [ 
https://issues.apache.org/jira/browse/FLINK-20919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17263954#comment-17263954
 ] 

Wu commented on FLINK-20919:
----------------------------

[~fly_in_gis]  Try to run the code as follows. Use the filesystem and print 
connector

 
        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");

> 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, 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)