fix update/delete vertices

alibaba · Sep 22, 2023 · 8bad090 · 8bad090
1 parent 6ab796e
commit 8bad090
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...e/groot-module/src/main/java/com/alibaba/graphscope/groot/frontend/write/GraphWriter.java b/...e/groot-module/src/main/java/com/alibaba/graphscope/groot/frontend/write/GraphWriter.java
@@ -257,7 +257,7 @@ private void addDeleteVertexOperation(
         Map<String, Object> properties = dataRecord.getProperties();
         Map<Integer, PropertyValue> propertyVals = parseRawProperties(vertexDef, properties);
         propertyVals.putAll(pkVals);
-        long hashId = getPrimaryKeysHashId(labelId, pkVals, vertexDef);
+        long hashId = getPrimaryKeysHashId(labelId, propertyVals, vertexDef);
         batchBuilder.addOperation(
                 new DeleteVertexOperation(new VertexId(hashId), new LabelId(labelId)));
     }
@@ -273,7 +273,7 @@ private void addUpdateVertexOperation(
         Map<String, Object> properties = dataRecord.getProperties();
         Map<Integer, PropertyValue> propertyVals = parseRawProperties(vertexDef, properties);
         propertyVals.putAll(pkVals);
-        long hashId = getPrimaryKeysHashId(labelId, pkVals, vertexDef);
+        long hashId = getPrimaryKeysHashId(labelId, propertyVals, vertexDef);
         batchBuilder.addOperation(
                 new UpdateVertexOperation(
                         new VertexId(hashId), new LabelId(labelId), propertyVals));