Repository: flink Updated Branches: refs/heads/master d850fdec9 -> 73088749e
[hotfix] [sql-client] Wrap exceptions thrown during environment instance creation Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/73088749 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/73088749 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/73088749 Branch: refs/heads/master Commit: 73088749e6377ad40bfed3a9da1b306bfbc4c2f4 Parents: d850fde Author: Timo Walther <[email protected]> Authored: Mon Jul 23 13:48:45 2018 +0200 Committer: Timo Walther <[email protected]> Committed: Mon Jul 23 13:48:45 2018 +0200 ---------------------------------------------------------------------- .../flink/table/client/gateway/local/ExecutionContext.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/73088749/flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java ---------------------------------------------------------------------- diff --git a/flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java b/flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java index 9152908..4283953 100644 --- a/flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java +++ b/flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java @@ -166,7 +166,12 @@ public class ExecutionContext<T> { } public EnvironmentInstance createEnvironmentInstance() { - return new EnvironmentInstance(); + try { + return new EnvironmentInstance(); + } catch (Throwable t) { + // catch everything such that a wrong environment does not affect invocations + throw new SqlExecutionException("Could not create environment instance.", t); + } } public Map<String, TableSource<?>> getTableSources() {
