This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-benchmarks.git
commit 3ca5d3719835297c1cecf45a62add4fed8912df7
Author: Dawid Wysakowicz <dwysakow...@apache.org>
AuthorDate: Fri Sep 24 18:54:15 2021 +0200
[hotfix] Optimize imports
---
.../apache/flink/benchmark/BlockingPartitionBenchmark.java | 1 -
.../benchmark/BlockingPartitionRemoteChannelBenchmark.java | 1 -
.../benchmark/ContinuousFileReaderOperatorBenchmark.java | 5 ++---
.../org/apache/flink/benchmark/FlinkEnvironmentContext.java | 2 +-
.../apache/flink/benchmark/MemoryStateBackendBenchmark.java | 2 --
.../apache/flink/benchmark/RocksStateBackendBenchmark.java | 2 --
.../flink/benchmark/UnalignedCheckpointTimeBenchmark.java | 2 --
.../java/org/apache/flink/benchmark/WindowBenchmarks.java | 1 -
.../flink/benchmark/full/PojoSerializationBenchmark.java | 11 +++++++++--
.../flink/benchmark/full/StringSerializationBenchmark.java | 10 +++++++++-
.../flink/benchmark/functions/BaseSourceWithKeyRange.java | 1 -
.../PartitionReleaseInBatchJobBenchmarkExecutor.java | 1 -
.../scheduling/InitSchedulingStrategyBenchmarkExecutor.java | 1 -
.../SchedulingDownstreamTasksInBatchJobBenchmarkExecutor.java | 1 -
.../topology/BuildExecutionGraphBenchmarkExecutor.java | 1 -
15 files changed, 21 insertions(+), 21 deletions(-)
diff --git
a/src/main/java/org/apache/flink/benchmark/BlockingPartitionBenchmark.java
b/src/main/java/org/apache/flink/benchmark/BlockingPartitionBenchmark.java
index 425debe..c05a9fd 100644
--- a/src/main/java/org/apache/flink/benchmark/BlockingPartitionBenchmark.java
+++ b/src/main/java/org/apache/flink/benchmark/BlockingPartitionBenchmark.java
@@ -27,7 +27,6 @@ import org.apache.flink.util.FileUtils;
import org.openjdk.jmh.annotations.Benchmark;
import org.openjdk.jmh.annotations.OperationsPerInvocation;
-import org.openjdk.jmh.annotations.Setup;
import org.openjdk.jmh.runner.Runner;
import org.openjdk.jmh.runner.RunnerException;
import org.openjdk.jmh.runner.options.Options;
diff --git
a/src/main/java/org/apache/flink/benchmark/BlockingPartitionRemoteChannelBenchmark.java
b/src/main/java/org/apache/flink/benchmark/BlockingPartitionRemoteChannelBenchmark.java
index 21e7cc1..59338db 100644
---
a/src/main/java/org/apache/flink/benchmark/BlockingPartitionRemoteChannelBenchmark.java
+++
b/src/main/java/org/apache/flink/benchmark/BlockingPartitionRemoteChannelBenchmark.java
@@ -27,7 +27,6 @@ import org.apache.flink.util.FileUtils;
import org.openjdk.jmh.annotations.Benchmark;
import org.openjdk.jmh.annotations.OperationsPerInvocation;
-import org.openjdk.jmh.annotations.Setup;
import org.openjdk.jmh.runner.Runner;
import org.openjdk.jmh.runner.RunnerException;
import org.openjdk.jmh.runner.options.Options;
diff --git
a/src/main/java/org/apache/flink/benchmark/ContinuousFileReaderOperatorBenchmark.java
b/src/main/java/org/apache/flink/benchmark/ContinuousFileReaderOperatorBenchmark.java
index 524bf5d..09ca8e3 100644
---
a/src/main/java/org/apache/flink/benchmark/ContinuousFileReaderOperatorBenchmark.java
+++
b/src/main/java/org/apache/flink/benchmark/ContinuousFileReaderOperatorBenchmark.java
@@ -17,7 +17,6 @@
package org.apache.flink.benchmark;
-import joptsimple.internal.Strings;
import org.apache.flink.api.common.io.FileInputFormat;
import org.apache.flink.api.common.restartstrategy.RestartStrategies;
import org.apache.flink.api.common.typeinfo.TypeInformation;
@@ -30,10 +29,10 @@ import
org.apache.flink.streaming.api.functions.sink.SinkFunction;
import
org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperatorFactory;
import org.apache.flink.streaming.api.functions.source.SourceFunction;
import
org.apache.flink.streaming.api.functions.source.TimestampedFileInputSplit;
+
+import joptsimple.internal.Strings;
import org.openjdk.jmh.annotations.Benchmark;
-import org.openjdk.jmh.annotations.Level;
import org.openjdk.jmh.annotations.OperationsPerInvocation;
-import org.openjdk.jmh.annotations.TearDown;
import org.openjdk.jmh.runner.Runner;
import org.openjdk.jmh.runner.RunnerException;
import org.openjdk.jmh.runner.options.Options;
diff --git
a/src/main/java/org/apache/flink/benchmark/FlinkEnvironmentContext.java
b/src/main/java/org/apache/flink/benchmark/FlinkEnvironmentContext.java
index 82201f9..7c8c97b 100644
--- a/src/main/java/org/apache/flink/benchmark/FlinkEnvironmentContext.java
+++ b/src/main/java/org/apache/flink/benchmark/FlinkEnvironmentContext.java
@@ -27,8 +27,8 @@ import org.apache.flink.runtime.minicluster.MiniCluster;
import org.apache.flink.runtime.minicluster.MiniClusterConfiguration;
import org.apache.flink.runtime.state.memory.MemoryStateBackend;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
-
import org.apache.flink.test.util.MiniClusterPipelineExecutorServiceLoader;
+
import org.openjdk.jmh.annotations.Setup;
import org.openjdk.jmh.annotations.State;
import org.openjdk.jmh.annotations.TearDown;
diff --git
a/src/main/java/org/apache/flink/benchmark/MemoryStateBackendBenchmark.java
b/src/main/java/org/apache/flink/benchmark/MemoryStateBackendBenchmark.java
index 85149f2..406b33b 100644
--- a/src/main/java/org/apache/flink/benchmark/MemoryStateBackendBenchmark.java
+++ b/src/main/java/org/apache/flink/benchmark/MemoryStateBackendBenchmark.java
@@ -25,9 +25,7 @@ import org.apache.flink.streaming.api.windowing.time.Time;
import org.openjdk.jmh.annotations.Benchmark;
import org.openjdk.jmh.annotations.OperationsPerInvocation;
import org.openjdk.jmh.annotations.Param;
-import org.openjdk.jmh.annotations.Setup;
import org.openjdk.jmh.annotations.State;
-import org.openjdk.jmh.annotations.TearDown;
import org.openjdk.jmh.runner.Runner;
import org.openjdk.jmh.runner.RunnerException;
import org.openjdk.jmh.runner.options.Options;
diff --git
a/src/main/java/org/apache/flink/benchmark/RocksStateBackendBenchmark.java
b/src/main/java/org/apache/flink/benchmark/RocksStateBackendBenchmark.java
index b748d60..0f80e37 100644
--- a/src/main/java/org/apache/flink/benchmark/RocksStateBackendBenchmark.java
+++ b/src/main/java/org/apache/flink/benchmark/RocksStateBackendBenchmark.java
@@ -28,9 +28,7 @@ import org.apache.flink.streaming.api.windowing.time.Time;
import org.openjdk.jmh.annotations.Benchmark;
import org.openjdk.jmh.annotations.OperationsPerInvocation;
import org.openjdk.jmh.annotations.Param;
-import org.openjdk.jmh.annotations.Setup;
import org.openjdk.jmh.annotations.State;
-import org.openjdk.jmh.annotations.TearDown;
import org.openjdk.jmh.runner.Runner;
import org.openjdk.jmh.runner.RunnerException;
import org.openjdk.jmh.runner.options.Options;
diff --git
a/src/main/java/org/apache/flink/benchmark/UnalignedCheckpointTimeBenchmark.java
b/src/main/java/org/apache/flink/benchmark/UnalignedCheckpointTimeBenchmark.java
index e328b85..7534c12 100644
---
a/src/main/java/org/apache/flink/benchmark/UnalignedCheckpointTimeBenchmark.java
+++
b/src/main/java/org/apache/flink/benchmark/UnalignedCheckpointTimeBenchmark.java
@@ -21,7 +21,6 @@ package org.apache.flink.benchmark;
import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.benchmark.operators.RecordSource;
import org.apache.flink.benchmark.operators.RecordSource.Record;
-import org.apache.flink.configuration.ConfigConstants;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.configuration.MemorySize;
import org.apache.flink.configuration.TaskManagerOptions;
@@ -33,7 +32,6 @@ import org.openjdk.jmh.annotations.Benchmark;
import org.openjdk.jmh.annotations.OperationsPerInvocation;
import org.openjdk.jmh.annotations.OutputTimeUnit;
import org.openjdk.jmh.annotations.Param;
-import org.openjdk.jmh.annotations.Setup;
import org.openjdk.jmh.runner.Runner;
import org.openjdk.jmh.runner.RunnerException;
import org.openjdk.jmh.runner.options.Options;
diff --git a/src/main/java/org/apache/flink/benchmark/WindowBenchmarks.java
b/src/main/java/org/apache/flink/benchmark/WindowBenchmarks.java
index 8fa6b6b..f78b7f9 100644
--- a/src/main/java/org/apache/flink/benchmark/WindowBenchmarks.java
+++ b/src/main/java/org/apache/flink/benchmark/WindowBenchmarks.java
@@ -30,7 +30,6 @@ import org.apache.flink.streaming.api.windowing.time.Time;
import org.openjdk.jmh.annotations.Benchmark;
import org.openjdk.jmh.annotations.OperationsPerInvocation;
-import org.openjdk.jmh.annotations.Setup;
import org.openjdk.jmh.runner.Runner;
import org.openjdk.jmh.runner.RunnerException;
import org.openjdk.jmh.runner.options.Options;
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 af77931..37fc508 100644
---
a/src/main/java/org/apache/flink/benchmark/full/PojoSerializationBenchmark.java
+++
b/src/main/java/org/apache/flink/benchmark/full/PojoSerializationBenchmark.java
@@ -17,23 +17,30 @@
*/
package org.apache.flink.benchmark.full;
+
import org.apache.flink.api.common.ExecutionConfig;
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.api.common.typeutils.TypeSerializer;
import org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer;
import org.apache.flink.benchmark.BenchmarkBase;
import org.apache.flink.benchmark.SerializationFrameworkMiniBenchmarks;
-import org.apache.flink.core.memory.DataInputView;
import org.apache.flink.core.memory.DataInputViewStreamWrapper;
import org.apache.flink.core.memory.DataOutputView;
import org.apache.flink.core.memory.DataOutputViewStreamWrapper;
import org.apache.flink.formats.avro.typeutils.AvroSerializer;
+
+import org.openjdk.jmh.annotations.Benchmark;
+import org.openjdk.jmh.annotations.BenchmarkMode;
+import org.openjdk.jmh.annotations.Mode;
+import org.openjdk.jmh.annotations.OutputTimeUnit;
+import org.openjdk.jmh.annotations.Scope;
+import org.openjdk.jmh.annotations.Setup;
+import org.openjdk.jmh.annotations.State;
import org.openjdk.jmh.runner.Runner;
import org.openjdk.jmh.runner.RunnerException;
import org.openjdk.jmh.runner.options.Options;
import org.openjdk.jmh.runner.options.OptionsBuilder;
import org.openjdk.jmh.runner.options.VerboseMode;
-import org.openjdk.jmh.annotations.*;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
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 ef7ca5d..9490a17 100644
---
a/src/main/java/org/apache/flink/benchmark/full/StringSerializationBenchmark.java
+++
b/src/main/java/org/apache/flink/benchmark/full/StringSerializationBenchmark.java
@@ -26,12 +26,20 @@ import org.apache.flink.core.memory.DataInputView;
import org.apache.flink.core.memory.DataInputViewStreamWrapper;
import org.apache.flink.core.memory.DataOutputView;
import org.apache.flink.core.memory.DataOutputViewStreamWrapper;
+
+import org.openjdk.jmh.annotations.Benchmark;
+import org.openjdk.jmh.annotations.BenchmarkMode;
+import org.openjdk.jmh.annotations.Mode;
+import org.openjdk.jmh.annotations.OutputTimeUnit;
+import org.openjdk.jmh.annotations.Param;
+import org.openjdk.jmh.annotations.Scope;
+import org.openjdk.jmh.annotations.Setup;
+import org.openjdk.jmh.annotations.State;
import org.openjdk.jmh.runner.Runner;
import org.openjdk.jmh.runner.RunnerException;
import org.openjdk.jmh.runner.options.Options;
import org.openjdk.jmh.runner.options.OptionsBuilder;
import org.openjdk.jmh.runner.options.VerboseMode;
-import org.openjdk.jmh.annotations.*;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
diff --git
a/src/main/java/org/apache/flink/benchmark/functions/BaseSourceWithKeyRange.java
b/src/main/java/org/apache/flink/benchmark/functions/BaseSourceWithKeyRange.java
index d65f34c..11cefdd 100644
---
a/src/main/java/org/apache/flink/benchmark/functions/BaseSourceWithKeyRange.java
+++
b/src/main/java/org/apache/flink/benchmark/functions/BaseSourceWithKeyRange.java
@@ -18,7 +18,6 @@
package org.apache.flink.benchmark.functions;
-import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.streaming.api.functions.source.ParallelSourceFunction;
import
org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext;
diff --git
a/src/main/java/org/apache/flink/scheduler/benchmark/partitionrelease/PartitionReleaseInBatchJobBenchmarkExecutor.java
b/src/main/java/org/apache/flink/scheduler/benchmark/partitionrelease/PartitionReleaseInBatchJobBenchmarkExecutor.java
index 3657874..af4cefa 100644
---
a/src/main/java/org/apache/flink/scheduler/benchmark/partitionrelease/PartitionReleaseInBatchJobBenchmarkExecutor.java
+++
b/src/main/java/org/apache/flink/scheduler/benchmark/partitionrelease/PartitionReleaseInBatchJobBenchmarkExecutor.java
@@ -19,7 +19,6 @@
package org.apache.flink.scheduler.benchmark.partitionrelease;
import org.apache.flink.runtime.scheduler.benchmark.JobConfiguration;
-import org.apache.flink.runtime.scheduler.benchmark.SchedulerBenchmarkUtils;
import
org.apache.flink.runtime.scheduler.benchmark.partitionrelease.PartitionReleaseInBatchJobBenchmark;
import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkExecutorBase;
diff --git
a/src/main/java/org/apache/flink/scheduler/benchmark/scheduling/InitSchedulingStrategyBenchmarkExecutor.java
b/src/main/java/org/apache/flink/scheduler/benchmark/scheduling/InitSchedulingStrategyBenchmarkExecutor.java
index 21c66d8..2674a0b 100644
---
a/src/main/java/org/apache/flink/scheduler/benchmark/scheduling/InitSchedulingStrategyBenchmarkExecutor.java
+++
b/src/main/java/org/apache/flink/scheduler/benchmark/scheduling/InitSchedulingStrategyBenchmarkExecutor.java
@@ -19,7 +19,6 @@
package org.apache.flink.scheduler.benchmark.scheduling;
import org.apache.flink.runtime.scheduler.benchmark.JobConfiguration;
-import org.apache.flink.runtime.scheduler.benchmark.SchedulerBenchmarkUtils;
import
org.apache.flink.runtime.scheduler.benchmark.scheduling.InitSchedulingStrategyBenchmark;
import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkExecutorBase;
diff --git
a/src/main/java/org/apache/flink/scheduler/benchmark/scheduling/SchedulingDownstreamTasksInBatchJobBenchmarkExecutor.java
b/src/main/java/org/apache/flink/scheduler/benchmark/scheduling/SchedulingDownstreamTasksInBatchJobBenchmarkExecutor.java
index 7968ff9..586ec6a 100644
---
a/src/main/java/org/apache/flink/scheduler/benchmark/scheduling/SchedulingDownstreamTasksInBatchJobBenchmarkExecutor.java
+++
b/src/main/java/org/apache/flink/scheduler/benchmark/scheduling/SchedulingDownstreamTasksInBatchJobBenchmarkExecutor.java
@@ -19,7 +19,6 @@
package org.apache.flink.scheduler.benchmark.scheduling;
import org.apache.flink.runtime.scheduler.benchmark.JobConfiguration;
-import org.apache.flink.runtime.scheduler.benchmark.SchedulerBenchmarkUtils;
import
org.apache.flink.runtime.scheduler.benchmark.scheduling.SchedulingDownstreamTasksInBatchJobBenchmark;
import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkExecutorBase;
diff --git
a/src/main/java/org/apache/flink/scheduler/benchmark/topology/BuildExecutionGraphBenchmarkExecutor.java
b/src/main/java/org/apache/flink/scheduler/benchmark/topology/BuildExecutionGraphBenchmarkExecutor.java
index cf97809..d5f8496 100644
---
a/src/main/java/org/apache/flink/scheduler/benchmark/topology/BuildExecutionGraphBenchmarkExecutor.java
+++
b/src/main/java/org/apache/flink/scheduler/benchmark/topology/BuildExecutionGraphBenchmarkExecutor.java
@@ -19,7 +19,6 @@
package org.apache.flink.scheduler.benchmark.topology;
import org.apache.flink.runtime.scheduler.benchmark.JobConfiguration;
-import org.apache.flink.runtime.scheduler.benchmark.SchedulerBenchmarkUtils;
import
org.apache.flink.runtime.scheduler.benchmark.topology.BuildExecutionGraphBenchmark;
import org.apache.flink.scheduler.benchmark.SchedulerBenchmarkExecutorBase;
