Skip to content

Commit 644b5f8

Browse files
spuchinVPolka
andauthored
delete query from queryIndex if error during insert (ydb-platform#9231) (ydb-platform#9495)
Co-authored-by: VPolka <vpolka@nebius.com>
1 parent ec98756 commit 644b5f8

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

ydb/core/kqp/compile_service/kqp_compile_service.cpp

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,7 @@ class TKqpQueryCache {
4343
auto queryIt = QueryIndex.emplace(query, compileResult->Uid);
4444
if (!queryIt.second) {
4545
EraseByUid(compileResult->Uid);
46+
QueryIndex.erase(query);
4647
}
4748
Y_ENSURE(queryIt.second);
4849
}
@@ -782,6 +783,12 @@ class TKqpCompileService : public TActorBootstrapped<TKqpCompileService> {
782783
auto query = request.Query ? *request.Query : *compileResult->Query;
783784
if (compileResult) {
784785
query.UserSid = compileResult->Query->UserSid;
786+
if (query != *compileResult->Query) {
787+
LOG_WARN_S(ctx, NKikimrServices::KQP_COMPILE_SERVICE, "queryId in recompile request and queryId in cache are different"
788+
<< ", queryId in request: " << query.SerializeToString()
789+
<< ", queryId in cache: " << compileResult->Query->SerializeToString()
790+
);
791+
}
785792
}
786793
TKqpCompileRequest compileRequest(ev->Sender, request.Uid, query,
787794
compileSettings, request.UserToken, dbCounters, request.GUCSettings, request.ApplicationName,

0 commit comments

Comments
 (0)