diff --git a/ydb/core/kqp/compute_actor/kqp_scan_compute_actor.h b/ydb/core/kqp/compute_actor/kqp_scan_compute_actor.h index deb86b95d3dc..993baab388fa 100644 --- a/ydb/core/kqp/compute_actor/kqp_scan_compute_actor.h +++ b/ydb/core/kqp/compute_actor/kqp_scan_compute_actor.h @@ -87,6 +87,7 @@ class TKqpScanComputeActor: public TSchedulableComputeActorBaseIsAllocatorAttached()) { ComputeCtx.Clear(); @@ -135,9 +141,8 @@ class TKqpScanComputeActor: public TSchedulableComputeActorBaseBindAllocator(TBase::GetMkqlMemoryLimit()); ComputeCtx.Clear(); } + ScanData = nullptr; } - - TBase::PassAway(); } void TerminateSources(const NYql::TIssues& issues, bool success) override {