diff options
author | slysheva <slysheva@yandex-team.com> | 2023-11-15 14:07:59 +0300 |
---|---|---|
committer | slysheva <slysheva@yandex-team.com> | 2023-11-15 14:51:43 +0300 |
commit | 75b8ed89473d7f20aba51749c7c0c73bb17a3d40 (patch) | |
tree | 2484d8fcc4b599b88e3110937d6eae996bd7bf4c /yt/cpp/mapreduce/client/retry_heavy_write_request.cpp | |
parent | a039451413668558443c36c16a466cd105f856ce (diff) | |
download | ydb-75b8ed89473d7f20aba51749c7c0c73bb17a3d40.tar.gz |
YT: fix duplicated proxy in url for write_file request
YT: fix duplicated proxy in url for write_file request
Diffstat (limited to 'yt/cpp/mapreduce/client/retry_heavy_write_request.cpp')
-rw-r--r-- | yt/cpp/mapreduce/client/retry_heavy_write_request.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/yt/cpp/mapreduce/client/retry_heavy_write_request.cpp b/yt/cpp/mapreduce/client/retry_heavy_write_request.cpp index c72f42089f..54a2be02e3 100644 --- a/yt/cpp/mapreduce/client/retry_heavy_write_request.cpp +++ b/yt/cpp/mapreduce/client/retry_heavy_write_request.cpp @@ -56,7 +56,10 @@ void RetryHeavyWriteRequest( header.AddTransactionId(attemptTx.GetId(), /* overwrite = */ true); header.SetRequestCompression(ToString(context.Config->ContentEncoding)); - auto request = context.HttpClient->StartRequest(GetFullUrl(hostName, context, header), requestId, header); + auto request = context.HttpClient->StartRequest( + GetFullUrlForProxy(hostName, context, header), + requestId, + header); TransferData(input.Get(), request->GetStream()); request->Finish()->GetResponse(); } catch (TErrorResponse& e) { |