emit each row

1 files changed, 2 insertions, 2 deletions

diff --git a/ydb/library/yql/sql/pg/pg_sql.cpp b/ydb/library/yql/sql/pg/pg_sql.cpp
index 3ceb27604ba..7281421913f 100644
--- a/ydb/library/yql/sql/pg/pg_sql.cpp
+++ b/ydb/library/yql/sql/pg/pg_sql.cpp
@@ -2693,9 +2693,9 @@ private:
         auto prevRow = position.Row;
         for (ui32 i = 0; i < query.Size(); ++i) {
             walker.Advance(query[i]);
-            if (position.Row != prevRow) {
+            while (position.Row != prevRow) {
                 RowStarts.push_back(i);
-                prevRow = position.Row;
+                ++prevRow;
             }
         }