This is an automated email from the ASF dual-hosted git repository.
panjuan 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 9d83f8b03b8 Rename ProcessSubscriber (#25453)
9d83f8b03b8 is described below
commit 9d83f8b03b8eacd2c0370605cbba61c0dbe316a1
Author: Liang Zhang <[email protected]>
AuthorDate: Thu May 4 22:19:41 2023 +0800
Rename ProcessSubscriber (#25453)
---
.../{ProcessListSubscriber.java => ProcessSubscriber.java} | 8 ++++----
.../process => process/event}/KillProcessRequestEvent.java | 2 +-
.../event}/ShowProcessListRequestEvent.java | 2 +-
.../event}/ShowProcessListResponseEvent.java | 2 +-
.../mode/manager/cluster/coordinator/RegistryCenter.java | 4 ++--
...ssListSubscriber.java => ClusterProcessSubscriber.java} | 14 +++++++-------
.../process/subscriber/ProcessListChangedSubscriber.java | 4 ++--
...bscriberTest.java => ClusterProcessSubscriberTest.java} | 8 ++++----
.../subscriber/ProcessListChangedSubscriberTest.java | 4 ++--
.../standalone/StandaloneContextManagerBuilder.java | 4 ++--
...istSubscriber.java => StandaloneProcessSubscriber.java} | 14 +++++++-------
...riberTest.java => StandaloneProcessSubscriberTest.java} | 6 +++---
.../mysql/handler/admin/executor/KillProcessExecutor.java | 2 +-
.../handler/admin/executor/ShowProcessListExecutor.java | 4 ++--
14 files changed, 39 insertions(+), 39 deletions(-)
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/process/ProcessListSubscriber.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/process/ProcessSubscriber.java
similarity index 87%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/process/ProcessListSubscriber.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/process/ProcessSubscriber.java
index 383a964a508..96fb755510c 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/process/ProcessListSubscriber.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/process/ProcessSubscriber.java
@@ -17,15 +17,15 @@
package org.apache.shardingsphere.mode.process;
-import org.apache.shardingsphere.mode.event.process.KillProcessRequestEvent;
-import
org.apache.shardingsphere.mode.event.process.ShowProcessListRequestEvent;
+import org.apache.shardingsphere.mode.process.event.KillProcessRequestEvent;
+import
org.apache.shardingsphere.mode.process.event.ShowProcessListRequestEvent;
import java.sql.SQLException;
/**
- * Processlist subscriber.
+ * Process subscriber.
*/
-public interface ProcessListSubscriber {
+public interface ProcessSubscriber {
/**
* Post show process list data.
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/process/KillProcessRequestEvent.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/process/event/KillProcessRequestEvent.java
similarity index 94%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/event/process/KillProcessRequestEvent.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/process/event/KillProcessRequestEvent.java
index 88291532d33..e69590c04cd 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/process/KillProcessRequestEvent.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/process/event/KillProcessRequestEvent.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.event.process;
+package org.apache.shardingsphere.mode.process.event;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/process/ShowProcessListRequestEvent.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/process/event/ShowProcessListRequestEvent.java
similarity index 94%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/event/process/ShowProcessListRequestEvent.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/process/event/ShowProcessListRequestEvent.java
index 7597631c8ee..289964b6287 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/process/ShowProcessListRequestEvent.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/process/event/ShowProcessListRequestEvent.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.event.process;
+package org.apache.shardingsphere.mode.process.event;
/**
* Show process list request event.
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/process/ShowProcessListResponseEvent.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/process/event/ShowProcessListResponseEvent.java
similarity index 95%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/event/process/ShowProcessListResponseEvent.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/process/event/ShowProcessListResponseEvent.java
index d13ddd10ba1..f3b44baf636 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/process/ShowProcessListResponseEvent.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/process/event/ShowProcessListResponseEvent.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.event.process;
+package org.apache.shardingsphere.mode.process.event;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/RegistryCenter.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/RegistryCenter.java
index d30d55b6b94..11f55122b52 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/RegistryCenter.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/RegistryCenter.java
@@ -35,7 +35,7 @@ import
org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.statu
import
org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.subscriber.ComputeNodeStatusSubscriber;
import
org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.storage.service.StorageNodeStatusService;
import
org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.storage.subscriber.StorageNodeStatusSubscriber;
-import
org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.process.subscriber.ClusterProcessListSubscriber;
+import
org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.process.subscriber.ClusterProcessSubscriber;
import
org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;
import
org.apache.shardingsphere.mode.repository.cluster.lock.holder.DistributedLockHolder;
import
org.apache.shardingsphere.mode.repository.cluster.lock.impl.props.DefaultLockTypedProperties;
@@ -99,7 +99,7 @@ public final class RegistryCenter {
new ComputeNodeStatusSubscriber(this, repository);
new ClusterStatusSubscriber(repository, eventBusContext);
new StorageNodeStatusSubscriber(repository, eventBusContext);
- new ClusterProcessListSubscriber(repository, eventBusContext);
+ new ClusterProcessSubscriber(repository, eventBusContext);
new ShardingSphereSchemaDataRegistrySubscriber(repository,
globalLockPersistService, eventBusContext);
}
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ClusterProcessListSubscriber.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ClusterProcessSubscriber.java
similarity index 90%
rename from
mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ClusterProcessListSubscriber.java
rename to
mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ClusterProcessSubscriber.java
index a5c06ffe1f3..8a354e05f51 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ClusterProcessListSubscriber.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ClusterProcessSubscriber.java
@@ -23,10 +23,10 @@ import
org.apache.shardingsphere.infra.instance.metadata.InstanceType;
import org.apache.shardingsphere.infra.util.eventbus.EventBusContext;
import org.apache.shardingsphere.metadata.persist.node.ComputeNode;
import org.apache.shardingsphere.metadata.persist.node.ProcessNode;
-import org.apache.shardingsphere.mode.event.process.KillProcessRequestEvent;
-import
org.apache.shardingsphere.mode.event.process.ShowProcessListRequestEvent;
-import
org.apache.shardingsphere.mode.event.process.ShowProcessListResponseEvent;
-import org.apache.shardingsphere.mode.process.ProcessListSubscriber;
+import org.apache.shardingsphere.mode.process.event.KillProcessRequestEvent;
+import
org.apache.shardingsphere.mode.process.event.ShowProcessListRequestEvent;
+import
org.apache.shardingsphere.mode.process.event.ShowProcessListResponseEvent;
+import org.apache.shardingsphere.mode.process.ProcessSubscriber;
import org.apache.shardingsphere.mode.spi.PersistRepository;
import java.util.Collection;
@@ -36,16 +36,16 @@ import java.util.stream.Collectors;
import java.util.stream.Stream;
/**
- * Cluster processlist subscriber.
+ * Cluster process subscriber.
*/
@SuppressWarnings("UnstableApiUsage")
-public final class ClusterProcessListSubscriber implements
ProcessListSubscriber {
+public final class ClusterProcessSubscriber implements ProcessSubscriber {
private final PersistRepository repository;
private final EventBusContext eventBusContext;
- public ClusterProcessListSubscriber(final PersistRepository repository,
final EventBusContext eventBusContext) {
+ public ClusterProcessSubscriber(final PersistRepository repository, final
EventBusContext eventBusContext) {
this.repository = repository;
this.eventBusContext = eventBusContext;
eventBusContext.register(this);
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ProcessListChangedSubscriber.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ProcessListChangedSubscriber.java
index 525384d432f..0213e98375e 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ProcessListChangedSubscriber.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ProcessListChangedSubscriber.java
@@ -103,12 +103,12 @@ public final class ProcessListChangedSubscriber {
}
/**
- * Complete to kill process instance.
+ * Complete to kill process.
*
* @param event kill process completed event
*/
@Subscribe
- public synchronized void completeToKillProcessInstance(final
KillProcessCompletedEvent event) {
+ public synchronized void completeToKillProcess(final
KillProcessCompletedEvent event) {
ProcessOperationLockRegistry.getInstance().notify(event.getProcessId());
}
}
diff --git
a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ClusterProcessListSubscriberTest.java
b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ClusterProcessSubscriberTest.java
similarity index 89%
rename from
mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ClusterProcessListSubscriberTest.java
rename to
mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ClusterProcessSubscriberTest.java
index 77be537b9a1..6f3ce36b9c6 100644
---
a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ClusterProcessListSubscriberTest.java
+++
b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ClusterProcessSubscriberTest.java
@@ -20,7 +20,7 @@ package
org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.proc
import org.apache.shardingsphere.infra.instance.metadata.InstanceType;
import org.apache.shardingsphere.infra.util.eventbus.EventBusContext;
import org.apache.shardingsphere.metadata.persist.node.ComputeNode;
-import
org.apache.shardingsphere.mode.event.process.ShowProcessListRequestEvent;
+import
org.apache.shardingsphere.mode.process.event.ShowProcessListRequestEvent;
import
org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
@@ -35,18 +35,18 @@ import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;
@ExtendWith(MockitoExtension.class)
-class ClusterProcessListSubscriberTest {
+class ClusterProcessSubscriberTest {
@Mock
private ClusterPersistRepository repository;
private final EventBusContext eventBusContext = new EventBusContext();
- private ClusterProcessListSubscriber clusterProcessListSubscriber;
+ private ClusterProcessSubscriber clusterProcessListSubscriber;
@BeforeEach
void setUp() {
- clusterProcessListSubscriber = new
ClusterProcessListSubscriber(repository, eventBusContext);
+ clusterProcessListSubscriber = new
ClusterProcessSubscriber(repository, eventBusContext);
}
@Test
diff --git
a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ProcessListChangedSubscriberTest.java
b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ProcessListChangedSubscriberTest.java
index cf49450d8e9..e57eac3c54b 100644
---
a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ProcessListChangedSubscriberTest.java
+++
b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/ProcessListChangedSubscriberTest.java
@@ -143,7 +143,7 @@ class ProcessListChangedSubscriberTest {
}
@Test
- void assertCompleteToKillProcessInstance() {
+ void assertCompleteToKillProcess() {
String processId = "foo_id";
long startMillis = System.currentTimeMillis();
Executors.newFixedThreadPool(1).submit(() -> {
@@ -151,7 +151,7 @@ class ProcessListChangedSubscriberTest {
Thread.sleep(50L);
} catch (final InterruptedException ignored) {
}
- subscriber.completeToKillProcessInstance(new
KillProcessCompletedEvent(processId));
+ subscriber.completeToKillProcess(new
KillProcessCompletedEvent(processId));
});
waitUntilReleaseReady(processId);
long currentMillis = System.currentTimeMillis();
diff --git
a/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/StandaloneContextManagerBuilder.java
b/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/StandaloneContextManagerBuilder.java
index 060fb8e7c58..eb7a621fe98 100644
---
a/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/StandaloneContextManagerBuilder.java
+++
b/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/StandaloneContextManagerBuilder.java
@@ -26,7 +26,7 @@ import org.apache.shardingsphere.mode.lock.GlobalLockContext;
import org.apache.shardingsphere.mode.manager.ContextManager;
import org.apache.shardingsphere.mode.manager.ContextManagerBuilder;
import org.apache.shardingsphere.mode.manager.ContextManagerBuilderParameter;
-import
org.apache.shardingsphere.mode.manager.standalone.subscriber.StandaloneProcessListSubscriber;
+import
org.apache.shardingsphere.mode.manager.standalone.subscriber.StandaloneProcessSubscriber;
import
org.apache.shardingsphere.mode.manager.standalone.workerid.generator.StandaloneWorkerIdGenerator;
import org.apache.shardingsphere.mode.metadata.MetaDataContexts;
import org.apache.shardingsphere.mode.metadata.MetaDataContextsFactory;
@@ -48,7 +48,7 @@ public final class StandaloneContextManagerBuilder implements
ContextManagerBuil
StandalonePersistRepository.class, null == repositoryConfig ?
null : repositoryConfig.getType(), null == repositoryConfig ? new Properties()
: repositoryConfig.getProps());
MetaDataPersistService persistService = new
MetaDataPersistService(repository);
InstanceContext instanceContext = buildInstanceContext(param);
- new
StandaloneProcessListSubscriber(instanceContext.getEventBusContext());
+ new StandaloneProcessSubscriber(instanceContext.getEventBusContext());
MetaDataContexts metaDataContexts =
MetaDataContextsFactory.create(persistService, param, instanceContext);
ContextManager result = new ContextManager(metaDataContexts,
instanceContext);
setContextManagerAware(result);
diff --git
a/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/subscriber/StandaloneProcessListSubscriber.java
b/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/subscriber/StandaloneProcessSubscriber.java
similarity index 84%
rename from
mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/subscriber/StandaloneProcessListSubscriber.java
rename to
mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/subscriber/StandaloneProcessSubscriber.java
index 0ec7320a19d..47e71a3daea 100644
---
a/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/subscriber/StandaloneProcessListSubscriber.java
+++
b/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/subscriber/StandaloneProcessSubscriber.java
@@ -24,26 +24,26 @@ import
org.apache.shardingsphere.infra.executor.sql.process.yaml.YamlProcessList
import
org.apache.shardingsphere.infra.executor.sql.process.yaml.swapper.YamlProcessListSwapper;
import org.apache.shardingsphere.infra.util.eventbus.EventBusContext;
import org.apache.shardingsphere.infra.util.yaml.YamlEngine;
-import org.apache.shardingsphere.mode.event.process.KillProcessRequestEvent;
-import
org.apache.shardingsphere.mode.event.process.ShowProcessListRequestEvent;
-import
org.apache.shardingsphere.mode.event.process.ShowProcessListResponseEvent;
-import org.apache.shardingsphere.mode.process.ProcessListSubscriber;
+import org.apache.shardingsphere.mode.process.event.KillProcessRequestEvent;
+import
org.apache.shardingsphere.mode.process.event.ShowProcessListRequestEvent;
+import
org.apache.shardingsphere.mode.process.event.ShowProcessListResponseEvent;
+import org.apache.shardingsphere.mode.process.ProcessSubscriber;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Collections;
/**
- * Standalone processlist subscriber.
+ * Standalone process subscriber.
*/
@SuppressWarnings("UnstableApiUsage")
-public final class StandaloneProcessListSubscriber implements
ProcessListSubscriber {
+public final class StandaloneProcessSubscriber implements ProcessSubscriber {
private final EventBusContext eventBusContext;
private final YamlProcessListSwapper swapper = new
YamlProcessListSwapper();
- public StandaloneProcessListSubscriber(final EventBusContext
eventBusContext) {
+ public StandaloneProcessSubscriber(final EventBusContext eventBusContext) {
this.eventBusContext = eventBusContext;
eventBusContext.register(this);
}
diff --git
a/mode/type/standalone/core/src/test/java/org/apache/shardingsphere/mode/manager/standalone/subscriber/StandaloneProcessListSubscriberTest.java
b/mode/type/standalone/core/src/test/java/org/apache/shardingsphere/mode/manager/standalone/subscriber/StandaloneProcessSubscriberTest.java
similarity index 87%
rename from
mode/type/standalone/core/src/test/java/org/apache/shardingsphere/mode/manager/standalone/subscriber/StandaloneProcessListSubscriberTest.java
rename to
mode/type/standalone/core/src/test/java/org/apache/shardingsphere/mode/manager/standalone/subscriber/StandaloneProcessSubscriberTest.java
index 5d3fce58550..83e1dae112c 100644
---
a/mode/type/standalone/core/src/test/java/org/apache/shardingsphere/mode/manager/standalone/subscriber/StandaloneProcessListSubscriberTest.java
+++
b/mode/type/standalone/core/src/test/java/org/apache/shardingsphere/mode/manager/standalone/subscriber/StandaloneProcessSubscriberTest.java
@@ -19,7 +19,7 @@ package
org.apache.shardingsphere.mode.manager.standalone.subscriber;
import org.apache.shardingsphere.infra.executor.sql.process.ProcessRegistry;
import org.apache.shardingsphere.infra.util.eventbus.EventBusContext;
-import
org.apache.shardingsphere.mode.event.process.ShowProcessListRequestEvent;
+import
org.apache.shardingsphere.mode.process.event.ShowProcessListRequestEvent;
import org.apache.shardingsphere.test.mock.AutoMockExtension;
import org.apache.shardingsphere.test.mock.StaticMockSettings;
import org.junit.jupiter.api.Test;
@@ -31,13 +31,13 @@ import static org.mockito.Mockito.when;
@ExtendWith(AutoMockExtension.class)
@StaticMockSettings(ProcessRegistry.class)
-class StandaloneProcessListSubscriberTest {
+class StandaloneProcessSubscriberTest {
@Test
void assertPostShowProcessListData() {
ProcessRegistry processRegistry = mock(ProcessRegistry.class);
when(ProcessRegistry.getInstance()).thenReturn(processRegistry);
- new StandaloneProcessListSubscriber(new
EventBusContext()).postShowProcessListData(new ShowProcessListRequestEvent());
+ new StandaloneProcessSubscriber(new
EventBusContext()).postShowProcessListData(new ShowProcessListRequestEvent());
verify(processRegistry).listAll();
}
}
diff --git
a/proxy/backend/type/mysql/src/main/java/org/apache/shardingsphere/proxy/backend/mysql/handler/admin/executor/KillProcessExecutor.java
b/proxy/backend/type/mysql/src/main/java/org/apache/shardingsphere/proxy/backend/mysql/handler/admin/executor/KillProcessExecutor.java
index c60e9da1943..4f1bc47e2ee 100644
---
a/proxy/backend/type/mysql/src/main/java/org/apache/shardingsphere/proxy/backend/mysql/handler/admin/executor/KillProcessExecutor.java
+++
b/proxy/backend/type/mysql/src/main/java/org/apache/shardingsphere/proxy/backend/mysql/handler/admin/executor/KillProcessExecutor.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.proxy.backend.mysql.handler.admin.executor;
import lombok.RequiredArgsConstructor;
-import org.apache.shardingsphere.mode.event.process.KillProcessRequestEvent;
+import org.apache.shardingsphere.mode.process.event.KillProcessRequestEvent;
import org.apache.shardingsphere.proxy.backend.context.ProxyContext;
import
org.apache.shardingsphere.proxy.backend.handler.admin.executor.DatabaseAdminExecutor;
import org.apache.shardingsphere.proxy.backend.session.ConnectionSession;
diff --git
a/proxy/backend/type/mysql/src/main/java/org/apache/shardingsphere/proxy/backend/mysql/handler/admin/executor/ShowProcessListExecutor.java
b/proxy/backend/type/mysql/src/main/java/org/apache/shardingsphere/proxy/backend/mysql/handler/admin/executor/ShowProcessListExecutor.java
index 5c13d1ffef3..84c955bce7a 100644
---
a/proxy/backend/type/mysql/src/main/java/org/apache/shardingsphere/proxy/backend/mysql/handler/admin/executor/ShowProcessListExecutor.java
+++
b/proxy/backend/type/mysql/src/main/java/org/apache/shardingsphere/proxy/backend/mysql/handler/admin/executor/ShowProcessListExecutor.java
@@ -30,8 +30,8 @@ import
org.apache.shardingsphere.infra.executor.sql.process.yaml.YamlProcess;
import org.apache.shardingsphere.infra.merge.result.MergedResult;
import
org.apache.shardingsphere.infra.merge.result.impl.transparent.TransparentMergedResult;
import org.apache.shardingsphere.infra.util.yaml.YamlEngine;
-import
org.apache.shardingsphere.mode.event.process.ShowProcessListRequestEvent;
-import
org.apache.shardingsphere.mode.event.process.ShowProcessListResponseEvent;
+import
org.apache.shardingsphere.mode.process.event.ShowProcessListRequestEvent;
+import
org.apache.shardingsphere.mode.process.event.ShowProcessListResponseEvent;
import org.apache.shardingsphere.proxy.backend.context.ProxyContext;
import
org.apache.shardingsphere.proxy.backend.handler.admin.executor.DatabaseAdminQueryExecutor;
import org.apache.shardingsphere.proxy.backend.session.ConnectionSession;
