File tree Expand file tree Collapse file tree 1 file changed +3
-7
lines changed
ydb/core/kqp/executer_actor Expand file tree Collapse file tree 1 file changed +3
-7
lines changed Original file line number Diff line number Diff line change @@ -1319,13 +1319,9 @@ class TKqpExecuterBase : public TActorBootstrapped<TDerived> {
13191319 const auto & input = stage.GetInputs (inputIndex);
13201320
13211321 // Current assumptions:
1322- // 1. `Broadcast` can not be the 1st stage input unless it's a single input
1323- // 2. All stage's inputs, except 1st one, must be a `Broadcast` or `UnionAll`
1324- if (inputIndex == 0 ) {
1325- if (stage.InputsSize () > 1 ) {
1326- YQL_ENSURE (input.GetTypeCase () != NKqpProto::TKqpPhyConnection::kBroadcast );
1327- }
1328- } else {
1322+ // 1. All stage's inputs, except 1st one, must be a `Broadcast` or `UnionAll`
1323+ // 2. 1st Broadcast is handled as UnionAll
1324+ if (inputIndex > 0 ) {
13291325 switch (input.GetTypeCase ()) {
13301326 case NKqpProto::TKqpPhyConnection::kBroadcast :
13311327 case NKqpProto::TKqpPhyConnection::kHashShuffle :
You can’t perform that action at this time.
0 commit comments