diff --git a/core/src/main/java/kafka/automq/backpressure/DefaultBackPressureManager.java b/core/src/main/java/kafka/automq/backpressure/DefaultBackPressureManager.java index 5321670302..3a95a98be3 100644 --- a/core/src/main/java/kafka/automq/backpressure/DefaultBackPressureManager.java +++ b/core/src/main/java/kafka/automq/backpressure/DefaultBackPressureManager.java @@ -16,13 +16,15 @@ import com.automq.stream.utils.ThreadUtils; import com.automq.stream.utils.Threads; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + import java.util.HashMap; import java.util.Map; import java.util.Set; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; import static kafka.automq.backpressure.BackPressureConfig.RECONFIGURABLE_CONFIGS; diff --git a/core/src/main/scala/kafka/log/stream/s3/DefaultS3Client.java b/core/src/main/scala/kafka/log/stream/s3/DefaultS3Client.java index 716a3adfbb..2b17455c4f 100644 --- a/core/src/main/scala/kafka/log/stream/s3/DefaultS3Client.java +++ b/core/src/main/scala/kafka/log/stream/s3/DefaultS3Client.java @@ -11,9 +11,6 @@ package kafka.log.stream.s3; -import com.automq.stream.s3.backpressure.BackPressureManager; -import com.automq.stream.s3.backpressure.DefaultBackPressureManager; -import com.automq.stream.s3.backpressure.Regulator; import kafka.autobalancer.metricsreporter.metric.Derivator; import kafka.log.stream.s3.metadata.StreamMetadataManager; import kafka.log.stream.s3.network.ControllerRequestSender; diff --git a/s3stream/src/main/java/com/automq/stream/utils/ThreadUtils.java b/s3stream/src/main/java/com/automq/stream/utils/ThreadUtils.java index 5619311bff..805253b5e0 100644 --- a/s3stream/src/main/java/com/automq/stream/utils/ThreadUtils.java +++ b/s3stream/src/main/java/com/automq/stream/utils/ThreadUtils.java @@ -11,13 +11,15 @@ package com.automq.stream.utils; -import io.netty.util.concurrent.FastThreadLocalThread; +import org.slf4j.Logger; +import org.slf4j.helpers.NOPLogger; + import java.util.concurrent.ExecutorService; import java.util.concurrent.ThreadFactory; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicLong; -import org.slf4j.Logger; -import org.slf4j.helpers.NOPLogger; + +import io.netty.util.concurrent.FastThreadLocalThread; /** * Utilities for working with threads.