src/main/java/org/apache/flink/benchmark/BlockingPartitionBenchmark.java [106:114]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            Configuration configuration = super.createConfiguration();

            if (isSortShuffle) {
                configuration.setInteger(
                        NettyShuffleEnvironmentOptions.NETWORK_SORT_SHUFFLE_MIN_PARALLELISM, 1);
            } else {
                configuration.setInteger(
                        NettyShuffleEnvironmentOptions.NETWORK_SORT_SHUFFLE_MIN_PARALLELISM,
                        Integer.MAX_VALUE);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/org/apache/flink/benchmark/BlockingPartitionRemoteChannelBenchmark.java [79:87]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            Configuration configuration = super.createConfiguration();

            if (isSortShuffle) {
                configuration.setInteger(
                        NettyShuffleEnvironmentOptions.NETWORK_SORT_SHUFFLE_MIN_PARALLELISM, 1);
            } else {
                configuration.setInteger(
                        NettyShuffleEnvironmentOptions.NETWORK_SORT_SHUFFLE_MIN_PARALLELISM,
                        Integer.MAX_VALUE);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -