aboutsummaryrefslogtreecommitdiffstats
path: root/yql/essentials/minikql/comp_nodes/ut/mkql_block_exists_ut.cpp
diff options
context:
space:
mode:
authorimunkin <imunkin@yandex-team.com>2025-01-17 16:12:38 +0300
committerimunkin <imunkin@yandex-team.com>2025-01-17 16:29:14 +0300
commit5bf3fd8cf1463c43723f1c8ba9d2322073f93c04 (patch)
tree89f3800c888c589798de9e4f5a34384eda2f6808 /yql/essentials/minikql/comp_nodes/ut/mkql_block_exists_ut.cpp
parente2b9ea56b89acb80b934fcfa26a782bb92e1d39e (diff)
downloadydb-5bf3fd8cf1463c43723f1c8ba9d2322073f93c04.tar.gz
YQL-19424: Use WideStream instead of WideFlow in WideFromBlocks computation node
commit_hash:21c84a9004cc57883d949b8fc637fc3ae7bfbda9
Diffstat (limited to 'yql/essentials/minikql/comp_nodes/ut/mkql_block_exists_ut.cpp')
-rw-r--r--yql/essentials/minikql/comp_nodes/ut/mkql_block_exists_ut.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/yql/essentials/minikql/comp_nodes/ut/mkql_block_exists_ut.cpp b/yql/essentials/minikql/comp_nodes/ut/mkql_block_exists_ut.cpp
index 67cf2acc49..fe65e76d1e 100644
--- a/yql/essentials/minikql/comp_nodes/ut/mkql_block_exists_ut.cpp
+++ b/yql/essentials/minikql/comp_nodes/ut/mkql_block_exists_ut.cpp
@@ -66,7 +66,7 @@ void DoBlockExistsOffset(size_t length, size_t offset) {
items[4],
};
});
- node = pb.WideFromBlocks(node);
+ node = pb.ToFlow(pb.WideFromBlocks(pb.FromFlow(node)));
node = pb.NarrowMap(node, [&](TRuntimeNode::TList items) -> TRuntimeNode {
return pb.NewTuple(outputTupleType, {items[0], items[1], items[2], items[3]});
});