flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From twalthr <...@git.apache.org>
Subject [GitHub] flink pull request #6201: [FLINK-8866][Table API & SQL] Add support for unif...
Date Tue, 26 Jun 2018 17:19:47 GMT
Github user twalthr commented on a diff in the pull request:

    https://github.com/apache/flink/pull/6201#discussion_r198219005
  
    --- 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);
    --- End diff --
    
    We also need to ship the query config here.


---

Mime
View raw message