void (@NotNull ExecutionEnvironmentBuilder builder) { ExecutionEnvironment environment = builder.build(); try { environment.getRunner().execute(environment); } catch (ExecutionException e) { LOG.error(e); } finally { ((MyRunProfile)environment.getRunProfile()).clear(); } }