Skip to content

Commit 16e6a63

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

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
}
@@ -785,6 +786,12 @@ class TKqpCompileService : public TActorBootstrapped<TKqpCompileService> {
785786
auto query = request.Query ? *request.Query : *compileResult->Query;
786787
if (compileResult) {
787788
query.UserSid = compileResult->Query->UserSid;
789+
if (query != *compileResult->Query) {
790+
LOG_WARN_S(ctx, NKikimrServices::KQP_COMPILE_SERVICE, "queryId in recompile request and queryId in cache are different"
791+
<< ", queryId in request: " << query.SerializeToString()
792+
<< ", queryId in cache: " << compileResult->Query->SerializeToString()
793+
);
794+
}
788795
}
789796
TKqpCompileRequest compileRequest(ev->Sender, request.Uid, query,
790797
compileSettings, request.UserToken, dbCounters, request.GUCSettings, request.ApplicationName,

0 commit comments

Comments
 (0)