[flink-benchmarks] branch exclude_startup updated: +

[chesnay]

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

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


The following commit(s) were added to refs/heads/exclude_startup by this push:
     new d7992fb  +
d7992fb is described below

commit d7992fb788da6699d8cf96c99eb2d2115d896aec
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Wed Jul 14 11:56:03 2021 +0200

    +
---
 pom.xml                                                                 | 1 +
 src/main/java/org/apache/flink/benchmark/WindowBenchmarks.java          | 2 +-
 .../org/apache/flink/benchmark/full/PojoSerializationBenchmark.java     | 2 +-
 .../org/apache/flink/benchmark/full/StringSerializationBenchmark.java   | 2 +-
 4 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/pom.xml b/pom.xml
index ee44284..730e8ac 100644
--- a/pom.xml
+++ b/pom.xml
@@ -190,6 +190,7 @@ under the License.
                </dependency>
 
                <dependency>
+                       <!-- required for using a pre-defined MiniCluster -->
                        <groupId>org.apache.flink</groupId>
                        
<artifactId>flink-test-utils_${scala.binary.version}</artifactId>
                        <version>${flink.version}</version>
diff --git a/src/main/java/org/apache/flink/benchmark/WindowBenchmarks.java 
b/src/main/java/org/apache/flink/benchmark/WindowBenchmarks.java
index 6489fce..1641b9c 100644
--- a/src/main/java/org/apache/flink/benchmark/WindowBenchmarks.java
+++ b/src/main/java/org/apache/flink/benchmark/WindowBenchmarks.java
@@ -85,7 +85,7 @@ public class WindowBenchmarks extends BenchmarkBase {
 
                @Setup
                @Override
-               public void setUp() throws IOException {
+               public void setUp() throws Exception {
                        super.setUp();
 
                        
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
diff --git 
a/src/main/java/org/apache/flink/benchmark/full/PojoSerializationBenchmark.java 
b/src/main/java/org/apache/flink/benchmark/full/PojoSerializationBenchmark.java
index 8951217..af77931 100644
--- 
a/src/main/java/org/apache/flink/benchmark/full/PojoSerializationBenchmark.java
+++ 
b/src/main/java/org/apache/flink/benchmark/full/PojoSerializationBenchmark.java
@@ -63,7 +63,7 @@ public class PojoSerializationBenchmark extends BenchmarkBase 
{
 
 
     @Setup
-    public void setUp() throws Exception {
+    public void setup() throws IOException {
         pojo = new SerializationFrameworkMiniBenchmarks.MyPojo(
                 0,
                 "myName",
diff --git 
a/src/main/java/org/apache/flink/benchmark/full/StringSerializationBenchmark.java
 
b/src/main/java/org/apache/flink/benchmark/full/StringSerializationBenchmark.java
index 729bf7b..ef7ca5d 100644
--- 
a/src/main/java/org/apache/flink/benchmark/full/StringSerializationBenchmark.java
+++ 
b/src/main/java/org/apache/flink/benchmark/full/StringSerializationBenchmark.java
@@ -72,7 +72,7 @@ public class StringSerializationBenchmark extends 
BenchmarkBase {
     DataInputView serializedStream;
 
     @Setup
-    public void setUp() throws Exception {
+    public void setup() throws IOException {
         length = Integer.parseInt(lengthStr);
         switch (type) {
             case "ascii":