diff options
Diffstat (limited to 'yt/cpp/mapreduce/raw_client/raw_requests.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/raw_client/raw_requests.cpp | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/yt/cpp/mapreduce/raw_client/raw_requests.cpp b/yt/cpp/mapreduce/raw_client/raw_requests.cpp index 98a8aa07929..0b7bcf2c662 100644 --- a/yt/cpp/mapreduce/raw_client/raw_requests.cpp +++ b/yt/cpp/mapreduce/raw_client/raw_requests.cpp @@ -876,7 +876,13 @@ TNode::TListType SkyShareTable( host = "skynet." + proxyName + ".yt.yandex.net"; } - header.MergeParameters(SerializeParamsForSkyShareTable(proxyName, context.Config->Prefix, tablePaths, options)); + TSkyShareTableOptions patchedOptions = options; + + if (context.Config->Pool && !patchedOptions.Pool_) { + patchedOptions.Pool(context.Config->Pool); + } + + header.MergeParameters(SerializeParamsForSkyShareTable(proxyName, context.Config->Prefix, tablePaths, patchedOptions)); TClientContext skyApiHost({ .ServerName = host, .HttpClient = NHttpClient::CreateDefaultHttpClient() }); TResponseInfo response = {}; |
