RemoteConnection (ExecutionEnvironment environment) { return remoteConnectionCreator == null ? super.createRemoteConnection(environment) : remoteConnectionCreator.createRemoteConnection(environment); }