YQL-18029: Make BinaryCacheFolder pragma cluster-specific (#11707)

Author: mxkovalev

ydb/library/yql/providers/yt/common/yql_yt_settings.cpp

@@ -391,7 +391,7 @@ TYtConfiguration::TYtConfiguration(TTypeAnnotationContext& typeCtx)
     REGISTER_SETTING(*this, LLVMNodeCountLimit);
     REGISTER_SETTING(*this, SamplingIoBlockSize);
     REGISTER_SETTING(*this, BinaryTmpFolder);
-    REGISTER_SETTING(*this, BinaryCacheFolder);
+    REGISTER_SETTING(*this, _BinaryCacheFolder);
     REGISTER_SETTING(*this, BinaryExpirationInterval);
     REGISTER_SETTING(*this, FolderInlineDataLimit);
     REGISTER_SETTING(*this, FolderInlineItemsLimit);

ydb/library/yql/providers/yt/common/yql_yt_settings.h

@@ -101,7 +101,6 @@ struct TYtSettings {
     NCommon::TConfSetting<TString, false> DefaultCluster;
     NCommon::TConfSetting<TString, false> StaticPool;
     NCommon::TConfSetting<TString, false> BinaryTmpFolder;
-    NCommon::TConfSetting<TString, false> BinaryCacheFolder;
     NCommon::TConfSetting<TDuration, false> BinaryExpirationInterval;
     NCommon::TConfSetting<bool, false> IgnoreTypeV3;
     NCommon::TConfSetting<bool, false> _UseMultisetAttributes;
@@ -207,6 +206,7 @@ struct TYtSettings {
     NCommon::TConfSetting<TSet<NUdf::EDataSlot>, true> BlockReaderSupportedDataTypes;
     NCommon::TConfSetting<TSet<TString>, true> JobBlockInputSupportedTypes;
     NCommon::TConfSetting<TSet<NUdf::EDataSlot>, true> JobBlockInputSupportedDataTypes;
+    NCommon::TConfSetting<TString, true> _BinaryCacheFolder;
 
     // Optimizers
     NCommon::TConfSetting<bool, true> _EnableDq;

ydb/library/yql/providers/yt/gateway/native/yql_yt_spec.cpp

@@ -572,7 +572,7 @@ void FillUserJobSpecImpl(NYT::TUserJobSpec& spec,
     }
 
     const TString binTmpFolder = settings->BinaryTmpFolder.Get().GetOrElse(TString());
-    const TString binCacheFolder = settings->BinaryCacheFolder.Get().GetOrElse(TString());
+    const TString binCacheFolder = settings->_BinaryCacheFolder.Get(cluster).GetOrElse(TString());
     if (!localRun && (binTmpFolder || binCacheFolder)) {
         TString bin = mrJobBin.empty() ? GetPersistentExecPath() : mrJobBin;
         const auto binSize = TFileStat(bin).Size;

ydb/library/yql/providers/yt/gateway/native/yql_yt_transform.cpp

@@ -444,7 +444,7 @@ void TGatewayTransformer::ApplyUserJobSpec(NYT::TUserJobSpec& spec, bool localRu
         spec.AddLocalFile(file.first, opts);
     }
     const TString binTmpFolder = Settings_->BinaryTmpFolder.Get().GetOrElse(TString());
-    const TString binCacheFolder = Settings_->BinaryCacheFolder.Get().GetOrElse(TString());
+    const TString binCacheFolder = Settings_->_BinaryCacheFolder.Get(ExecCtx_.Cluster_).GetOrElse(TString());
     if (!localRun && binCacheFolder) {
         auto udfFiles = std::move(*DeferredUdfFiles_);
         TTransactionCache::TEntry::TPtr entry = GetEntry();