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();
}