fix streamlookup join from multi-partitioned streams

yumkam · yumkam · commit ddf25c8626b0 · 2024-09-04T12:19:00.000+03:00
diff --git a/ydb/library/yql/dq/tasks/dq_connection_builder.h b/ydb/library/yql/dq/tasks/dq_connection_builder.h
@@ -216,7 +216,7 @@ void BuildStreamLookupChannels(TGraph& graph, const NNodes::TDqPhyStage& stage,
     auto& originStageInfo = graph.GetStageInfo(cnStreamLookup.Output().Stage());
     auto outputIndex = FromString<ui32>(cnStreamLookup.Output().Index().Value());
 
-    BuildMapChannels(graph, stageInfo, inputIndex, originStageInfo, outputIndex, false /*spilling*/, logFunc);
+    BuildUnionAllChannels(graph, stageInfo, inputIndex, originStageInfo, outputIndex, false /*spilling*/, logFunc);
 }
 
 template <typename TGraph>

Original file line number	Diff line number	Diff line change
`@@ -216,7 +216,7 @@ void BuildStreamLookupChannels(TGraph& graph, const NNodes::TDqPhyStage& stage,`
`216`	`216`	`auto& originStageInfo = graph.GetStageInfo(cnStreamLookup.Output().Stage());`
`217`	`217`	`auto outputIndex = FromString<ui32>(cnStreamLookup.Output().Index().Value());`
`218`	`218`
`219`		`- BuildMapChannels(graph, stageInfo, inputIndex, originStageInfo, outputIndex, false /spilling/, logFunc);`
	`219`	`+ BuildUnionAllChannels(graph, stageInfo, inputIndex, originStageInfo, outputIndex, false /spilling/, logFunc);`
`220`	`220`	`}`
`221`	`221`
`222`	`222`	`template <typename TGraph>`