diff --git a/ydb/library/yql/dq/actors/spilling/channel_storage_actor.cpp b/ydb/library/yql/dq/actors/spilling/channel_storage_actor.cpp
index 2c5813ed57ad..071ed4593d88 100644
--- a/ydb/library/yql/dq/actors/spilling/channel_storage_actor.cpp
+++ b/ydb/library/yql/dq/actors/spilling/channel_storage_actor.cpp
@@ -35,7 +35,7 @@ namespace {
     LOG_WARN_S(*ActorSystem_,  NKikimrServices::KQP_COMPUTE, "TxId: " << TxId << ", channelId: " << ChannelId << ". " << s);
 
 #define LOG_T(s) \
-    LOG_TRACE_S(*ActorSystem_,  NKikimrServices::KQP_COMPUTE, "TxId: " << TxId_ << ", channelId: " << ChannelId_ << ". " << s); 
+    LOG_TRACE_S(*ActorSystem_,  NKikimrServices::KQP_COMPUTE, "TxId: " << TxId_ << ", channelId: " << ChannelId_ << ". " << s);
 
 class TDqChannelStorageActor : public IDqChannelStorageActor,
                                public NActors::TActorBootstrapped<TDqChannelStorageActor>
@@ -115,7 +115,7 @@ class TDqChannelStorageActor : public IDqChannelStorageActor,
         LOG_T("[TEvGet] blobId: " << msg.BlobId_);
 
         auto opBegin = TInstant::Now();
- 
+
         auto loadingBlobInfo = TLoadingBlobInfo{std::move(msg.Promise_), opBegin};
         LoadingBlobs_.emplace(msg.BlobId_, std::move(loadingBlobInfo));
 
@@ -203,7 +203,7 @@ class TDqChannelStorageActor : public IDqChannelStorageActor,
 
     // BlobId -> blob size + promise that blob is saved
     std::unordered_map<ui64, TWritingBlobInfo> WritingBlobs_;
-    
+
     // BlobId -> promise with requested blob
     std::unordered_map<ui64, TLoadingBlobInfo> LoadingBlobs_;
 
diff --git a/ydb/library/yql/dq/actors/spilling/compute_storage.cpp b/ydb/library/yql/dq/actors/spilling/compute_storage.cpp
index 04dab7ff070f..8c2690032d3c 100644
--- a/ydb/library/yql/dq/actors/spilling/compute_storage.cpp
+++ b/ydb/library/yql/dq/actors/spilling/compute_storage.cpp
@@ -28,7 +28,7 @@ NThreading::TFuture<NKikimr::NMiniKQL::ISpiller::TKey> TDqComputeStorage::Put(TC
 }
 
 NThreading::TFuture<std::optional<TChunkedBuffer>> TDqComputeStorage::Get(TKey key) {
-    return GetInternal(key, false);
+    return Extract(key);
 }
 
 NThreading::TFuture<void> TDqComputeStorage::Delete(TKey key) {
@@ -41,15 +41,10 @@ NThreading::TFuture<void> TDqComputeStorage::Delete(TKey key) {
 }
 
 NThreading::TFuture<std::optional<TChunkedBuffer>> TDqComputeStorage::Extract(TKey key) {
-    return GetInternal(key, true);
-}
-
-NThreading::TFuture<std::optional<TChunkedBuffer>> TDqComputeStorage::GetInternal(TKey key, bool removeBlobAfterRead) {
-
     auto promise = NThreading::NewPromise<std::optional<TChunkedBuffer>>();
     auto future = promise.GetFuture();
 
-    ActorSystem_->Send(ComputeStorageActorId_, new TEvGet(key, std::move(promise), removeBlobAfterRead));
+    ActorSystem_->Send(ComputeStorageActorId_, new TEvGet(key, std::move(promise)));
     return future;
 }
 
diff --git a/ydb/library/yql/dq/actors/spilling/compute_storage.h b/ydb/library/yql/dq/actors/spilling/compute_storage.h
index 6b7314525c9c..97cb93d5afb9 100644
--- a/ydb/library/yql/dq/actors/spilling/compute_storage.h
+++ b/ydb/library/yql/dq/actors/spilling/compute_storage.h
@@ -30,8 +30,6 @@ class TDqComputeStorage : public NKikimr::NMiniKQL::ISpiller
     NThreading::TFuture<void> Delete(TKey key) override;
 
 private:
-    NThreading::TFuture<std::optional<TChunkedBuffer>> GetInternal(TKey key, bool removeBlobAfterRead);
-
     NActors::TActorSystem* ActorSystem_;
     IDqComputeStorageActor* ComputeStorageActor_;
     NActors::TActorId ComputeStorageActorId_;
diff --git a/ydb/library/yql/dq/actors/spilling/compute_storage_actor.cpp b/ydb/library/yql/dq/actors/spilling/compute_storage_actor.cpp
index e0c8b3c21cbf..29c86727ba80 100644
--- a/ydb/library/yql/dq/actors/spilling/compute_storage_actor.cpp
+++ b/ydb/library/yql/dq/actors/spilling/compute_storage_actor.cpp
@@ -41,7 +41,6 @@ class TDqComputeStorageActor : public NActors::TActorBootstrapped<TDqComputeStor
     };
 
     struct TLoadingBlobInfo {
-        bool RemoveAfterRead;
         NThreading::TPromise<std::optional<TChunkedBuffer>> BlobPromise;
         TInstant OpBegin;
     };
@@ -59,8 +58,7 @@ class TDqComputeStorageActor : public NActors::TActorBootstrapped<TDqComputeStor
     }
 
     void Bootstrap() {
-        auto spillingActor = CreateDqLocalFileSpillingActor(TxId_, SpillerName_,
-            SelfId(), false);
+        auto spillingActor = CreateDqLocalFileSpillingActor(TxId_, SpillerName_, SelfId(), true);
         SpillingActorId_ = Register(spillingActor);
         Become(&TDqComputeStorageActor::WorkState);
     }
