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;