aboutsummaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/client/retry_heavy_write_request.cpp
diff options
context:
space:
mode:
authorslysheva <slysheva@yandex-team.com>2023-11-15 14:07:59 +0300
committerslysheva <slysheva@yandex-team.com>2023-11-15 14:51:43 +0300
commit75b8ed89473d7f20aba51749c7c0c73bb17a3d40 (patch)
tree2484d8fcc4b599b88e3110937d6eae996bd7bf4c /yt/cpp/mapreduce/client/retry_heavy_write_request.cpp
parenta039451413668558443c36c16a466cd105f856ce (diff)
downloadydb-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.cpp5
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) {