diff --git a/flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/application/ScriptRunner.java b/flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/application/ScriptRunner.java index 060d0f87be6c1..7c4ea7585abf5 100644 --- a/flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/application/ScriptRunner.java +++ b/flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/application/ScriptRunner.java @@ -45,13 +45,12 @@ public static void run(String script) throws Exception { @VisibleForTesting public static void run(String script, OutputStream outputStream) throws Exception { DefaultContext defaultContext = - DefaultContext.load( + new DefaultContext( (Configuration) StreamExecutionEnvironment.getExecutionEnvironment( new Configuration()) .getConfiguration(), - Collections.emptyList(), - false); + Collections.emptyList()); SessionContext sessionContext = SessionContext.create( defaultContext,