aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAnton Romanov <Anton.Romanov@ydb.tech>2025-03-31 18:45:35 +0300
committerrobot-piglet <robot-piglet@yandex-team.com>2025-03-31 19:01:52 +0300
commit0f618a68fd57833a29e1e41ef24e2eb012f344af (patch)
treec004af6559442bb192e0a50420ce8dd356f83a18
parenta3a494d48c4b3d4f66cb235a7cc3e97f347f12f3 (diff)
downloadydb-0f618a68fd57833a29e1e41ef24e2eb012f344af.tar.gz
Fix read with union all
Type: fix Component: yql --- Co-authored-by: Tony-Romanov [150126326+Tony-Romanov@users.noreply.github.com] Pull Request resolved: https://github.com/ytsaurus/ytsaurus/pull/1164 commit_hash:4cafa69be7e700491887192f9e34682facc31fcb
-rw-r--r--yt/yql/providers/yt/gateway/lib/yt_helpers.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/yt/yql/providers/yt/gateway/lib/yt_helpers.cpp b/yt/yql/providers/yt/gateway/lib/yt_helpers.cpp
index 6ad53ec6d9..dd4ba61d7c 100644
--- a/yt/yql/providers/yt/gateway/lib/yt_helpers.cpp
+++ b/yt/yql/providers/yt/gateway/lib/yt_helpers.cpp
@@ -369,7 +369,7 @@ static bool IterateRows(NYT::ITransactionPtr tx,
} else {
auto format = specsCache.GetSpecs().MakeInputFormat(tableIndex);
auto rawReader = tx->CreateRawReader(path, format, readerOptions);
- TMkqlReaderImpl reader(*rawReader, 0, 4 << 10, tableIndex);
+ TMkqlReaderImpl reader(*rawReader, 0, 4 << 10, tableIndex, true);
reader.SetSpecs(specsCache.GetSpecs(), specsCache.GetHolderFactory());
for (reader.Next(); reader.IsValid(); reader.Next()) {