Fix inf loop at init

1 files changed, 4 insertions, 0 deletions

diff --git a/ydb/core/tx/schemeshard/schemeshard__init.cpp b/ydb/core/tx/schemeshard/schemeshard__init.cpp
index a9c719aff5..9bfdded52c 100644
--- a/ydb/core/tx/schemeshard/schemeshard__init.cpp
+++ b/ydb/core/tx/schemeshard/schemeshard__init.cpp
@@ -2936,6 +2936,10 @@ struct TSchemeShard::TTxInit : public TTransactionBase<TSchemeShard> {
                 } else {
                     stream->DoneShards.insert(shardIdx);
                 }
+
+                if (!rowset.Next()) {
+                    return false;
+                }
             }
         }