From eedfb6fdb412d7f0eb40cfe6fe01786da6d804be Mon Sep 17 00:00:00 2001 From: gintarasm Date: Tue, 6 Feb 2024 16:10:56 +0200 Subject: [PATCH] chore: remove unused imports --- .../bigquery/sink/defaultStream/BigQueryDefaultSinkWriter.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/src/main/java/com/vinted/flink/bigquery/sink/defaultStream/BigQueryDefaultSinkWriter.java b/src/main/java/com/vinted/flink/bigquery/sink/defaultStream/BigQueryDefaultSinkWriter.java index 44e6abe..fe9763d 100644 --- a/src/main/java/com/vinted/flink/bigquery/sink/defaultStream/BigQueryDefaultSinkWriter.java +++ b/src/main/java/com/vinted/flink/bigquery/sink/defaultStream/BigQueryDefaultSinkWriter.java @@ -12,14 +12,11 @@ import com.vinted.flink.bigquery.sink.ExecutorProvider; import io.grpc.Status; import org.apache.flink.api.connector.sink2.Sink; -import org.apache.flink.metrics.Counter; -import org.apache.flink.metrics.Gauge; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.util.Optional; import java.util.concurrent.Phaser; -import java.util.function.Function; public abstract class BigQueryDefaultSinkWriter extends BigQuerySinkWriter {