[hotfix] Add missing @Override annotations
diff --git a/src/main/java/org/apache/flink/benchmark/BlockingPartitionBenchmark.java b/src/main/java/org/apache/flink/benchmark/BlockingPartitionBenchmark.java
index f8f2a20..915a4a8 100644
--- a/src/main/java/org/apache/flink/benchmark/BlockingPartitionBenchmark.java
+++ b/src/main/java/org/apache/flink/benchmark/BlockingPartitionBenchmark.java
@@ -87,6 +87,7 @@
*/
private final int parallelism = 4;
+ @Override
public void setUp() throws IOException {
super.setUp();
diff --git a/src/main/java/org/apache/flink/benchmark/BlockingPartitionRemoteChannelBenchmark.java b/src/main/java/org/apache/flink/benchmark/BlockingPartitionRemoteChannelBenchmark.java
index 155bba6..15091a4 100644
--- a/src/main/java/org/apache/flink/benchmark/BlockingPartitionRemoteChannelBenchmark.java
+++ b/src/main/java/org/apache/flink/benchmark/BlockingPartitionRemoteChannelBenchmark.java
@@ -66,6 +66,7 @@
*/
public static class BlockingPartitionEnvironmentContext extends FlinkEnvironmentContext {
+ @Override
public void setUp() throws IOException {
super.setUp();
diff --git a/src/main/java/org/apache/flink/benchmark/MemoryStateBackendBenchmark.java b/src/main/java/org/apache/flink/benchmark/MemoryStateBackendBenchmark.java
index ea0e779..85149f2 100644
--- a/src/main/java/org/apache/flink/benchmark/MemoryStateBackendBenchmark.java
+++ b/src/main/java/org/apache/flink/benchmark/MemoryStateBackendBenchmark.java
@@ -63,6 +63,7 @@
@Param({"MEMORY", "FS", "FS_ASYNC"})
public StateBackend stateBackend = StateBackend.MEMORY;
+ @Override
public void setUp() throws IOException {
super.setUp(stateBackend, RECORDS_PER_INVOCATION);
}
diff --git a/src/main/java/org/apache/flink/benchmark/RocksStateBackendBenchmark.java b/src/main/java/org/apache/flink/benchmark/RocksStateBackendBenchmark.java
index 5c6af97..b748d60 100644
--- a/src/main/java/org/apache/flink/benchmark/RocksStateBackendBenchmark.java
+++ b/src/main/java/org/apache/flink/benchmark/RocksStateBackendBenchmark.java
@@ -66,6 +66,7 @@
@Param({"ROCKS", "ROCKS_INC"})
public StateBackend stateBackend = StateBackend.MEMORY;
+ @Override
public void setUp() throws IOException {
super.setUp(stateBackend, RECORDS_PER_INVOCATION);
}
diff --git a/src/main/java/org/apache/flink/benchmark/UnalignedCheckpointTimeBenchmark.java b/src/main/java/org/apache/flink/benchmark/UnalignedCheckpointTimeBenchmark.java
index b371563..58b3e1c 100644
--- a/src/main/java/org/apache/flink/benchmark/UnalignedCheckpointTimeBenchmark.java
+++ b/src/main/java/org/apache/flink/benchmark/UnalignedCheckpointTimeBenchmark.java
@@ -94,6 +94,7 @@
@Param({"0", "1", "ALIGNED"})
public String timeout = "0";
+ @Override
public void setUp() throws IOException {
super.setUp();
