diff options
| author | Александр Новожилов <mrlolthe1st@ydb.tech> | 2024-02-27 10:48:48 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-02-27 10:48:48 +0300 |
| commit | 156670e579358faf9523ae6610d202211744d25c (patch) | |
| tree | 19740d45613f036ada47e73f1548086cfc9c4107 | |
| parent | 48a641ae6497aaae54c4479518154f4cabcf762e (diff) | |
| download | ydb-156670e579358faf9523ae6610d202211744d25c.tar.gz | |
Add TMPDIR to reducer and mapper enviroment (#2248)
| -rw-r--r-- | ydb/library/yql/providers/yt/gateway/native/yql_yt_spec.cpp | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/ydb/library/yql/providers/yt/gateway/native/yql_yt_spec.cpp b/ydb/library/yql/providers/yt/gateway/native/yql_yt_spec.cpp index 2aad48fb864..66a4895f626 100644 --- a/ydb/library/yql/providers/yt/gateway/native/yql_yt_spec.cpp +++ b/ydb/library/yql/providers/yt/gateway/native/yql_yt_spec.cpp @@ -472,6 +472,14 @@ void FillSpec(NYT::TNode& spec, spec["force_job_size_adjuster"] = *val; } } + + if (opProps.HasFlags(EYtOpProp::WithMapper)) { + spec["mapper"]["environment"]["TMPDIR"] = "."; + } + + if (opProps.HasFlags(EYtOpProp::WithReducer)) { + spec["reducer"]["environment"]["TMPDIR"] = "."; + } } void FillSecureVault(NYT::TNode& spec, const IYtGateway::TSecureParams& secureParams) { |