summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/interface/operation.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'yt/cpp/mapreduce/interface/operation.cpp')
-rw-r--r--yt/cpp/mapreduce/interface/operation.cpp4
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()));
}
}