@Test public void testExecutionConfig() throws Exception { final ExecutionContext<?> context = createDefaultExecutionContext(); final ExecutionConfig config = context.createEnvironmentInstance().getExecutionConfig(); assertEquals(99, config.getAutoWatermarkInterval()); final RestartStrategies.RestartStrategyConfiguration restartConfig = config.getRestartStrategy(); assertTrue(restartConfig instanceof RestartStrategies.FailureRateRestartStrategyConfiguration); final RestartStrategies.FailureRateRestartStrategyConfiguration failureRateStrategy = (RestartStrategies.FailureRateRestartStrategyConfiguration) restartConfig; assertEquals(10, failureRateStrategy.getMaxFailureRate()); assertEquals(99_000, failureRateStrategy.getFailureInterval().toMilliseconds()); assertEquals(1_000, failureRateStrategy.getDelayBetweenAttemptsInterval().toMilliseconds()); }
public EnvironmentInstance createEnvironmentInstance() { try { return wrapClassLoader(EnvironmentInstance::new); } catch (Throwable t) { throw new SqlExecutionException("Could not create environment instance.", t); } }
ExecutionContext { public EnvironmentInstance createEnvironmentInstance() { try { return wrapClassLoader(EnvironmentInstance::new); } catch (Throwable t) { throw new SqlExecutionException("Could not create environment instance.", t); } } }
ExecutionContext { public EnvironmentInstance createEnvironmentInstance() { try { return wrapClassLoader(EnvironmentInstance::new); } catch (Throwable t) { throw new SqlExecutionException("Could not create environment instance.", t); } } ExecutionContext(Environment defaultEnvironment, SessionContext sessionContext, List<URL> dependencies,
			Configuration flinkConfig, Options commandLineOptions, List<CustomCommandLine<?>> availableCommandLines); }
ExecutionContext { public EnvironmentInstance createEnvironmentInstance() { try { return wrapClassLoader(EnvironmentInstance::new); } catch (Throwable t) { throw new SqlExecutionException("Could not create environment instance.", t); } } ExecutionContext(Environment defaultEnvironment, SessionContext sessionContext, List<URL> dependencies,
			Configuration flinkConfig, Options commandLineOptions, List<CustomCommandLine<?>> availableCommandLines); SessionContext getSessionContext(); ClassLoader getClassLoader(); Environment getMergedEnvironment(); ClusterSpecification getClusterSpec(); T getClusterId(); ClusterDescriptor<T> createClusterDescriptor(); EnvironmentInstance createEnvironmentInstance(); Map<String, Catalog> getCatalogs(); Map<String, TableSource<?>> getTableSources(); Map<String, TableSink<?>> getTableSinks(); R wrapClassLoader(Supplier<R> supplier); }
ExecutionContext { public EnvironmentInstance createEnvironmentInstance() { try { return wrapClassLoader(EnvironmentInstance::new); } catch (Throwable t) { throw new SqlExecutionException("Could not create environment instance.", t); } } ExecutionContext(Environment defaultEnvironment, SessionContext sessionContext, List<URL> dependencies,
			Configuration flinkConfig, Options commandLineOptions, List<CustomCommandLine<?>> availableCommandLines); SessionContext getSessionContext(); ClassLoader getClassLoader(); Environment getMergedEnvironment(); ClusterSpecification getClusterSpec(); T getClusterId(); ClusterDescriptor<T> createClusterDescriptor(); EnvironmentInstance createEnvironmentInstance(); Map<String, Catalog> getCatalogs(); Map<String, TableSource<?>> getTableSources(); Map<String, TableSink<?>> getTableSinks(); R wrapClassLoader(Supplier<R> supplier);  }