diff options
| author | Pavel Velikhov <pavelvelikhov@ydb.tech> | 2025-02-14 12:59:33 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-02-14 12:59:33 +0300 |
| commit | 4adb4e566b376e307ddb377bed51f2173330734b (patch) | |
| tree | e6c267c0e7331c63e4dec91a1b4a23049c109578 | |
| parent | 214dda53530a25336874effeaeb07dea8ba696ef (diff) | |
| download | ydb-4adb4e566b376e307ddb377bed51f2173330734b.tar.gz | |
Fixed replication bug (#14550)
Co-authored-by: Pavel Velikhov <pavelvelikhov@localhost.localdomain>
| -rw-r--r-- | ydb/library/yql/dq/opt/dq_opt_phy.cpp | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/ydb/library/yql/dq/opt/dq_opt_phy.cpp b/ydb/library/yql/dq/opt/dq_opt_phy.cpp index ed62d85445..de2c089f61 100644 --- a/ydb/library/yql/dq/opt/dq_opt_phy.cpp +++ b/ydb/library/yql/dq/opt/dq_opt_phy.cpp @@ -2594,11 +2594,13 @@ TExprBase DqBuildScalarPrecompute(TExprBase node, TExprContext& ctx, IOptimizati auto takeProgram = Build<TCoLambda>(ctx, node.Pos()) .Args({"take_arg"}) // DqOutput expects stream as input, thus form stream with one element - .Body<TCoToStream>() - .Input<TCoTake>() - .Input({"take_arg"}) - .Count<TCoUint64>() - .Literal().Build("1") + .Body<TCoToFlow>() + .Input<TCoToStream>() + .Input<TCoTake>() + .Input({"take_arg"}) + .Count<TCoUint64>() + .Literal().Build("1") + .Build() .Build() .Build() .Build() |