diff options
| author | Maxim Yurchuk <maxim-yurchuk@ydb.tech> | 2024-12-13 10:22:13 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-12-13 10:22:13 +0000 |
| commit | e73e490feb4e1f63d097697324aa48b643a62317 (patch) | |
| tree | f63fe3d15819a5148ade51609c5211251d93e425 /yt/cpp/mapreduce/client/operation_preparer.cpp | |
| parent | 19346460a8060a0ed4731edb192745642ff34b3d (diff) | |
| parent | 4dde77404d1eae4a633d1cc3807142409a9938eb (diff) | |
| download | ydb-e73e490feb4e1f63d097697324aa48b643a62317.tar.gz | |
Merge pull request #12582 from vitalyisaev2/rightlib_20241212
Merge rightlib 20241212
Diffstat (limited to 'yt/cpp/mapreduce/client/operation_preparer.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/client/operation_preparer.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/yt/cpp/mapreduce/client/operation_preparer.cpp b/yt/cpp/mapreduce/client/operation_preparer.cpp index 07d00e88d6..a6d424c5a1 100644 --- a/yt/cpp/mapreduce/client/operation_preparer.cpp +++ b/yt/cpp/mapreduce/client/operation_preparer.cpp @@ -17,6 +17,7 @@ #include <yt/cpp/mapreduce/raw_client/raw_batch_request.h> #include <yt/cpp/mapreduce/interface/error_codes.h> +#include <yt/cpp/mapreduce/interface/raw_client.h> #include <yt/cpp/mapreduce/interface/logging/yt_log.h> @@ -395,7 +396,8 @@ TJobPreparer::TJobPreparer( size_t outputTableCount, const TVector<TSmallJobFile>& smallFileList, const TOperationOptions& options) - : OperationPreparer_(operationPreparer) + : RawClient_(operationPreparer.GetClient()->GetRawClient()) + , OperationPreparer_(operationPreparer) , Spec_(spec) , Options_(options) , Layers_(spec.Layers_) @@ -631,6 +633,7 @@ TMaybe<TString> TJobPreparer::TryUploadWithDeduplication(const IItemToUpload& it CreateFileInCypress(cypressPath); auto uploadTx = MakeIntrusive<TTransaction>( + OperationPreparer_.GetClient()->GetRawClient(), OperationPreparer_.GetClient(), OperationPreparer_.GetContext(), TTransactionId(), |