spotless:apply

XComp · Aug 28, 2024 · 95dc61d · 95dc61d
1 parent 3879c14
commit 95dc61d
Show file tree

Hide file tree

Showing 13 changed files with 17 additions and 13 deletions.
diff --git a/...onnector-base/src/test/java/org/apache/flink/connector/base/sink/AsyncSinkBaseITCase.java b/...onnector-base/src/test/java/org/apache/flink/connector/base/sink/AsyncSinkBaseITCase.java
@@ -18,7 +18,6 @@
 package org.apache.flink.connector.base.sink;
 
 import org.apache.flink.api.common.restartstrategy.RestartStrategies;
-import java.time.Duration;
 import org.apache.flink.runtime.client.JobExecutionException;
 import org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
@@ -29,6 +28,8 @@
 import org.junit.jupiter.api.extension.ExtendWith;
 import org.junit.jupiter.api.extension.RegisterExtension;
 
+import java.time.Duration;
+
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
 
 /** Integration tests of a baseline generic sink that implements the AsyncSinkBase. */

diff --git a/...c/test/java/org/apache/flink/streaming/connectors/wikiedits/WikipediaEditsSourceTest.java b/...c/test/java/org/apache/flink/streaming/connectors/wikiedits/WikipediaEditsSourceTest.java
@@ -18,7 +18,6 @@
 
 package org.apache.flink.streaming.connectors.wikiedits;
 
-import java.time.Duration;
 import org.apache.flink.streaming.api.functions.source.SourceFunction;
 import org.apache.flink.streaming.api.watermark.Watermark;
 import org.apache.flink.testutils.junit.RetryOnFailure;
@@ -31,6 +30,7 @@
 
 import java.net.InetSocketAddress;
 import java.net.Socket;
+import java.time.Duration;
 import java.util.Objects;
 import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.BlockingQueue;

diff --git a/...nk-file-sink-test/src/main/java/org/apache/flink/connector/file/sink/FileSinkProgram.java b/...nk-file-sink-test/src/main/java/org/apache/flink/connector/file/sink/FileSinkProgram.java
@@ -22,7 +22,6 @@
 import org.apache.flink.api.common.serialization.Encoder;
 import org.apache.flink.api.common.state.ListState;
 import org.apache.flink.api.common.state.ListStateDescriptor;
-import java.time.Duration;
 import org.apache.flink.api.common.typeutils.base.IntSerializer;
 import org.apache.flink.api.java.tuple.Tuple2;
 import org.apache.flink.api.java.utils.ParameterTool;
@@ -40,6 +39,7 @@
 import org.apache.flink.streaming.api.functions.source.SourceFunction;
 
 import java.io.PrintStream;
+import java.time.Duration;
 import java.util.Collections;
 
 /**

diff --git a/...k-stream-state-ttl-test/src/main/java/org/apache/flink/streaming/tests/TtlTestConfig.java b/...k-stream-state-ttl-test/src/main/java/org/apache/flink/streaming/tests/TtlTestConfig.java
@@ -18,11 +18,12 @@
 
 package org.apache.flink.streaming.tests;
 
-import java.time.Duration;
 import org.apache.flink.api.java.utils.ParameterTool;
 import org.apache.flink.configuration.ConfigOption;
 import org.apache.flink.configuration.ConfigOptions;
 
+import java.time.Duration;
+
 class TtlTestConfig {
     private static final ConfigOption<Integer> UPDATE_GENERATOR_SRC_KEYSPACE =
             ConfigOptions.key("update_generator_source.keyspace").intType().defaultValue(100);

diff --git a/flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/RpcUtils.java b/flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/RpcUtils.java
@@ -19,13 +19,13 @@
 package org.apache.flink.runtime.rpc;
 
 import org.apache.flink.annotation.VisibleForTesting;
-import java.time.Duration;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.util.AutoCloseableAsync;
 import org.apache.flink.util.concurrent.FutureUtils;
 
 import javax.annotation.Nullable;
 
+import java.time.Duration;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collection;

diff --git a/...va/org/apache/flink/state/changelog/ChangelogDelegateEmbeddedRocksDBStateBackendTest.java b/...va/org/apache/flink/state/changelog/ChangelogDelegateEmbeddedRocksDBStateBackendTest.java
@@ -19,7 +19,6 @@
 package org.apache.flink.state.changelog;
 
 import org.apache.flink.api.common.state.StateTtlConfig;
-import java.time.Duration;
 import org.apache.flink.api.common.typeutils.TypeSerializer;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.configuration.StateLatencyTrackOptions;
@@ -40,6 +39,7 @@
 
 import java.io.IOException;
 import java.nio.file.Path;
+import java.time.Duration;
 
 /** Tests for {@link ChangelogStateBackend} delegating {@link EmbeddedRocksDBStateBackend}. */
 public class ChangelogDelegateEmbeddedRocksDBStateBackendTest

diff --git a/...src/test/java/org/apache/flink/state/changelog/ChangelogDelegateFileStateBackendTest.java b/...src/test/java/org/apache/flink/state/changelog/ChangelogDelegateFileStateBackendTest.java
@@ -19,7 +19,6 @@
 package org.apache.flink.state.changelog;
 
 import org.apache.flink.api.common.state.StateTtlConfig;
-import java.time.Duration;
 import org.apache.flink.api.common.typeutils.TypeSerializer;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.configuration.StateLatencyTrackOptions;
@@ -41,6 +40,7 @@
 
 import java.io.IOException;
 import java.nio.file.Path;
