diff options
Diffstat (limited to 'yt/cpp/mapreduce/interface/operation.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/interface/operation.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/yt/cpp/mapreduce/interface/operation.cpp b/yt/cpp/mapreduce/interface/operation.cpp index b3229117d91..d5b9271bcd4 100644 --- a/yt/cpp/mapreduce/interface/operation.cpp +++ b/yt/cpp/mapreduce/interface/operation.cpp @@ -1,5 +1,7 @@ #include "operation.h" +#include <yt/cpp/mapreduce/interface/helpers.h> + #include <util/generic/iterator_range.h> namespace NYT { @@ -127,7 +129,7 @@ TRawJobContext::TRawJobContext(size_t outputTableCount) : InputFile_(Duplicate(0)) { for (size_t i = 0; i != outputTableCount; ++i) { - OutputFileList_.emplace_back(Duplicate(3 * i + 1)); + OutputFileList_.emplace_back(Duplicate(3 * i + GetJobFirstOutputTableFD())); } } |
