fix useless message send

1 files changed, 7 insertions, 9 deletions

diff --git a/ydb/core/tx/columnshard/columnshard__scan.cpp b/ydb/core/tx/columnshard/columnshard__scan.cpp
index 506f5b4d760..dffbb8e8d7a 100644
--- a/ydb/core/tx/columnshard/columnshard__scan.cpp
+++ b/ydb/core/tx/columnshard/columnshard__scan.cpp
@@ -247,6 +247,13 @@ private:
         Y_VERIFY(!Finished);
         Y_VERIFY(ScanIterator);
 
+        if (!PeerFreeSpace) {
+            LOG_DEBUG_S(*TlsActivationContext, NKikimrServices::TX_COLUMNSHARD_SCAN,
+                "Scan " << ScanActorId << " producing result: bytes limit exhausted"
+                << " txId: " << TxId << " scanId: " << ScanId << " gen: " << ScanGen << " tablet: " << TabletId);
+            return false;
+        }
+
         if (ScanIterator->Finished()) {
             LOG_DEBUG_S(*TlsActivationContext, NKikimrServices::TX_COLUMNSHARD_SCAN,
                 "Scan " << ScanActorId << " producing result: scan iterator is finished"
@@ -330,15 +337,6 @@ private:
             return;
         }
 
-        if (PeerFreeSpace == 0) {
-            // Throttle down until the compute actor is ready to receive more rows
-
-            LOG_DEBUG_S(*TlsActivationContext, NKikimrServices::TX_COLUMNSHARD_SCAN,
-                "Scan " << ScanActorId << " waiting for peer free space"
-                << " txId: " << TxId << " scanId: " << ScanId << " gen: " << ScanGen << " tablet: " << TabletId);
-            return;
-        }
-
         // Send new results if there is available capacity
         while (ScanIterator && ProduceResults()) {
         }