This is an automated email from the ASF dual-hosted git repository.
duanzhengqiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 2e4b80d370f Remove useless @Slf4j (#21587)
2e4b80d370f is described below
commit 2e4b80d370f4e0c63755a7f5878586f6e1af76cb
Author: Liang Zhang <[email protected]>
AuthorDate: Sat Oct 15 23:49:00 2022 +0800
Remove useless @Slf4j (#21587)
---
.../shardingsphere/agent/metrics/api/advice/ChannelHandlerAdvice.java | 2 --
.../agent/metrics/prometheus/wrapper/PrometheusWrapperFactory.java | 2 --
.../db/protocol/mysql/packet/binlog/AbstractMySQLBinlogEventPacket.java | 2 --
.../mysql/type/MGRMySQLDatabaseDiscoveryProviderAlgorithm.java | 2 --
.../type/MySQLNormalReplicationDatabaseDiscoveryProviderAlgorithm.java | 2 --
.../OpenGaussNormalReplicationDatabaseDiscoveryProviderAlgorithm.java | 2 --
.../distsql/handler/update/DropMigrationSourceResourceUpdater.java | 2 --
.../data/pipeline/api/config/job/ConsistencyCheckJobConfiguration.java | 2 --
.../data/pipeline/api/config/job/MigrationJobConfiguration.java | 2 --
.../core/context/AbstractInventoryIncrementalProcessContext.java | 2 --
.../data/pipeline/core/execute/ShardingSphereDataScheduleCollector.java | 2 +-
.../core/ingest/channel/memory/MultiplexMemoryPipelineChannel.java | 2 --
.../shardingsphere/data/pipeline/core/job/AbstractPipelineJob.java | 2 --
.../data/pipeline/core/metadata/node/PipelineMetaDataNodeWatcher.java | 2 --
.../node/event/handler/impl/BarrierMetaDataChangedEventHandler.java | 2 --
.../data/pipeline/core/prepare/InventoryTaskSplitter.java | 2 +-
.../scenario/consistencycheck/ConsistencyCheckJobItemContext.java | 2 --
.../pipeline/scenario/migration/MigrationDataConsistencyChecker.java | 2 --
.../data/pipeline/scenario/migration/MigrationJobItemContext.java | 2 --
.../data/pipeline/scenario/migration/MigrationProcessContext.java | 2 --
.../data/pipeline/opengauss/ingest/OpenGaussWalDumper.java | 2 --
.../data/pipeline/postgresql/ingest/PostgreSQLWalDumper.java | 2 --
.../shardingsphere/schedule/core/context/ClusterScheduleContext.java | 2 --
.../shardingsphere/mode/repository/cluster/etcd/EtcdRepository.java | 2 --
.../backend/handler/distsql/rdl/rule/RuleDefinitionBackendHandler.java | 2 --
.../proxy/frontend/reactive/command/ReactiveCommandExecuteTask.java | 2 +-
26 files changed, 3 insertions(+), 49 deletions(-)
diff --git
a/agent/plugins/metrics/api/src/main/java/org/apache/shardingsphere/agent/metrics/api/advice/ChannelHandlerAdvice.java
b/agent/plugins/metrics/api/src/main/java/org/apache/shardingsphere/agent/metrics/api/advice/ChannelHandlerAdvice.java
index 45d45d0233c..a587673678e 100644
---
a/agent/plugins/metrics/api/src/main/java/org/apache/shardingsphere/agent/metrics/api/advice/ChannelHandlerAdvice.java
+++
b/agent/plugins/metrics/api/src/main/java/org/apache/shardingsphere/agent/metrics/api/advice/ChannelHandlerAdvice.java
@@ -17,7 +17,6 @@
package org.apache.shardingsphere.agent.metrics.api.advice;
-import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.agent.api.advice.AdviceTargetObject;
import org.apache.shardingsphere.agent.api.advice.InstanceMethodAroundAdvice;
import org.apache.shardingsphere.agent.api.result.MethodInvocationResult;
@@ -30,7 +29,6 @@ import java.lang.reflect.Method;
/**
* Channel handler advice.
*/
-@Slf4j
public final class ChannelHandlerAdvice implements InstanceMethodAroundAdvice {
public static final String CHANNEL_READ = "channelRead";
diff --git
a/agent/plugins/metrics/prometheus/src/main/java/org/apache/shardingsphere/agent/metrics/prometheus/wrapper/PrometheusWrapperFactory.java
b/agent/plugins/metrics/prometheus/src/main/java/org/apache/shardingsphere/agent/metrics/prometheus/wrapper/PrometheusWrapperFactory.java
index e43a7f023a1..e65978b6028 100644
---
a/agent/plugins/metrics/prometheus/src/main/java/org/apache/shardingsphere/agent/metrics/prometheus/wrapper/PrometheusWrapperFactory.java
+++
b/agent/plugins/metrics/prometheus/src/main/java/org/apache/shardingsphere/agent/metrics/prometheus/wrapper/PrometheusWrapperFactory.java
@@ -22,7 +22,6 @@ import io.prometheus.client.Gauge;
import io.prometheus.client.GaugeMetricFamily;
import io.prometheus.client.Histogram;
import io.prometheus.client.Summary;
-import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.agent.metrics.api.MetricsWrapper;
import org.apache.shardingsphere.agent.metrics.api.MetricsWrapperFactory;
import org.yaml.snakeyaml.Yaml;
@@ -36,7 +35,6 @@ import java.util.Optional;
/**
* Prometheus metrics wrapper factory.
*/
-@Slf4j
public class PrometheusWrapperFactory implements MetricsWrapperFactory {
private static List<Map<String, Object>> metrics;
diff --git
a/db-protocol/mysql/src/main/java/org/apache/shardingsphere/db/protocol/mysql/packet/binlog/AbstractMySQLBinlogEventPacket.java
b/db-protocol/mysql/src/main/java/org/apache/shardingsphere/db/protocol/mysql/packet/binlog/AbstractMySQLBinlogEventPacket.java
index e87533c9c12..cde3274c0ae 100644
---
a/db-protocol/mysql/src/main/java/org/apache/shardingsphere/db/protocol/mysql/packet/binlog/AbstractMySQLBinlogEventPacket.java
+++
b/db-protocol/mysql/src/main/java/org/apache/shardingsphere/db/protocol/mysql/packet/binlog/AbstractMySQLBinlogEventPacket.java
@@ -20,7 +20,6 @@ package
org.apache.shardingsphere.db.protocol.mysql.packet.binlog;
import lombok.AccessLevel;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.db.protocol.mysql.packet.MySQLPacket;
import org.apache.shardingsphere.db.protocol.mysql.payload.MySQLPacketPayload;
@@ -29,7 +28,6 @@ import
org.apache.shardingsphere.db.protocol.mysql.payload.MySQLPacketPayload;
*/
@RequiredArgsConstructor(access = AccessLevel.PROTECTED)
@Getter
-@Slf4j
public abstract class AbstractMySQLBinlogEventPacket implements MySQLPacket,
MySQLBinlogEventPacket {
private final MySQLBinlogEventHeader binlogEventHeader;
diff --git
a/features/db-discovery/provider/mysql/src/main/java/org/apache/shardingsphere/dbdiscovery/mysql/type/MGRMySQLDatabaseDiscoveryProviderAlgorithm.java
b/features/db-discovery/provider/mysql/src/main/java/org/apache/shardingsphere/dbdiscovery/mysql/type/MGRMySQLDatabaseDiscoveryProviderAlgorithm.java
index 3a73b84b229..d36dfab242d 100644
---
a/features/db-discovery/provider/mysql/src/main/java/org/apache/shardingsphere/dbdiscovery/mysql/type/MGRMySQLDatabaseDiscoveryProviderAlgorithm.java
+++
b/features/db-discovery/provider/mysql/src/main/java/org/apache/shardingsphere/dbdiscovery/mysql/type/MGRMySQLDatabaseDiscoveryProviderAlgorithm.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.dbdiscovery.mysql.type;
import lombok.Getter;
-import lombok.extern.slf4j.Slf4j;
import
org.apache.shardingsphere.dbdiscovery.mysql.exception.mgr.InvalidMGRGroupNameConfigurationException;
import
org.apache.shardingsphere.dbdiscovery.mysql.exception.mgr.InvalidMGRModeException;
import
org.apache.shardingsphere.dbdiscovery.mysql.exception.mgr.InvalidMGRPluginException;
@@ -47,7 +46,6 @@ import java.util.concurrent.ExecutorService;
* MGR database discovery provider algorithm for MySQL.
*/
@Getter
-@Slf4j
public final class MGRMySQLDatabaseDiscoveryProviderAlgorithm implements
DatabaseDiscoveryProviderAlgorithm {
private static final String QUERY_PLUGIN_STATUS = "SELECT PLUGIN_STATUS
FROM information_schema.PLUGINS WHERE PLUGIN_NAME='group_replication'";
diff --git
a/features/db-discovery/provider/mysql/src/main/java/org/apache/shardingsphere/dbdiscovery/mysql/type/MySQLNormalReplicationDatabaseDiscoveryProviderAlgorithm.java
b/features/db-discovery/provider/mysql/src/main/java/org/apache/shardingsphere/dbdiscovery/mysql/type/MySQLNormalReplicationDatabaseDiscoveryProviderAlgorithm.java
index aaa15b48bae..cbce85f6079 100644
---
a/features/db-discovery/provider/mysql/src/main/java/org/apache/shardingsphere/dbdiscovery/mysql/type/MySQLNormalReplicationDatabaseDiscoveryProviderAlgorithm.java
+++
b/features/db-discovery/provider/mysql/src/main/java/org/apache/shardingsphere/dbdiscovery/mysql/type/MySQLNormalReplicationDatabaseDiscoveryProviderAlgorithm.java
@@ -19,7 +19,6 @@ package org.apache.shardingsphere.dbdiscovery.mysql.type;
import com.google.common.base.Preconditions;
import lombok.Getter;
-import lombok.extern.slf4j.Slf4j;
import
org.apache.shardingsphere.dbdiscovery.spi.DatabaseDiscoveryProviderAlgorithm;
import org.apache.shardingsphere.dbdiscovery.spi.ReplicaDataSourceStatus;
import org.apache.shardingsphere.infra.executor.kernel.ExecutorEngine;
@@ -41,7 +40,6 @@ import java.util.concurrent.ExecutorService;
* Normal replication database discovery provider algorithm for MySQL.
*/
@Getter
-@Slf4j
public final class MySQLNormalReplicationDatabaseDiscoveryProviderAlgorithm
implements DatabaseDiscoveryProviderAlgorithm {
private static final String SHOW_SLAVE_STATUS = "SHOW SLAVE STATUS";
diff --git
a/features/db-discovery/provider/opengauss/src/main/java/org/apache/shardingsphere/dbdiscovery/opengauss/OpenGaussNormalReplicationDatabaseDiscoveryProviderAlgorithm.java
b/features/db-discovery/provider/opengauss/src/main/java/org/apache/shardingsphere/dbdiscovery/opengauss/OpenGaussNormalReplicationDatabaseDiscoveryProviderAlgorithm.java
index a52641e900b..b6c96c7b9f6 100644
---
a/features/db-discovery/provider/opengauss/src/main/java/org/apache/shardingsphere/dbdiscovery/opengauss/OpenGaussNormalReplicationDatabaseDiscoveryProviderAlgorithm.java
+++
b/features/db-discovery/provider/opengauss/src/main/java/org/apache/shardingsphere/dbdiscovery/opengauss/OpenGaussNormalReplicationDatabaseDiscoveryProviderAlgorithm.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.dbdiscovery.opengauss;
import lombok.Getter;
-import lombok.extern.slf4j.Slf4j;
import
org.apache.shardingsphere.dbdiscovery.spi.DatabaseDiscoveryProviderAlgorithm;
import org.apache.shardingsphere.dbdiscovery.spi.ReplicaDataSourceStatus;
@@ -34,7 +33,6 @@ import java.util.Properties;
* Normal replication database discovery provider algorithm for openGauss.
*/
@Getter
-@Slf4j
public final class
OpenGaussNormalReplicationDatabaseDiscoveryProviderAlgorithm implements
DatabaseDiscoveryProviderAlgorithm {
private static final String QUERY_DB_ROLE = "SELECT local_role,db_state
FROM pg_stat_get_stream_replications()";
diff --git
a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/DropMigrationSourceResourceUpdater.java
b/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/DropMigrationSourceResourceUpdater.java
index 70a3f046b05..0c2ac35825a 100644
---
a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/DropMigrationSourceResourceUpdater.java
+++
b/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/DropMigrationSourceResourceUpdater.java
@@ -17,7 +17,6 @@
package org.apache.shardingsphere.migration.distsql.handler.update;
-import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI;
import org.apache.shardingsphere.data.pipeline.api.PipelineJobPublicAPIFactory;
import org.apache.shardingsphere.infra.distsql.update.RALUpdater;
@@ -26,7 +25,6 @@ import
org.apache.shardingsphere.migration.distsql.statement.DropMigrationSource
/**
* Drop migration source resource updater.
*/
-@Slf4j
public final class DropMigrationSourceResourceUpdater implements
RALUpdater<DropMigrationSourceResourceStatement> {
private static final MigrationJobPublicAPI JOB_API =
PipelineJobPublicAPIFactory.getMigrationJobPublicAPI();
diff --git
a/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/job/ConsistencyCheckJobConfiguration.java
b/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/job/ConsistencyCheckJobConfiguration.java
index b80eab65ee1..4661c75dc03 100644
---
a/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/job/ConsistencyCheckJobConfiguration.java
+++
b/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/job/ConsistencyCheckJobConfiguration.java
@@ -20,7 +20,6 @@ package
org.apache.shardingsphere.data.pipeline.api.config.job;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import lombok.ToString;
-import lombok.extern.slf4j.Slf4j;
import java.util.Properties;
@@ -29,7 +28,6 @@ import java.util.Properties;
*/
@RequiredArgsConstructor
@Getter
-@Slf4j
@ToString
public final class ConsistencyCheckJobConfiguration implements
PipelineJobConfiguration {
diff --git
a/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/job/MigrationJobConfiguration.java
b/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/job/MigrationJobConfiguration.java
index cb19ff443e6..15e6c0feeda 100644
---
a/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/job/MigrationJobConfiguration.java
+++
b/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/job/MigrationJobConfiguration.java
@@ -20,7 +20,6 @@ package
org.apache.shardingsphere.data.pipeline.api.config.job;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import lombok.ToString;
-import lombok.extern.slf4j.Slf4j;
import
org.apache.shardingsphere.data.pipeline.api.datasource.config.PipelineDataSourceConfiguration;
import
org.apache.shardingsphere.data.pipeline.api.metadata.model.PipelineColumnMetaData;
@@ -31,7 +30,6 @@ import java.util.List;
*/
@RequiredArgsConstructor
@Getter
-@Slf4j
@ToString(exclude = {"source", "target"})
public final class MigrationJobConfiguration implements
PipelineJobConfiguration {
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/context/AbstractInventoryIncrementalProcessContext.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/context/AbstractInventoryIncrementalProcessContext.java
index 54a43cb02af..f17fc8470da 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/context/AbstractInventoryIncrementalProcessContext.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/context/AbstractInventoryIncrementalProcessContext.java
@@ -19,7 +19,6 @@ package org.apache.shardingsphere.data.pipeline.core.context;
import lombok.Getter;
import lombok.SneakyThrows;
-import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.concurrent.ConcurrentException;
import org.apache.commons.lang3.concurrent.LazyInitializer;
import
org.apache.shardingsphere.data.pipeline.api.config.process.PipelineProcessConfiguration;
@@ -37,7 +36,6 @@ import
org.apache.shardingsphere.infra.config.algorithm.AlgorithmConfiguration;
* Abstract inventory incremental process context.
*/
@Getter
-@Slf4j
public abstract class AbstractInventoryIncrementalProcessContext implements
InventoryIncrementalProcessContext {
private final PipelineProcessConfiguration pipelineProcessConfig;
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/execute/ShardingSphereDataScheduleCollector.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/execute/ShardingSphereDataScheduleCollector.java
index d5304491f44..51fa0bbae87 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/execute/ShardingSphereDataScheduleCollector.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/execute/ShardingSphereDataScheduleCollector.java
@@ -44,8 +44,8 @@ import java.util.concurrent.TimeUnit;
/**
* ShardingSphere data schedule collector.
*/
-@Slf4j
@RequiredArgsConstructor
+@Slf4j
public final class ShardingSphereDataScheduleCollector {
private static final String SHARDING_SPHERE = "shardingsphere";
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/memory/MultiplexMemoryPipelineChannel.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/memory/MultiplexMemoryPipelineChannel.java
index cfa4831697c..61d0e9de301 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/memory/MultiplexMemoryPipelineChannel.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/memory/MultiplexMemoryPipelineChannel.java
@@ -17,7 +17,6 @@
package org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory;
-import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.data.pipeline.api.ingest.channel.AckCallback;
import
org.apache.shardingsphere.data.pipeline.api.ingest.channel.PipelineChannel;
import org.apache.shardingsphere.data.pipeline.api.ingest.record.DataRecord;
@@ -33,7 +32,6 @@ import java.util.Map;
/**
* Multiplex memory pipeline channel.
*/
-@Slf4j
public final class MultiplexMemoryPipelineChannel implements PipelineChannel {
private static final EmptyAckCallback EMPTY_ACK_CALLBACK = new
EmptyAckCallback();
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/AbstractPipelineJob.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/AbstractPipelineJob.java
index d48f4467a0c..c29e4310a55 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/AbstractPipelineJob.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/job/AbstractPipelineJob.java
@@ -19,7 +19,6 @@ package org.apache.shardingsphere.data.pipeline.core.job;
import lombok.Getter;
import lombok.Setter;
-import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.data.pipeline.api.job.PipelineJob;
import org.apache.shardingsphere.data.pipeline.api.task.PipelineTasksRunner;
import org.apache.shardingsphere.elasticjob.lite.api.bootstrap.JobBootstrap;
@@ -31,7 +30,6 @@ import java.util.concurrent.ConcurrentHashMap;
/**
* Abstract pipeline job.
*/
-@Slf4j
@Getter
public abstract class AbstractPipelineJob implements PipelineJob {
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/metadata/node/PipelineMetaDataNodeWatcher.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/metadata/node/PipelineMetaDataNodeWatcher.java
index 70326d46e58..1a34b0a9a41 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/metadata/node/PipelineMetaDataNodeWatcher.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/metadata/node/PipelineMetaDataNodeWatcher.java
@@ -17,7 +17,6 @@
package org.apache.shardingsphere.data.pipeline.core.metadata.node;
-import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.data.pipeline.core.api.PipelineAPIFactory;
import
org.apache.shardingsphere.data.pipeline.core.constant.DataPipelineConstants;
import
org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.PipelineMetaDataChangedEventHandler;
@@ -33,7 +32,6 @@ import java.util.regex.Pattern;
/**
* Pipeline meta data node watcher.
*/
-@Slf4j
public final class PipelineMetaDataNodeWatcher {
private static final PipelineMetaDataNodeWatcher INSTANCE = new
PipelineMetaDataNodeWatcher();
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/metadata/node/event/handler/impl/BarrierMetaDataChangedEventHandler.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/metadata/node/event/handler/impl/BarrierMetaDataChangedEventHandler.java
index 95d32aa87b4..cce22a41d9c 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/metadata/node/event/handler/impl/BarrierMetaDataChangedEventHandler.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/metadata/node/event/handler/impl/BarrierMetaDataChangedEventHandler.java
@@ -17,7 +17,6 @@
package
org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.impl;
-import lombok.extern.slf4j.Slf4j;
import
org.apache.shardingsphere.data.pipeline.core.metadata.node.PipelineMetaDataNode;
import
org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.PipelineMetaDataChangedEventHandler;
import
org.apache.shardingsphere.data.pipeline.core.util.PipelineDistributedBarrier;
@@ -29,7 +28,6 @@ import java.util.regex.Pattern;
/**
* Barrier meta data changed event handler.
*/
-@Slf4j
public final class BarrierMetaDataChangedEventHandler implements
PipelineMetaDataChangedEventHandler {
@Override
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/prepare/InventoryTaskSplitter.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/prepare/InventoryTaskSplitter.java
index f14e56d3e71..9cfcd247ca2 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/prepare/InventoryTaskSplitter.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/prepare/InventoryTaskSplitter.java
@@ -55,8 +55,8 @@ import java.util.List;
/**
* Inventory data task splitter.
*/
-@Slf4j
@RequiredArgsConstructor
+@Slf4j
public final class InventoryTaskSplitter {
private final PipelineDataSourceWrapper sourceDataSource;
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/ConsistencyCheckJobItemContext.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/ConsistencyCheckJobItemContext.java
index 7b812529dd6..c35ef0adae6 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/ConsistencyCheckJobItemContext.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/ConsistencyCheckJobItemContext.java
@@ -19,7 +19,6 @@ package
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck;
import lombok.Getter;
import lombok.Setter;
-import lombok.extern.slf4j.Slf4j;
import
org.apache.shardingsphere.data.pipeline.api.config.job.ConsistencyCheckJobConfiguration;
import
org.apache.shardingsphere.data.pipeline.api.context.PipelineJobItemContext;
import
org.apache.shardingsphere.data.pipeline.api.context.PipelineProcessContext;
@@ -36,7 +35,6 @@ import java.util.concurrent.atomic.AtomicLong;
*/
@Getter
@Setter
-@Slf4j
public final class ConsistencyCheckJobItemContext implements
PipelineJobItemContext, PipelineJobProgressListener {
private final String jobId;
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationDataConsistencyChecker.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationDataConsistencyChecker.java
index f6b97a2a455..88e5cc1fa59 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationDataConsistencyChecker.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationDataConsistencyChecker.java
@@ -17,7 +17,6 @@
package org.apache.shardingsphere.data.pipeline.scenario.migration;
-import lombok.extern.slf4j.Slf4j;
import
org.apache.shardingsphere.data.pipeline.api.check.consistency.DataConsistencyCheckResult;
import
org.apache.shardingsphere.data.pipeline.api.check.consistency.PipelineDataConsistencyChecker;
import
org.apache.shardingsphere.data.pipeline.api.config.TableNameSchemaNameMapping;
@@ -48,7 +47,6 @@ import java.util.Map;
/**
* Data consistency checker for migration job.
*/
-@Slf4j
public final class MigrationDataConsistencyChecker implements
PipelineDataConsistencyChecker {
private final MigrationJobConfiguration jobConfig;
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobItemContext.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobItemContext.java
index 35651826bd2..c5a5f2301ba 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobItemContext.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobItemContext.java
@@ -20,7 +20,6 @@ package
org.apache.shardingsphere.data.pipeline.scenario.migration;
import lombok.Getter;
import lombok.Setter;
import lombok.SneakyThrows;
-import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.concurrent.ConcurrentException;
import org.apache.commons.lang3.concurrent.LazyInitializer;
import
org.apache.shardingsphere.data.pipeline.api.config.job.MigrationJobConfiguration;
@@ -45,7 +44,6 @@ import java.util.concurrent.atomic.AtomicLong;
*/
@Getter
@Setter
-@Slf4j
public final class MigrationJobItemContext implements
InventoryIncrementalJobItemContext {
private final String jobId;
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationProcessContext.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationProcessContext.java
index 1122a40ecc0..7cdde29e4c1 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationProcessContext.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationProcessContext.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.data.pipeline.scenario.migration;
import lombok.Getter;
-import lombok.extern.slf4j.Slf4j;
import
org.apache.shardingsphere.data.pipeline.api.config.process.PipelineProcessConfiguration;
import
org.apache.shardingsphere.data.pipeline.core.context.AbstractInventoryIncrementalProcessContext;
@@ -26,7 +25,6 @@ import
org.apache.shardingsphere.data.pipeline.core.context.AbstractInventoryInc
* Migration process context.
*/
@Getter
-@Slf4j
public final class MigrationProcessContext extends
AbstractInventoryIncrementalProcessContext {
/**
diff --git
a/kernel/data-pipeline/dialect/opengauss/src/main/java/org/apache/shardingsphere/data/pipeline/opengauss/ingest/OpenGaussWalDumper.java
b/kernel/data-pipeline/dialect/opengauss/src/main/java/org/apache/shardingsphere/data/pipeline/opengauss/ingest/OpenGaussWalDumper.java
index 247a48bab72..2f95e72aa3d 100644
---
a/kernel/data-pipeline/dialect/opengauss/src/main/java/org/apache/shardingsphere/data/pipeline/opengauss/ingest/OpenGaussWalDumper.java
+++
b/kernel/data-pipeline/dialect/opengauss/src/main/java/org/apache/shardingsphere/data/pipeline/opengauss/ingest/OpenGaussWalDumper.java
@@ -17,7 +17,6 @@
package org.apache.shardingsphere.data.pipeline.opengauss.ingest;
-import lombok.extern.slf4j.Slf4j;
import
org.apache.shardingsphere.data.pipeline.api.config.ingest.DumperConfiguration;
import
org.apache.shardingsphere.data.pipeline.api.datasource.config.impl.StandardPipelineDataSourceConfiguration;
import
org.apache.shardingsphere.data.pipeline.api.executor.AbstractLifecycleExecutor;
@@ -46,7 +45,6 @@ import java.sql.SQLException;
/**
* WAL dumper of openGauss.
*/
-@Slf4j
public final class OpenGaussWalDumper extends AbstractLifecycleExecutor
implements IncrementalDumper {
private final DumperConfiguration dumperConfig;
diff --git
a/kernel/data-pipeline/dialect/postgresql/src/main/java/org/apache/shardingsphere/data/pipeline/postgresql/ingest/PostgreSQLWalDumper.java
b/kernel/data-pipeline/dialect/postgresql/src/main/java/org/apache/shardingsphere/data/pipeline/postgresql/ingest/PostgreSQLWalDumper.java
index 9a30a945909..39751a70b96 100644
---
a/kernel/data-pipeline/dialect/postgresql/src/main/java/org/apache/shardingsphere/data/pipeline/postgresql/ingest/PostgreSQLWalDumper.java
+++
b/kernel/data-pipeline/dialect/postgresql/src/main/java/org/apache/shardingsphere/data/pipeline/postgresql/ingest/PostgreSQLWalDumper.java
@@ -17,7 +17,6 @@
package org.apache.shardingsphere.data.pipeline.postgresql.ingest;
-import lombok.extern.slf4j.Slf4j;
import
org.apache.shardingsphere.data.pipeline.api.config.ingest.DumperConfiguration;
import
org.apache.shardingsphere.data.pipeline.api.datasource.config.impl.StandardPipelineDataSourceConfiguration;
import
org.apache.shardingsphere.data.pipeline.api.executor.AbstractLifecycleExecutor;
@@ -47,7 +46,6 @@ import java.sql.SQLException;
/**
* PostgreSQL WAL dumper.
*/
-@Slf4j
public final class PostgreSQLWalDumper extends AbstractLifecycleExecutor
implements IncrementalDumper {
private final DumperConfiguration dumperConfig;
diff --git
a/kernel/schedule/core/src/main/java/org/apache/shardingsphere/schedule/core/context/ClusterScheduleContext.java
b/kernel/schedule/core/src/main/java/org/apache/shardingsphere/schedule/core/context/ClusterScheduleContext.java
index 53d7052220c..374fa99403b 100644
---
a/kernel/schedule/core/src/main/java/org/apache/shardingsphere/schedule/core/context/ClusterScheduleContext.java
+++
b/kernel/schedule/core/src/main/java/org/apache/shardingsphere/schedule/core/context/ClusterScheduleContext.java
@@ -20,7 +20,6 @@ package org.apache.shardingsphere.schedule.core.context;
import com.google.common.base.Preconditions;
import lombok.RequiredArgsConstructor;
import lombok.SneakyThrows;
-import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.concurrent.ConcurrentException;
import org.apache.commons.lang3.concurrent.LazyInitializer;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
@@ -43,7 +42,6 @@ import java.util.function.Consumer;
* Cluster schedule context.
*/
@RequiredArgsConstructor
-@Slf4j
public final class ClusterScheduleContext implements ScheduleContext {
private static final Map<String, ScheduleJobBootstrap>
SCHEDULE_JOB_BOOTSTRAP_MAP = new HashMap<>();
diff --git
a/mode/type/cluster/repository/provider/etcd/src/main/java/org/apache/shardingsphere/mode/repository/cluster/etcd/EtcdRepository.java
b/mode/type/cluster/repository/provider/etcd/src/main/java/org/apache/shardingsphere/mode/repository/cluster/etcd/EtcdRepository.java
index 13d0363db69..d7fe3656c27 100644
---
a/mode/type/cluster/repository/provider/etcd/src/main/java/org/apache/shardingsphere/mode/repository/cluster/etcd/EtcdRepository.java
+++
b/mode/type/cluster/repository/provider/etcd/src/main/java/org/apache/shardingsphere/mode/repository/cluster/etcd/EtcdRepository.java
@@ -30,7 +30,6 @@ import io.etcd.jetcd.options.WatchOption;
import io.etcd.jetcd.support.Observers;
import io.etcd.jetcd.watch.WatchEvent;
import lombok.SneakyThrows;
-import lombok.extern.slf4j.Slf4j;
import
org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;
import
org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepositoryConfiguration;
import
org.apache.shardingsphere.mode.repository.cluster.etcd.lock.EtcdInternalLockProvider;
@@ -49,7 +48,6 @@ import java.util.stream.Collectors;
/**
* Registry repository of ETCD.
*/
-@Slf4j
public final class EtcdRepository implements ClusterPersistRepository {
private Client client;
diff --git
a/proxy/backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/rule/RuleDefinitionBackendHandler.java
b/proxy/backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/rule/RuleDefinitionBackendHandler.java
index c98c5775eeb..ce2732ca909 100644
---
a/proxy/backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/rule/RuleDefinitionBackendHandler.java
+++
b/proxy/backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/rule/RuleDefinitionBackendHandler.java
@@ -17,7 +17,6 @@
package org.apache.shardingsphere.proxy.backend.handler.distsql.rdl.rule;
-import lombok.extern.slf4j.Slf4j;
import
org.apache.shardingsphere.distsql.parser.statement.rdl.RuleDefinitionStatement;
import org.apache.shardingsphere.infra.config.rule.RuleConfiguration;
import
org.apache.shardingsphere.infra.distsql.update.RuleDefinitionAlterUpdater;
@@ -44,7 +43,6 @@ import java.util.Optional;
*
* @param <T> type of SQL statement
*/
-@Slf4j
public final class RuleDefinitionBackendHandler<T extends
RuleDefinitionStatement> extends DatabaseRequiredBackendHandler<T> {
public RuleDefinitionBackendHandler(final T sqlStatement, final
ConnectionSession connectionSession) {
diff --git
a/proxy/frontend/reactive-core/src/main/java/org/apache/shardingsphere/proxy/frontend/reactive/command/ReactiveCommandExecuteTask.java
b/proxy/frontend/reactive-core/src/main/java/org/apache/shardingsphere/proxy/frontend/reactive/command/ReactiveCommandExecuteTask.java
index 81507aefb7e..e429fc33bf6 100644
---
a/proxy/frontend/reactive-core/src/main/java/org/apache/shardingsphere/proxy/frontend/reactive/command/ReactiveCommandExecuteTask.java
+++
b/proxy/frontend/reactive-core/src/main/java/org/apache/shardingsphere/proxy/frontend/reactive/command/ReactiveCommandExecuteTask.java
@@ -44,8 +44,8 @@ import java.util.Optional;
* Reactive command executor task.
*/
@SuppressWarnings("unchecked")
-@Slf4j
@RequiredArgsConstructor
+@Slf4j
public final class ReactiveCommandExecuteTask implements Runnable {
private final ReactiveDatabaseProtocolFrontendEngine
reactiveDatabaseProtocolFrontendEngine;