+import java.time.Duration;
 
 /** Tests for {@link ChangelogStateBackend} delegating {@link FsStateBackend}. */
 public class ChangelogDelegateFileStateBackendTest extends FileStateBackendTest {

diff --git a/...hangelog/src/test/java/org/apache/flink/state/changelog/ChangelogDelegateHashMapTest.java b/...hangelog/src/test/java/org/apache/flink/state/changelog/ChangelogDelegateHashMapTest.java
@@ -19,7 +19,6 @@
 package org.apache.flink.state.changelog;
 
 import org.apache.flink.api.common.state.StateTtlConfig;
-import java.time.Duration;
 import org.apache.flink.api.common.typeutils.TypeSerializer;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.configuration.StateLatencyTrackOptions;
@@ -38,6 +37,7 @@
 
 import java.io.IOException;
 import java.nio.file.Path;
+import java.time.Duration;
 
 /** Tests for {@link ChangelogStateBackend} delegating {@link HashMapStateBackendTest}. */
 public class ChangelogDelegateHashMapTest extends HashMapStateBackendTest {

diff --git a/...c/test/java/org/apache/flink/state/changelog/ChangelogDelegateMemoryStateBackendTest.java b/...c/test/java/org/apache/flink/state/changelog/ChangelogDelegateMemoryStateBackendTest.java
@@ -19,7 +19,6 @@
 package org.apache.flink.state.changelog;
 
 import org.apache.flink.api.common.state.StateTtlConfig;
-import java.time.Duration;
 import org.apache.flink.api.common.typeutils.TypeSerializer;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.configuration.StateLatencyTrackOptions;
@@ -41,6 +40,7 @@
 
 import java.io.IOException;
 import java.nio.file.Path;
+import java.time.Duration;
 
 /** Tests for {@link ChangelogStateBackend} delegating {@link MemoryStateBackend}. */
 public class ChangelogDelegateMemoryStateBackendTest extends MemoryStateBackendTest {

diff --git a/.../main/java/org/apache/flink/table/gateway/rest/handler/AbstractSqlGatewayRestHandler.java b/.../main/java/org/apache/flink/table/gateway/rest/handler/AbstractSqlGatewayRestHandler.java
@@ -18,7 +18,6 @@
 
 package org.apache.flink.table.gateway.rest.handler;
 
-import java.time.Duration;
 import org.apache.flink.runtime.rest.handler.AbstractHandler;
 import org.apache.flink.runtime.rest.handler.HandlerRequest;
 import org.apache.flink.runtime.rest.handler.RestHandlerException;
@@ -39,6 +38,7 @@
 import javax.annotation.Nonnull;
 import javax.annotation.Nullable;
 
+import java.time.Duration;
 import java.util.Map;
 import java.util.concurrent.CompletableFuture;
 

diff --git a/...link-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/RestAPIITCaseBase.java b/...link-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/RestAPIITCaseBase.java
@@ -18,7 +18,6 @@
 
 package org.apache.flink.table.gateway.rest;
 
-import java.time.Duration;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.runtime.rest.messages.MessageHeaders;
 import org.apache.flink.runtime.rest.messages.MessageParameters;
@@ -38,6 +37,7 @@
 import java.io.IOException;
 import java.net.InetAddress;
 import java.net.InetSocketAddress;
+import java.time.Duration;
 import java.util.concurrent.CompletableFuture;
 
 import static org.apache.flink.table.gateway.rest.util.SqlGatewayRestEndpointTestUtils.getBaseConfig;

diff --git a/...apache/flink/table/runtime/operators/deduplicate/ProcTimeDeduplicateFunctionTestBase.java b/...apache/flink/table/runtime/operators/deduplicate/ProcTimeDeduplicateFunctionTestBase.java
@@ -18,7 +18,6 @@
 
 package org.apache.flink.table.runtime.operators.deduplicate;
 
-import java.time.Duration;
 import org.apache.flink.table.data.RowData;
 import org.apache.flink.table.runtime.generated.GeneratedRecordEqualiser;
 import org.apache.flink.table.runtime.generated.RecordEqualiser;
@@ -32,6 +31,8 @@
 import org.apache.flink.table.types.logical.VarCharType;
 import org.apache.flink.table.utils.HandwrittenSelectorUtil;
 
+import java.time.Duration;
+
 /** Base class of tests for all kinds of processing-time DeduplicateFunction. */
 abstract class ProcTimeDeduplicateFunctionTestBase {
 

diff --git a/.../apache/flink/table/runtime/operators/deduplicate/RowTimeDeduplicateFunctionTestBase.java b/.../apache/flink/table/runtime/operators/deduplicate/RowTimeDeduplicateFunctionTestBase.java
@@ -18,7 +18,6 @@
 
 package org.apache.flink.table.runtime.operators.deduplicate;
 
-import java.time.Duration;
 import org.apache.flink.api.common.typeutils.TypeSerializer;
 import org.apache.flink.streaming.api.operators.KeyedProcessOperator;
 import org.apache.flink.streaming.util.KeyedOneInputStreamOperatorTestHarness;
@@ -34,6 +33,8 @@
 import org.apache.flink.table.types.logical.VarCharType;
 import org.apache.flink.table.utils.HandwrittenSelectorUtil;
 
+import java.time.Duration;
+
 /** Base class of tests for all kinds of row-time DeduplicateFunction. */
 abstract class RowTimeDeduplicateFunctionTestBase {