You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by pa...@apache.org on 2023/05/04 14:19:49 UTC
[shardingsphere] branch master updated: Rename ProcessSubscriber (#25453)
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 <zh...@apache.org>
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;