Merge f93a8b0 into 4b641a3

Hor911 · web-flow · commit 945332520636 · 2025-03-06T12:31:26.000+03:00
diff --git a/ydb/core/kqp/compute_actor/kqp_scan_compute_actor.h b/ydb/core/kqp/compute_actor/kqp_scan_compute_actor.h
@@ -127,17 +127,18 @@ class TKqpScanComputeActor: public TSchedulableComputeActorBase<TKqpScanComputeA
 
     void PollSources(ui64 prevFreeSpace);
 
-    void PassAway() override {
+    void DoTerminateImpl() override {
         if (TaskRunner) {
             if (TaskRunner->IsAllocatorAttached()) {
                 ComputeCtx.Clear();
             } else {
                 auto guard = TaskRunner->BindAllocator(TBase::GetMkqlMemoryLimit());
                 ComputeCtx.Clear();
             }
+            ScanData = nullptr;
         }
 
-        TBase::PassAway();
+        TBase::DoTerminateImpl();
     }
 
     void TerminateSources(const NYql::TIssues& issues, bool success) override {

Original file line number	Diff line number	Diff line change
`@@ -127,17 +127,18 @@ class TKqpScanComputeActor: public TSchedulableComputeActorBase<TKqpScanComputeA`
`127`	`127`
`128`	`128`	`void PollSources(ui64 prevFreeSpace);`
`129`	`129`
`130`		`- void PassAway() override {`
	`130`	`+ void DoTerminateImpl() override {`
`131`	`131`	`if (TaskRunner) {`
`132`	`132`	`if (TaskRunner->IsAllocatorAttached()) {`
`133`	`133`	`ComputeCtx.Clear();`
`134`	`134`	`} else {`
`135`	`135`	`auto guard = TaskRunner->BindAllocator(TBase::GetMkqlMemoryLimit());`
`136`	`136`	`ComputeCtx.Clear();`
`137`	`137`	`}`
	`138`	`+ ScanData = nullptr;`
`138`	`139`	`}`
`139`	`140`
`140`		`- TBase::PassAway();`
	`141`	`+ TBase::DoTerminateImpl();`
`141`	`142`	`}`
`142`	`143`
`143`	`144`	`void TerminateSources(const NYql::TIssues& issues, bool success) override {`