client-flink/flink-1.16/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java [34:55]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public ShuffleEnvironment createShuffleEnvironment( ShuffleEnvironmentContext shuffleEnvironmentContext) { AbstractRemoteShuffleServiceParameters parameters = initializePreCreateShuffleEnvironment(shuffleEnvironmentContext); RemoteShuffleResultPartitionFactory resultPartitionFactory = new RemoteShuffleResultPartitionFactory( parameters.celebornConf, parameters.resultPartitionManager, parameters.networkBufferPool, parameters.bufferSize); RemoteShuffleInputGateFactory inputGateFactory = new RemoteShuffleInputGateFactory( parameters.celebornConf, parameters.networkBufferPool, parameters.bufferSize); return new RemoteShuffleEnvironment( parameters.networkBufferPool, parameters.resultPartitionManager, resultPartitionFactory, inputGateFactory, parameters.celebornConf, new NettyShuffleEnvironmentWrapper(nettyShuffleServiceFactory, shuffleEnvironmentContext)); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java [34:55]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public ShuffleEnvironment createShuffleEnvironment( ShuffleEnvironmentContext shuffleEnvironmentContext) { AbstractRemoteShuffleServiceParameters parameters = initializePreCreateShuffleEnvironment(shuffleEnvironmentContext); RemoteShuffleResultPartitionFactory resultPartitionFactory = new RemoteShuffleResultPartitionFactory( parameters.celebornConf, parameters.resultPartitionManager, parameters.networkBufferPool, parameters.bufferSize); RemoteShuffleInputGateFactory inputGateFactory = new RemoteShuffleInputGateFactory( parameters.celebornConf, parameters.networkBufferPool, parameters.bufferSize); return new RemoteShuffleEnvironment( parameters.networkBufferPool, parameters.resultPartitionManager, resultPartitionFactory, inputGateFactory, parameters.celebornConf, new NettyShuffleEnvironmentWrapper(nettyShuffleServiceFactory, shuffleEnvironmentContext)); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java [34:55]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public ShuffleEnvironment createShuffleEnvironment( ShuffleEnvironmentContext shuffleEnvironmentContext) { AbstractRemoteShuffleServiceParameters parameters = initializePreCreateShuffleEnvironment(shuffleEnvironmentContext); RemoteShuffleResultPartitionFactory resultPartitionFactory = new RemoteShuffleResultPartitionFactory( parameters.celebornConf, parameters.resultPartitionManager, parameters.networkBufferPool, parameters.bufferSize); RemoteShuffleInputGateFactory inputGateFactory = new RemoteShuffleInputGateFactory( parameters.celebornConf, parameters.networkBufferPool, parameters.bufferSize); return new RemoteShuffleEnvironment( parameters.networkBufferPool, parameters.resultPartitionManager, resultPartitionFactory, inputGateFactory, parameters.celebornConf, new NettyShuffleEnvironmentWrapper(nettyShuffleServiceFactory, shuffleEnvironmentContext)); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - client-flink/flink-1.19/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java [34:55]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public ShuffleEnvironment createShuffleEnvironment( ShuffleEnvironmentContext shuffleEnvironmentContext) { AbstractRemoteShuffleServiceParameters parameters = initializePreCreateShuffleEnvironment(shuffleEnvironmentContext); RemoteShuffleResultPartitionFactory resultPartitionFactory = new RemoteShuffleResultPartitionFactory( parameters.celebornConf, parameters.resultPartitionManager, parameters.networkBufferPool, parameters.bufferSize); RemoteShuffleInputGateFactory inputGateFactory = new RemoteShuffleInputGateFactory( parameters.celebornConf, parameters.networkBufferPool, parameters.bufferSize); return new RemoteShuffleEnvironment( parameters.networkBufferPool, parameters.resultPartitionManager, resultPartitionFactory, inputGateFactory, parameters.celebornConf, new NettyShuffleEnvironmentWrapper(nettyShuffleServiceFactory, shuffleEnvironmentContext)); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java [34:55]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public ShuffleEnvironment createShuffleEnvironment( ShuffleEnvironmentContext shuffleEnvironmentContext) { AbstractRemoteShuffleServiceParameters parameters = initializePreCreateShuffleEnvironment(shuffleEnvironmentContext); RemoteShuffleResultPartitionFactory resultPartitionFactory = new RemoteShuffleResultPartitionFactory( parameters.celebornConf, parameters.resultPartitionManager, parameters.networkBufferPool, parameters.bufferSize); RemoteShuffleInputGateFactory inputGateFactory = new RemoteShuffleInputGateFactory( parameters.celebornConf, parameters.networkBufferPool, parameters.bufferSize); return new RemoteShuffleEnvironment( parameters.networkBufferPool, parameters.resultPartitionManager, resultPartitionFactory, inputGateFactory, parameters.celebornConf, new NettyShuffleEnvironmentWrapper(nettyShuffleServiceFactory, shuffleEnvironmentContext)); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - client-flink/flink-1.18/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java [34:55]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public ShuffleEnvironment createShuffleEnvironment( ShuffleEnvironmentContext shuffleEnvironmentContext) { AbstractRemoteShuffleServiceParameters parameters = initializePreCreateShuffleEnvironment(shuffleEnvironmentContext); RemoteShuffleResultPartitionFactory resultPartitionFactory = new RemoteShuffleResultPartitionFactory( parameters.celebornConf, parameters.resultPartitionManager, parameters.networkBufferPool, parameters.bufferSize); RemoteShuffleInputGateFactory inputGateFactory = new RemoteShuffleInputGateFactory( parameters.celebornConf, parameters.networkBufferPool, parameters.bufferSize); return new RemoteShuffleEnvironment( parameters.networkBufferPool, parameters.resultPartitionManager, resultPartitionFactory, inputGateFactory, parameters.celebornConf, new NettyShuffleEnvironmentWrapper(nettyShuffleServiceFactory, shuffleEnvironmentContext)); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -