Fix RPC reader (#3905)

1 files changed, 5 insertions, 3 deletions

diff --git a/ydb/library/yql/providers/yt/comp_nodes/dq/dq_yt_rpc_reader.cpp b/ydb/library/yql/providers/yt/comp_nodes/dq/dq_yt_rpc_reader.cpp
index 88d1b21aa8..81b82ef649 100644
--- a/ydb/library/yql/providers/yt/comp_nodes/dq/dq_yt_rpc_reader.cpp
+++ b/ydb/library/yql/providers/yt/comp_nodes/dq/dq_yt_rpc_reader.cpp
@@ -200,10 +200,12 @@ bool TParallelFileInputState::NextValue() {
             MkqlReader_.Next();
             return true;
         }
-        if (MkqlReader_.GetRowIndexUnchecked()) {
-            StateByReader_[CurrentInput_].CurrentRow = *MkqlReader_.GetRowIndexUnchecked() - 1;
+        if (!Settings_->Requests.empty()) {
+            if (MkqlReader_.GetRowIndexUnchecked()) {
+                StateByReader_[CurrentInput_].CurrentRow = *MkqlReader_.GetRowIndexUnchecked() - 1;
+            }
+            StateByReader_[CurrentInput_].CurrentRange = MkqlReader_.GetRangeIndexUnchecked();
         }
-        StateByReader_[CurrentInput_].CurrentRange = MkqlReader_.GetRangeIndexUnchecked();
         bool needWait = false;
         {
             std::lock_guard lock(InnerState_->Lock);