diff options
-rw-r--r-- | searchcore/src/vespa/searchcore/proton/matchengine/matchengine.cpp | 4 | ||||
-rw-r--r-- | searchcore/src/vespa/searchcore/proton/summaryengine/summaryengine.cpp | 4 |
2 files changed, 8 insertions, 0 deletions
diff --git a/searchcore/src/vespa/searchcore/proton/matchengine/matchengine.cpp b/searchcore/src/vespa/searchcore/proton/matchengine/matchengine.cpp index a6c1b6b1f72..5ad4a7ed52b 100644 --- a/searchcore/src/vespa/searchcore/proton/matchengine/matchengine.cpp +++ b/searchcore/src/vespa/searchcore/proton/matchengine/matchengine.cpp @@ -149,6 +149,10 @@ MatchEngine::performSearch(search::engine::SearchRequest::Source req) ret->request = req.release(); if (_forward_issues) { ret->my_issues = std::move(my_issues); + } else { + my_issues->for_each_message([](const auto &msg){ + LOG(warning, "unhandled issue: %s", msg.c_str()); + }); } ret->setDistributionKey(_distributionKey); if ((ret->request->trace().getLevel() > 0) && ret->request->trace().hasTrace()) { diff --git a/searchcore/src/vespa/searchcore/proton/summaryengine/summaryengine.cpp b/searchcore/src/vespa/searchcore/proton/summaryengine/summaryengine.cpp index 1e488fd6dfe..95643c7d1a8 100644 --- a/searchcore/src/vespa/searchcore/proton/summaryengine/summaryengine.cpp +++ b/searchcore/src/vespa/searchcore/proton/summaryengine/summaryengine.cpp @@ -148,6 +148,10 @@ SummaryEngine::getDocsums(DocsumRequest::UP req) reply->setRequest(std::move(req)); if (_forward_issues) { reply->setIssues(std::move(my_issues)); + } else { + my_issues->for_each_message([](const auto &msg){ + LOG(warning, "unhandled issue: %s", msg.c_str()); + }); } return reply; } |