diff --git a/conf/nebula-graphd.conf.default b/conf/nebula-graphd.conf.default index 80c0d0976a7..919f94d7f5c 100644 --- a/conf/nebula-graphd.conf.default +++ b/conf/nebula-graphd.conf.default @@ -62,7 +62,7 @@ # The number of networking IO threads, 0 for # of CPU cores --num_netio_threads=0 # The number of threads to execute user queries, 0 for # of CPU cores ---num_worker_threads=1 +--num_worker_threads=0 # HTTP service ip --ws_ip=0.0.0.0 # HTTP service port diff --git a/src/common/utils/NebulaKeyUtils.cpp b/src/common/utils/NebulaKeyUtils.cpp index 6db2db93a13..479ad2c939c 100644 --- a/src/common/utils/NebulaKeyUtils.cpp +++ b/src/common/utils/NebulaKeyUtils.cpp @@ -45,7 +45,6 @@ std::string NebulaKeyUtils::tagKey( .append(vId.data(), vId.size()) .append(vIdLen - vId.size(), pad) .append(reinterpret_cast(&tagId), sizeof(TagID)); - VLOG(1) << "tagKey return value: " << key; return key; } @@ -71,7 +70,6 @@ std::string NebulaKeyUtils::edgeKey(size_t vIdLen, .append(dstId.data(), dstId.size()) .append(vIdLen - dstId.size(), '\0') .append(1, ev); - VLOG(1) << "edgeKey return value: " << key; return key; } diff --git a/src/graph/executor/query/TraverseExecutor.cpp b/src/graph/executor/query/TraverseExecutor.cpp index be316a9d25a..a9cdde86939 100644 --- a/src/graph/executor/query/TraverseExecutor.cpp +++ b/src/graph/executor/query/TraverseExecutor.cpp @@ -242,15 +242,9 @@ Status TraverseExecutor::buildInterimPath(GetNeighborsIter* iter) { return Status::Error("Can't find prev paths."); } const auto& paths = pathToSrcFound->second; - // debug - VLOG(1) << "visited src:\t" << srcV.toString() << "\tedge:\t" << e.toString(); - VLOG(1) << "prevPath size:\t" << paths.size(); for (auto& prevPath : paths) { if (hasSameEdge(prevPath, e.getEdge())) { - VLOG(1) << "\t\tsame edge:\t" << prevPath.toString() << "\t\tto edge\t" << e.toString(); continue; - } else { - VLOG(1) << "\t\tdiff edge:\t" << prevPath.toString() << "\t\tto edge\t" << e.toString(); } vids_.emplace(dst); @@ -263,7 +257,6 @@ Status TraverseExecutor::buildInterimPath(GetNeighborsIter* iter) { List neighbors; neighbors.values.emplace_back(e); path.values.emplace_back(std::move(neighbors)); - VLOG(1) << "\t\t\tadded path:" << path.toString(); buildPath(current, dst, std::move(path)); ++count; } else { @@ -271,7 +264,6 @@ Status TraverseExecutor::buildInterimPath(GetNeighborsIter* iter) { auto& eList = path.values.back().mutableList().values; eList.emplace_back(srcV); eList.emplace_back(e); - VLOG(1) << "\t\t\tadded path:" << path.toString(); buildPath(current, dst, std::move(path)); ++count; } diff --git a/src/storage/exec/GetNeighborsNode.h b/src/storage/exec/GetNeighborsNode.h index 1817a08d3dc..a6d9d877071 100644 --- a/src/storage/exec/GetNeighborsNode.h +++ b/src/storage/exec/GetNeighborsNode.h @@ -63,7 +63,6 @@ class GetNeighborsNode : public QueryNode { if (context_->isIntId()) { row.emplace_back(*reinterpret_cast(vId.data())); } else { - VLOG(1) << "vId to iterate: " << vId; row.emplace_back(vId); } // second column is reserved for stat @@ -120,7 +119,6 @@ class GetNeighborsNode : public QueryNode { auto reader = upstream_->reader(); auto props = context_->props_; auto columnIdx = context_->columnIdx_; - VLOG(1) << "Key to iterate: " << key.toString(); list.reserve(props->size()); // collect props need to return if (!QueryUtils::collectEdgeProps( diff --git a/src/storage/exec/HashJoinNode.h b/src/storage/exec/HashJoinNode.h index ff806a75f5d..1448c64d3fe 100644 --- a/src/storage/exec/HashJoinNode.h +++ b/src/storage/exec/HashJoinNode.h @@ -156,29 +156,24 @@ class HashJoinNode : public IterateNode { /* This section is implemented to filter out duplicated self-reflective edges. */ private: bool isDuplicatedSelfReflectiveEdge(SingleEdgeNode* edgeNode) { - // get destination id if (!edgeNode->valid()) { return false; } auto rawKey = edgeNode->key(); std::string srcID = NebulaKeyUtils::getSrcId(context_->vIdLen(), rawKey).str(); std::string dstID = NebulaKeyUtils::getDstId(context_->vIdLen(), rawKey).str(); - VLOG(1) << "Tried to detect SR Edge with: " << srcID << "\t" << dstID; if (srcID.compare(dstID) == 0) { // self-reflective edge std::string rank = std::to_string(NebulaKeyUtils::getRank(context_->vIdLen(), rawKey)); auto edgeType = NebulaKeyUtils::getEdgeType(context_->vIdLen(), rawKey); edgeType = edgeType > 0 ? edgeType : -edgeType; std::string type = std::to_string(edgeType); - // std::string key = srcID + std::to_string(edgeType) + std::to_string(rank); std::string key; key.reserve(srcID.size() + type.size() + rank.size()); key = type + rank + srcID; if (!visitedSelfReflectiveEdges_.insert(key).second) { return true; } - for (auto& elem : visitedSelfReflectiveEdges_) { - } } return false; }