diff --git a/interactive_engine/groot-module/src/main/java/com/alibaba/graphscope/groot/frontend/write/GraphWriter.java b/interactive_engine/groot-module/src/main/java/com/alibaba/graphscope/groot/frontend/write/GraphWriter.java index 1fcee8edb33f..a15359d1877b 100644 --- a/interactive_engine/groot-module/src/main/java/com/alibaba/graphscope/groot/frontend/write/GraphWriter.java +++ b/interactive_engine/groot-module/src/main/java/com/alibaba/graphscope/groot/frontend/write/GraphWriter.java @@ -257,7 +257,7 @@ private void addDeleteVertexOperation( Map properties = dataRecord.getProperties(); Map 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 properties = dataRecord.getProperties(); Map 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));