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

zyxxoo pushed a commit to branch refactor/rust-rewrite-design
in repository https://gitbox.apache.org/repos/asf/hugegraph.git


The following commit(s) were added to refs/heads/refactor/rust-rewrite-design 
by this push:
     new 202650f71 test(pd): isolate partition integration graph state
202650f71 is described below

commit 202650f71c204348cc3e97f416a307496adcbecd
Author: vaughn <[email protected]>
AuthorDate: Thu Sep 10 09:46:56 2026 +0800

    test(pd): isolate partition integration graph state
---
 .../org/apache/hugegraph/pd/core/PartitionServiceTest.java | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git 
a/hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/core/PartitionServiceTest.java
 
b/hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/core/PartitionServiceTest.java
index 198c35da9..27b96458b 100644
--- 
a/hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/core/PartitionServiceTest.java
+++ 
b/hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/core/PartitionServiceTest.java
@@ -52,11 +52,11 @@ public class PartitionServiceTest extends PDCoreTestBase {
         // 9, 10, 11 -> 3
         this.service.combinePartition(4);
 
-        var partition = this.service.getPartitionById("graph0", 0);
+        var partition = this.service.getPartitionById("graph_partition_core", 
0);
         assertEquals(0, partition.getStartKey());
         assertEquals(5462, partition.getEndKey());
 
-        var tasks = 
getStoreNodeService().getTaskInfoMeta().scanMoveTask("graph0");
+        var tasks = 
getStoreNodeService().getTaskInfoMeta().scanMoveTask("graph_partition_core");
         assertEquals(11, tasks.size());
 
         for (MetaTask.Task task : tasks) {
@@ -64,7 +64,7 @@ public class PartitionServiceTest extends PDCoreTestBase {
             getTaskService().reportTask(newTask);
         }
 
-        tasks = getStoreNodeService().getTaskInfoMeta().scanMoveTask("graph0");
+        tasks = 
getStoreNodeService().getTaskInfoMeta().scanMoveTask("graph_partition_core");
         assertEquals(0, tasks.size());
     }
 
@@ -78,11 +78,11 @@ public class PartitionServiceTest extends PDCoreTestBase {
         // 9, 10, 11 -> 3
         this.service.combinePartition(4);
 
-        var partition = this.service.getPartitionById("graph0", 0);
+        var partition = this.service.getPartitionById("graph_partition_core", 
0);
         assertEquals(0, partition.getStartKey());
         assertEquals(5462, partition.getEndKey());
 
-        var tasks = 
getStoreNodeService().getTaskInfoMeta().scanMoveTask("graph0");
+        var tasks = 
getStoreNodeService().getTaskInfoMeta().scanMoveTask("graph_partition_core");
         assertEquals(11, tasks.size());
 
         for (MetaTask.Task task : tasks) {
@@ -90,7 +90,7 @@ public class PartitionServiceTest extends PDCoreTestBase {
             getTaskService().reportTask(newTask);
         }
 
-        tasks = getStoreNodeService().getTaskInfoMeta().scanMoveTask("graph0");
+        tasks = 
getStoreNodeService().getTaskInfoMeta().scanMoveTask("graph_partition_core");
         assertEquals(0, tasks.size());
     }
 
@@ -137,7 +137,7 @@ public class PartitionServiceTest extends PDCoreTestBase {
             if (lastId >= PartitionUtils.MAX_VALUE) {
                 break;
             }
-            var partitionShard = this.service.getPartitionByCode("graph0", 
lastId);
+            var partitionShard = 
this.service.getPartitionByCode("graph_partition_core", lastId);
             if (partitionShard != null) {
                 lastId = partitionShard.getPartition().getEndKey();
             }

Reply via email to