Try to upload data asap without waiting for the zstd-frame to end

1 files changed, 6 insertions, 1 deletions

diff --git a/ydb/core/tx/datashard/import_s3.cpp b/ydb/core/tx/datashard/import_s3.cpp
index 7a592b1b150..4599eddd246 100644
--- a/ydb/core/tx/datashard/import_s3.cpp
+++ b/ydb/core/tx/datashard/import_s3.cpp
@@ -130,7 +130,7 @@ class TS3Downloader: public TActorBootstrapped<TS3Downloader> {
                 }
             }
 
-            Pos = pos + 1; // for '\n'
+            Pos = pos + 1 /* \n */;
             return READY_DATA;
         }
 
@@ -204,6 +204,11 @@ class TS3Downloader: public TActorBootstrapped<TS3Downloader> {
                     ReadyInputBytes = PendingInputBytes;
                     ReadyOutputPos = Buffer.Size();
                     Reset();
+                } else {
+                    const ui64 pos = AsStringBuf(Buffer.Size()).rfind('\n');
+                    if (TString::npos != pos) {
+                        ReadyOutputPos = pos + 1 /* \n */;
+                    }
                 }
             }