@@ -131,12 +129,10 @@ class TDqComputeStorageActor : public NActors::TActorBootstrapped<TDqComputeStor
             return;
         }
 
-        bool removeBlobAfterRead = msg.RemoveBlobAfterRead_;
-
-        auto loadingBlobInfo = TLoadingBlobInfo{removeBlobAfterRead, std::move(msg.Promise_), opBegin};
+        auto loadingBlobInfo = TLoadingBlobInfo{std::move(msg.Promise_), opBegin};
         LoadingBlobs_.emplace(msg.Key_, std::move(loadingBlobInfo));
 
-        SendInternal(SpillingActorId_, new TEvDqSpilling::TEvRead(msg.Key_, removeBlobAfterRead));
+        SendInternal(SpillingActorId_, new TEvDqSpilling::TEvRead(msg.Key_));
     }
 
     void HandleWork(TEvDelete::TPtr& ev) {
@@ -149,7 +145,7 @@ class TDqComputeStorageActor : public NActors::TActorBootstrapped<TDqComputeStor
 
         DeletingBlobs_.emplace(msg.Key_, std::move(msg.Promise_));
 
-        SendInternal(SpillingActorId_, new TEvDqSpilling::TEvRead(msg.Key_, true));
+        SendInternal(SpillingActorId_, new TEvDqSpilling::TEvRead(msg.Key_));
     }
 
     void HandleWork(TEvDqSpilling::TEvWriteResult::TPtr& ev) {
@@ -209,9 +205,7 @@ class TDqComputeStorageActor : public NActors::TActorBootstrapped<TDqComputeStor
             SpillingTaskCounters_->ComputeReadTime += opDuration.MilliSeconds();
         }
 
-        if (blobInfo.RemoveAfterRead) {
-            UpdateStatsAfterBlobDeletion(msg.Blob.Size(), msg.BlobId);
-        }
+        UpdateStatsAfterBlobDeletion(msg.Blob.Size(), msg.BlobId);
 
         auto owner = std::make_shared<TBuffer>(std::move(msg.Blob));
         TChunkedBuffer res(TStringBuf(reinterpret_cast<const char*>(owner->Data()), owner->Size()), owner);
@@ -277,9 +271,9 @@ class TDqComputeStorageActor : public NActors::TActorBootstrapped<TDqComputeStor
 
 } // anonymous namespace
 
