From 91d4bb3aa5a3fb24697f54e6a0df6fd3ef33e006 Mon Sep 17 00:00:00 2001 From: jimingquan <6930445+nevermore3@users.noreply.github.com> Date: Mon, 13 May 2024 22:33:02 +0800 Subject: [PATCH] fix max edge per vertex --- src/storage/query/GetNeighborsProcessor.cpp | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/storage/query/GetNeighborsProcessor.cpp b/src/storage/query/GetNeighborsProcessor.cpp index 89f49e0c59..a5a4a6448e 100644 --- a/src/storage/query/GetNeighborsProcessor.cpp +++ b/src/storage/query/GetNeighborsProcessor.cpp @@ -58,8 +58,9 @@ void GetNeighborsProcessor::doProcess(const cpp2::GetNeighborsRequest& req) { int64_t limit = FLAGS_max_edge_returned_per_vertex; bool random = false; if ((*req.traverse_spec_ref()).limit_ref().has_value()) { - if (*(*req.traverse_spec_ref()).limit_ref() >= 0) { - limit = *(*req.traverse_spec_ref()).limit_ref(); + int64_t traverseLimit = *(*req.traverse_spec_ref()).limit_ref(); + if (traverseLimit >= 0 && traverseLimit < limit) { + limit = traverseLimit; } if ((*req.traverse_spec_ref()).random_ref().has_value()) { random = *(*req.traverse_spec_ref()).random_ref();