This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch 23383 in repository https://gitbox.apache.org/repos/asf/flink-benchmarks.git
commit aa12f042746f1d6ab868bef57702e41abcd8b427 Author: Chesnay Schepler <[email protected]> AuthorDate: Wed Jul 14 14:49:12 2021 +0200 [hotfix] Add missing @Override annotations --- src/main/java/org/apache/flink/benchmark/BlockingPartitionBenchmark.java | 1 + .../apache/flink/benchmark/BlockingPartitionRemoteChannelBenchmark.java | 1 + .../java/org/apache/flink/benchmark/MemoryStateBackendBenchmark.java | 1 + src/main/java/org/apache/flink/benchmark/RocksStateBackendBenchmark.java | 1 + .../org/apache/flink/benchmark/UnalignedCheckpointTimeBenchmark.java | 1 + 5 files changed, 5 insertions(+) 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 @@ public class BlockingPartitionBenchmark extends BenchmarkBase { */ 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 class BlockingPartitionRemoteChannelBenchmark extends RemoteBenchmarkBase */ 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 @@ public class MemoryStateBackendBenchmark extends StateBackendBenchmarkBase { @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 @@ public class RocksStateBackendBenchmark extends StateBackendBenchmarkBase { @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 @@ public class UnalignedCheckpointTimeBenchmark extends BenchmarkBase { @Param({"0", "1", "ALIGNED"}) public String timeout = "0"; + @Override public void setUp() throws IOException { super.setUp();
