[GitHub] flink pull request #6201: [FLINK-8866][Table API & SQL] Add support for unif...

[suez1224]

Github user suez1224 commented on a diff in the pull request:

    https://github.com/apache/flink/pull/6201#discussion_r199066578
  
    --- Diff: 
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/LocalExecutor.java
 ---
    @@ -321,6 +327,18 @@ public void stop(SessionContext session) {
                }
        }
     
    +   private <T> void executeUpdateInternal(ExecutionContext<T> context, 
String query) {
    +           final ExecutionContext.EnvironmentInstance envInst = 
context.createEnvironmentInstance();
    +
    +           envInst.getTableEnvironment().sqlUpdate(query);
    +           // create job graph with dependencies
    +           final String jobName = context.getSessionContext().getName() + 
": " + query;
    +           final JobGraph jobGraph = envInst.createJobGraph(jobName);
    +
    +           // create execution
    +           new Thread(new ProgramDeployer<>(context, jobName, jobGraph, 
null)).start();
    --- End diff --
    
    Yes, let me put it into a separate PR. StatusResult make sense to me.


---