diff --git a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/job/service/GovernanceRepositoryAPIImplTest.java b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/job/service/GovernanceRepositoryAPIImplTest.java index 9339b4ab88fc5..2b28e2d95c54c 100644 --- a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/job/service/GovernanceRepositoryAPIImplTest.java +++ b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/job/service/GovernanceRepositoryAPIImplTest.java @@ -77,6 +77,14 @@ private static void watch() { }); } + @Test + void assertIsExisted() { + String testKey = "/testKey1"; + assertFalse(governanceRepositoryAPI.isExisted(testKey)); + governanceRepositoryAPI.persist(testKey, "testValue1"); + assertTrue(governanceRepositoryAPI.isExisted(testKey)); + } + @Test void assertPersistJobItemProgress() { MigrationJobItemContext jobItemContext = mockJobItemContext();