diff --git a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/job/service/PipelineJobGovernanceRepositoryTest.java b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/job/service/PipelineJobGovernanceRepositoryTest.java index ccebbd8414a5f..402e31c01c3e3 100644 --- a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/job/service/PipelineJobGovernanceRepositoryTest.java +++ b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/job/service/PipelineJobGovernanceRepositoryTest.java @@ -24,6 +24,7 @@ import org.apache.shardingsphere.mode.manager.ContextManager; import org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository; import org.apache.shardingsphere.test.it.data.pipeline.core.util.PipelineContextUtils; +import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.Test; import java.util.Optional; @@ -32,6 +33,11 @@ class PipelineJobGovernanceRepositoryTest { + @BeforeAll + static void beforeClass() { + PipelineContextUtils.mockModeConfigAndContextManager(); + } + @Test void assertDelete() { ClusterPersistRepository clusterPersistRepository = getClusterPersistRepository();