From 1ef145af149a13b662361305fed6546d8e6ed706 Mon Sep 17 00:00:00 2001 From: ayusheshan Date: Fri, 13 Oct 2023 19:08:26 +0530 Subject: [PATCH] fixes for ci --- .../subscriber/ClusterStatusSubscriberTest.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/cluster/subscriber/ClusterStatusSubscriberTest.java b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/cluster/subscriber/ClusterStatusSubscriberTest.java index 242189aeca844..b4bfe6428c7f6 100644 --- a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/cluster/subscriber/ClusterStatusSubscriberTest.java +++ b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/cluster/subscriber/ClusterStatusSubscriberTest.java @@ -15,26 +15,26 @@ * limitations under the License. */ -package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.cluster.watcher; +package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.cluster.subscriber; -import org.apache.shardingsphere.infra.state.cluster.ClusterState; import org.junit.jupiter.api.Test; import org.mockito.Mock; -import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.cluster.subscriber.ClusterStatusSubscriber; +import org.junit.jupiter.api.extension.ExtendWith; import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.cluster.event.ClusterStatusChangedEvent; import org.apache.shardingsphere.infra.state.cluster.ClusterState; import org.apache.shardingsphere.infra.util.eventbus.EventBusContext; import org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository; import org.apache.shardingsphere.metadata.persist.node.ComputeNode; +import org.mockito.junit.jupiter.MockitoExtension; import static org.mockito.Mockito.verify; @ExtendWith(MockitoExtension.class) class ClusterStatusSubscriberTest { - + @Mock private ClusterPersistRepository repository; - + @Test void updateTest() { ClusterStatusSubscriber clusterStatusSubscriber = new ClusterStatusSubscriber(repository, new EventBusContext());