You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2021/10/14 08:22:49 UTC
[flink-benchmarks] 01/02: [hotfix] Reformat
CheckpointingTimeBenchmark
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-benchmarks.git
commit 165e7b2065cac38e9e65a5cce548398c126b04f7
Author: Piotr Nowojski <pi...@gmail.com>
AuthorDate: Wed Oct 13 12:27:20 2021 +0200
[hotfix] Reformat CheckpointingTimeBenchmark
---
.../java/org/apache/flink/benchmark/CheckpointingTimeBenchmark.java | 2 --
1 file changed, 2 deletions(-)
diff --git a/src/main/java/org/apache/flink/benchmark/CheckpointingTimeBenchmark.java b/src/main/java/org/apache/flink/benchmark/CheckpointingTimeBenchmark.java
index a56b4fa..631ac89 100644
--- a/src/main/java/org/apache/flink/benchmark/CheckpointingTimeBenchmark.java
+++ b/src/main/java/org/apache/flink/benchmark/CheckpointingTimeBenchmark.java
@@ -18,13 +18,11 @@
package org.apache.flink.benchmark;
-import org.apache.flink.api.common.JobID;
import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.benchmark.operators.RecordSource;
import org.apache.flink.configuration.MemorySize;
import org.apache.flink.runtime.jobgraph.JobVertexID;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
-import org.apache.flink.streaming.api.functions.sink.SinkFunction;
import org.apache.flink.streaming.api.graph.StreamGraph;
import org.openjdk.jmh.annotations.Benchmark;