From 557dbca5bd9747e799af923842f3d49538d3ca7b Mon Sep 17 00:00:00 2001
From: Xinze Guo <101622833+azexcy@users.noreply.github.com>
Date: Wed, 22 Nov 2023 15:59:44 +0800
Subject: [PATCH] Clean invalid job config

---
 .../core/job/service/GovernanceRepositoryAPIImplTest.java       | 2 ++
 1 file changed, 2 insertions(+)

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 cf5203910f467..ecf3fe879cd74 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
@@ -87,6 +87,8 @@ void assertIsJobConfigurationExisted() {
         assertFalse(governanceRepositoryAPI.isJobConfigurationExisted("foo_job"));
         getClusterPersistRepository().persist("/pipeline/jobs/foo_job/config", "foo");
         assertTrue(governanceRepositoryAPI.isJobConfigurationExisted("foo_job"));
+        getClusterPersistRepository().delete("/pipeline/jobs/foo_job/config");
+        assertFalse(governanceRepositoryAPI.isJobConfigurationExisted("foo_job"));
     }
     
     @Test