(shardingsphere) branch master updated: Recover PipelineGovernanceFacadeTest; Clean new created node in unit test (#29150)

[zhonghongsheng]

This is an automated email from the ASF dual-hosted git repository.

zhonghongsheng 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 7bf4865fd50 Recover PipelineGovernanceFacadeTest; Clean new created 
node in unit test (#29150)
7bf4865fd50 is described below

commit 7bf4865fd50c5232b8ea9d040f213f08e41795e5
Author: Xinze Guo <101622833+aze...@users.noreply.github.com>
AuthorDate: Mon Nov 27 10:57:40 2023 +0800

    Recover PipelineGovernanceFacadeTest; Clean new created node in unit test 
(#29150)
---
 .../core/job/service/PipelineGovernanceFacadeTest.java        | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git 
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/job/service/PipelineGovernanceFacadeTest.java
 
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/job/service/PipelineGovernanceFacadeTest.java
index d7fcec76f0c..d0d678eb524 100644
--- 
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/job/service/PipelineGovernanceFacadeTest.java
+++ 
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/job/service/PipelineGovernanceFacadeTest.java
@@ -32,6 +32,8 @@ import 
org.apache.shardingsphere.data.pipeline.core.task.InventoryTask;
 import org.apache.shardingsphere.data.pipeline.core.task.PipelineTaskUtils;
 import 
org.apache.shardingsphere.data.pipeline.scenario.migration.config.MigrationTaskConfiguration;
 import 
org.apache.shardingsphere.data.pipeline.scenario.migration.context.MigrationJobItemContext;
+import org.apache.shardingsphere.elasticjob.infra.pojo.JobConfigurationPOJO;
+import org.apache.shardingsphere.infra.util.yaml.YamlEngine;
 import org.apache.shardingsphere.mode.event.DataChangedEvent;
 import org.apache.shardingsphere.mode.event.DataChangedEvent.Type;
 import org.apache.shardingsphere.mode.manager.ContextManager;
@@ -103,10 +105,15 @@ class PipelineGovernanceFacadeTest {
     
     @Test
     void assertIsExistedJobConfiguration() {
-        ClusterPersistRepository clusterPersistRepository = 
getClusterPersistRepository();
         
assertFalse(governanceFacade.getJobFacade().getConfiguration().isExisted("foo_job"));
-        clusterPersistRepository.persist("/pipeline/jobs/foo_job/config", 
"foo");
+        JobConfigurationPOJO value = new JobConfigurationPOJO();
+        value.setJobName("foo_job");
+        value.setShardingTotalCount(1);
+        ClusterPersistRepository clusterPersistRepository = 
getClusterPersistRepository();
+        clusterPersistRepository.persist("/pipeline/jobs/foo_job/config", 
YamlEngine.marshal(value));
         
assertTrue(governanceFacade.getJobFacade().getConfiguration().isExisted("foo_job"));
+        clusterPersistRepository.delete("/pipeline/jobs/foo_job/config");
+        
assertFalse(governanceFacade.getJobFacade().getConfiguration().isExisted("foo_job"));
     }
     
     @Test