diff options
| author | mrlolthe1st <mrlolthe1st@yandex-team.com> | 2023-11-17 10:49:40 +0300 |
|---|---|---|
| committer | mrlolthe1st <mrlolthe1st@yandex-team.com> | 2023-11-17 11:13:12 +0300 |
| commit | 85278a57df949fe47f379978a77b007b68b17590 (patch) | |
| tree | e3c704468ca83f871eccba00f3b0533796dd8855 | |
| parent | 34eae36a4cbbe40d938ca620c2eb447fecb3d0b1 (diff) | |
| download | ydb-85278a57df949fe47f379978a77b007b68b17590.tar.gz | |
YQL-16963: Fix RPC reader
fix
| -rw-r--r-- | ydb/library/yql/providers/yt/comp_nodes/dq/dq_yt_rpc_helpers.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/library/yql/providers/yt/comp_nodes/dq/dq_yt_rpc_helpers.cpp b/ydb/library/yql/providers/yt/comp_nodes/dq/dq_yt_rpc_helpers.cpp index a450bbdff9..57b98f4824 100644 --- a/ydb/library/yql/providers/yt/comp_nodes/dq/dq_yt_rpc_helpers.cpp +++ b/ydb/library/yql/providers/yt/comp_nodes/dq/dq_yt_rpc_helpers.cpp @@ -71,7 +71,7 @@ std::unique_ptr<TSettingsHolder> CreateInputStreams(bool isArrow, const TString& ++inputIdx; continue; } - originalIndexes.emplace_back(inputIdx); + originalIndexes.emplace_back(inputIdx++); auto request = apiServiceProxy.ReadTable(); client->InitStreamingRequest(*request); |