[hotfix] [sql-client] Wrap exceptions thrown during environment insta…

…nce creation
mpdn · Jul 23, 2018 · 7308874 · 7308874
1 parent d850fde
commit 7308874
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...ql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java b/...ql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java
@@ -166,7 +166,12 @@ public ClusterDescriptor<T> createClusterDescriptor() throws Exception {
 	}
 
 	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() {