diff options
| author | AlexSm <[email protected]> | 2024-01-11 14:49:03 +0100 |
|---|---|---|
| committer | GitHub <[email protected]> | 2024-01-11 14:49:03 +0100 |
| commit | 2e180154bd6a38b90a128ba0463d0dd2706a5ccf (patch) | |
| tree | 0e0890fa08e63af33c52c9b6eacee56d037a740b /yt/cpp/mapreduce/client/operation.cpp | |
| parent | 4366d88bef9360d9754e77eaa1f4a25d046a9cbd (diff) | |
Library import 7 (#937)
Diffstat (limited to 'yt/cpp/mapreduce/client/operation.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/client/operation.cpp | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/yt/cpp/mapreduce/client/operation.cpp b/yt/cpp/mapreduce/client/operation.cpp index 855e6e834c1..ade0f339b78 100644 --- a/yt/cpp/mapreduce/client/operation.cpp +++ b/yt/cpp/mapreduce/client/operation.cpp @@ -364,9 +364,9 @@ TString GetJobStderrWithRetriesAndIgnoreErrors( options); } catch (const TErrorResponse& e) { YT_LOG_ERROR("Cannot get job stderr (OperationId: %v, JobId: %v, Error: %v)", - operationId, - jobId, - e.what()); + operationId, + jobId, + e.what()); } if (jobStderr.size() > stderrTailSize) { jobStderr = jobStderr.substr(jobStderr.size() - stderrTailSize, stderrTailSize); @@ -1605,12 +1605,12 @@ void ExecuteMapReduce( auto nodeReaderFormat = NodeReaderFormatFromHintAndGlobalConfig(spec.MapperFormatHints_); auto [inputFormat, inputFormatConfig] = formatBuilder.CreateFormat( - *mapper, - EIODirection::Input, - structuredInputs, - hints.InputFormatHints_, - nodeReaderFormat, - /* allowFormatFromTableAttribute */ true); + *mapper, + EIODirection::Input, + structuredInputs, + hints.InputFormatHints_, + nodeReaderFormat, + /* allowFormatFromTableAttribute */ true); auto [outputFormat, outputFormatConfig] = formatBuilder.CreateFormat( *mapper, |
