Major Description
Storage#mutateEdges use following condition to separate strong edges and weak edges.
val (strongEdges, weakEdges) =
(edges.partition(e => e.label.consistencyLevel == "strong" || e.op == GraphUtil.operations("insertBulk")))
I think current condition is wrong. the condition should be following.
val (strongEdges, weakEdges) =
(edges.partition(e => e.label.consistencyLevel == "strong" && e.op != GraphUtil.operations("insertBulk")
Because of above bug, insertBulk is not working as intended(not lookup snapshotEdge and just build and fire RPCs).
Attachments
Issue Links
- links to
