diff options
| -rw-r--r-- | ydb/library/yql/providers/yt/provider/yql_yt_logical_optimize.cpp | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/ydb/library/yql/providers/yt/provider/yql_yt_logical_optimize.cpp b/ydb/library/yql/providers/yt/provider/yql_yt_logical_optimize.cpp index 83c482b49e..5eb55995c9 100644 --- a/ydb/library/yql/providers/yt/provider/yql_yt_logical_optimize.cpp +++ b/ydb/library/yql/providers/yt/provider/yql_yt_logical_optimize.cpp @@ -2645,9 +2645,11 @@ protected: .ListHandlerLambda<TCoLambda>() .Args({ TStringBuf("stream") }) .Body<TCoForwardList>() - .Stream<TExprApplier>() - .Apply(shuffle.ListHandlerLambda().Body()) - .With(shuffle.ListHandlerLambda().Args().Arg(0), TStringBuf("stream")) + .Stream<TCoToStream>() + .Input<TExprApplier>() + .Apply(shuffle.ListHandlerLambda().Body()) + .With(shuffle.ListHandlerLambda().Args().Arg(0), TStringBuf("stream")) + .Build() .Build() .Build() .Build() |