You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2018/07/23 11:54:23 UTC
flink git commit: [hotfix] [sql-client] Wrap exceptions thrown during
environment instance creation
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 <tw...@apache.org>
Authored: Mon Jul 23 13:48:45 2018 +0200
Committer: Timo Walther <tw...@apache.org>
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() {