diff options
Diffstat (limited to 'yt/cpp')
| -rw-r--r-- | yt/cpp/mapreduce/client/operation.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/yt/cpp/mapreduce/client/operation.cpp b/yt/cpp/mapreduce/client/operation.cpp index fc1600c240..a14a8b330c 100644 --- a/yt/cpp/mapreduce/client/operation.cpp +++ b/yt/cpp/mapreduce/client/operation.cpp @@ -1144,7 +1144,9 @@ void DoExecuteReduce( operationIo.OutputFormat, fluent); }) - .Item("sort_by").Value(spec.SortBy_) + .DoIf(!spec.SortBy_.Parts_.empty(), [&] (TFluentMap fluent) { + fluent.Item("sort_by").Value(spec.SortBy_); + }) .Item("reduce_by").Value(spec.ReduceBy_) .DoIf(spec.JoinBy_.Defined(), [&] (TFluentMap fluent) { fluent.Item("join_by").Value(spec.JoinBy_.GetRef()); |