-IDqComputeStorageActor* CreateDqComputeStorageActor(TTxId txId, const TString& spillerName, TWakeUpCallback wakeupCallback, 
+IDqComputeStorageActor* CreateDqComputeStorageActor(TTxId txId, const TString& spillerName, TWakeUpCallback wakeupCallback,
     TErrorCallback errorCallback, TIntrusivePtr<TSpillingTaskCounters> spillingTaskCounters) {
     return new TDqComputeStorageActor(txId, spillerName, wakeupCallback, errorCallback, spillingTaskCounters);
 }
 
-} // namespace NYql::NDq 
+} // namespace NYql::NDq
diff --git a/ydb/library/yql/dq/actors/spilling/compute_storage_actor.h b/ydb/library/yql/dq/actors/spilling/compute_storage_actor.h
index ddd86432f81e..ace0d712a0c3 100644
--- a/ydb/library/yql/dq/actors/spilling/compute_storage_actor.h
+++ b/ydb/library/yql/dq/actors/spilling/compute_storage_actor.h
@@ -27,7 +27,6 @@ struct TDqComputeStorageActorEvents {
     enum {
         EvPut = EventSpaceBegin(NActors::TEvents::EEventSpace::ES_USERSPACE) + 30000,
         EvGet,
-        EvExtract,
         EvDelete
     };
 };
@@ -44,16 +43,14 @@ struct TEvPut : NActors::TEventLocal<TEvPut, TDqComputeStorageActorEvents::EvPut
 };
 
 struct TEvGet : NActors::TEventLocal<TEvGet, TDqComputeStorageActorEvents::EvGet> {
-    TEvGet(IDqComputeStorageActor::TKey key, NThreading::TPromise<std::optional<TChunkedBuffer>>&& promise, bool removeBlobAfterRead)
+    TEvGet(IDqComputeStorageActor::TKey key, NThreading::TPromise<std::optional<TChunkedBuffer>>&& promise)
         : Key_(key)
         , Promise_(std::move(promise))
-        , RemoveBlobAfterRead_(removeBlobAfterRead)
     {
     }
 
     IDqComputeStorageActor::TKey Key_;
     NThreading::TPromise<std::optional<TChunkedBuffer>> Promise_;
-    bool RemoveBlobAfterRead_;
 };
 
 struct TEvDelete : NActors::TEventLocal<TEvDelete, TDqComputeStorageActorEvents::EvDelete> {
@@ -67,7 +64,7 @@ struct TEvDelete : NActors::TEventLocal<TEvDelete, TDqComputeStorageActorEvents:
     NThreading::TPromise<void> Promise_;
 };
 
-IDqComputeStorageActor* CreateDqComputeStorageActor(TTxId txId, const TString& spillerName, TWakeUpCallback wakeupCallback, 
+IDqComputeStorageActor* CreateDqComputeStorageActor(TTxId txId, const TString& spillerName, TWakeUpCallback wakeupCallback,
     TErrorCallback errorCallback, TIntrusivePtr<TSpillingTaskCounters> spillingTaskCounters);
 
 } // namespace NYql::NDq
diff --git a/ydb/library/yql/dq/actors/spilling/spilling.h b/ydb/library/yql/dq/actors/spilling/spilling.h
index 767ede0bdd76..920d7f902298 100644
--- a/ydb/library/yql/dq/actors/spilling/spilling.h
+++ b/ydb/library/yql/dq/actors/spilling/spilling.h
@@ -30,11 +30,10 @@ struct TEvDqSpilling {
 
     struct TEvRead : public NActors::TEventLocal<TEvRead, TDqSpillingEvents::EvRead> {
         ui64 BlobId;
-        bool RemoveBlob;
         TMaybe<TDuration> Timeout;
 
-        TEvRead(ui64 blobId, bool removeBlob = false, TMaybe<TDuration> timeout = {})
-            : BlobId(blobId), RemoveBlob(removeBlob), Timeout(timeout) {}
+        TEvRead(ui64 blobId, TMaybe<TDuration> timeout = {})
+            : BlobId(blobId), Timeout(timeout) {}
     };
 
     struct TEvReadResult : public NActors::TEventLocal<TEvReadResult, TDqSpillingEvents::EvReadResult> {