[flink-benchmarks] branch master updated: [FLINK-28931] Fix BlockingPartitionBenchmark compile error

[roman]

This is an automated email from the ASF dual-hosted git repository.

roman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-benchmarks.git


The following commit(s) were added to refs/heads/master by this push:
     new 4726194  [FLINK-28931] Fix BlockingPartitionBenchmark compile error
4726194 is described below

commit 4726194e7e73a39a78b102a4ce2b4ece4d338ece
Author: Roman Khachatryan <khachatryan.ro...@gmail.com>
AuthorDate: Thu Aug 11 15:22:18 2022 +0200

    [FLINK-28931] Fix BlockingPartitionBenchmark compile error
---
 .../java/org/apache/flink/benchmark/BlockingPartitionBenchmark.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/src/main/java/org/apache/flink/benchmark/BlockingPartitionBenchmark.java 
b/src/main/java/org/apache/flink/benchmark/BlockingPartitionBenchmark.java
index bcef395..c447049 100644
--- a/src/main/java/org/apache/flink/benchmark/BlockingPartitionBenchmark.java
+++ b/src/main/java/org/apache/flink/benchmark/BlockingPartitionBenchmark.java
@@ -114,7 +114,7 @@ public class BlockingPartitionBenchmark extends 
BenchmarkBase {
                         Integer.MAX_VALUE);
             }
             configuration.setBoolean(
-                    
NettyShuffleEnvironmentOptions.BLOCKING_SHUFFLE_COMPRESSION_ENABLED,
+                    
NettyShuffleEnvironmentOptions.BATCH_SHUFFLE_COMPRESSION_ENABLED,
                     compressionEnabled);
             configuration.setString(
                     
NettyShuffleEnvironmentOptions.NETWORK_BLOCKING_SHUFFLE_TYPE, subpartitionType);