aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorVPolka <39378135+VPolka@users.noreply.github.com>2024-08-08 22:21:55 +0200
committerGitHub <noreply@github.com>2024-08-08 22:21:55 +0200
commit05377f6cdf75fca89aaa0db98f1a95ad5a073894 (patch)
treedeb2cb1614a06986a44b18906420fa5fdb7dba70
parentf71631da8acb44db9abdcb8ebb921da9f631dcfd (diff)
downloadydb-05377f6cdf75fca89aaa0db98f1a95ad5a073894.tar.gz
fix query id for recompilation (#7562)
-rw-r--r--ydb/core/kqp/compile_service/kqp_compile_service.cpp6
1 files changed, 5 insertions, 1 deletions
diff --git a/ydb/core/kqp/compile_service/kqp_compile_service.cpp b/ydb/core/kqp/compile_service/kqp_compile_service.cpp
index d0788088ff0..5e256275f25 100644
--- a/ydb/core/kqp/compile_service/kqp_compile_service.cpp
+++ b/ydb/core/kqp/compile_service/kqp_compile_service.cpp
@@ -778,7 +778,11 @@ private:
: (TableServiceConfig.GetEnableAstCache() && !request.QueryAst)
? ECompileActorAction::PARSE
: ECompileActorAction::COMPILE);
- TKqpCompileRequest compileRequest(ev->Sender, request.Uid, request.Query ? *request.Query : *compileResult->Query,
+ auto query = request.Query ? *request.Query : *compileResult->Query;
+ if (compileResult) {
+ query.UserSid = compileResult->Query->UserSid;
+ }
+ TKqpCompileRequest compileRequest(ev->Sender, request.Uid, query,
compileSettings, request.UserToken, dbCounters, request.GUCSettings, request.ApplicationName,
ev->Cookie, std::move(ev->Get()->IntrestedInResult),
ev->Get()->UserRequestContext,