Merge f4f5ed5 into 1e497ce

Author: Hor911

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,11 +115,11 @@ 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));
 
-        SendInternal(SpillingActorId_, new TEvDqSpilling::TEvRead(msg.BlobId_));
+        SendInternal(SpillingActorId_, new TEvDqSpilling::TEvRead(msg.BlobId_, true));
     }
 
     void HandleWork(TEvDqChannelSpilling::TEvPut::TPtr& ev) {
@@ -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_;