diff options
| author | va-kuznecov <va-kuznecov@ydb.tech> | 2023-01-20 11:53:40 +0300 |
|---|---|---|
| committer | va-kuznecov <va-kuznecov@ydb.tech> | 2023-01-20 11:53:40 +0300 |
| commit | a9990339af015cb07a6dd902b20f0a74b4d8aec6 (patch) | |
| tree | 4fdc927f73a625a6f6734a83a986adba5b25af72 | |
| parent | 9fe36a164e3a650600e1d3bdb1c97c37ac2ce8da (diff) | |
| download | ydb-a9990339af015cb07a6dd902b20f0a74b4d8aec6.tar.gz | |
Fix reply race when repling through ForwardResponse
| -rw-r--r-- | ydb/core/kqp/session_actor/kqp_session_actor.cpp | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/ydb/core/kqp/session_actor/kqp_session_actor.cpp b/ydb/core/kqp/session_actor/kqp_session_actor.cpp index 3ac3dffa5d3..21124e4ae24 100644 --- a/ydb/core/kqp/session_actor/kqp_session_actor.cpp +++ b/ydb/core/kqp/session_actor/kqp_session_actor.cpp @@ -415,8 +415,7 @@ public: } void ForwardResponse(TEvKqp::TEvQueryResponse::TPtr& ev) { - TlsActivationContext->Send(new IEventHandle(Owner, SelfId(), ev->Release().Release(), ev->Flags, ev->Cookie, - nullptr, std::move(ev->TraceId))); + QueryResponse = std::unique_ptr<TEvKqp::TEvQueryResponse>(ev->Release().Release()); Cleanup(); } |