commit 4726194e7e73a39a78b102a4ce2b4ece4d338ece
author Roman Khachatryan <khachatryan.roman@gmail.com> Thu Aug 11 15:22:18 2022 +0200
committer Roman <khachatryan.roman@gmail.com> Fri Aug 12 09:59:47 2022 +0200
tree 907705f0df6c10aef5b178e81599287d3ce2aeb2
parent 5d2f5a96b4bcb6f2e96db0a16a7ccea6280c91e2

[FLINK-28931] Fix BlockingPartitionBenchmark compile error

src/main/java/org/apache/flink/benchmark/BlockingPartitionBenchmark.java

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 @@
                         Integer.MAX_VALUE);
             }
             configuration.setBoolean(
-                    NettyShuffleEnvironmentOptions.BLOCKING_SHUFFLE_COMPRESSION_ENABLED,
+                    NettyShuffleEnvironmentOptions.BATCH_SHUFFLE_COMPRESSION_ENABLED,
                     compressionEnabled);
             configuration.setString(
                     NettyShuffleEnvironmentOptions.NETWORK_BLOCKING_SHUFFLE_TYPE, subpartitionType);