File tree 2 files changed +8
-3
lines changed
2 files changed +8
-3
lines changed Original file line number Diff line number Diff line change 44
44
#include < library/cpp/lwtrace/mon/mon_lwtrace.h>
45
45
#include < library/cpp/monlib/service/pages/templates.h>
46
46
#include < library/cpp/resource/resource.h>
47
-
47
+ # include < util/generic/guid.h >
48
48
49
49
namespace NKikimr ::NKqp {
50
50
@@ -234,9 +234,14 @@ class TKqpProxyService : public TActorBootstrapped<TKqpProxyService> {
234
234
WhiteBoardService = NNodeWhiteboard::MakeNodeWhiteboardServiceId (SelfId ().NodeId ());
235
235
236
236
if (auto & cfg = TableServiceConfig.GetSpillingServiceConfig ().GetLocalFileConfig (); cfg.GetEnable ()) {
237
+ TString spillingRoot = cfg.GetRoot ();
238
+ if (spillingRoot.empty ()) {
239
+ spillingRoot = TStringBuilder () << " /tmp/ydb_spilling_" << CreateGuidAsString () << " /" ;
240
+ }
241
+
237
242
SpillingService = TlsActivationContext->ExecutorThread .RegisterActor (NYql::NDq::CreateDqLocalFileSpillingService (
238
243
NYql::NDq::TFileSpillingServiceConfig{
239
- .Root = cfg. GetRoot () ,
244
+ .Root = spillingRoot ,
240
245
.MaxTotalSize = cfg.GetMaxTotalSize (),
241
246
.MaxFileSize = cfg.GetMaxFileSize (),
242
247
.MaxFilePartSize = cfg.GetMaxFilePartSize (),
Original file line number Diff line number Diff line change @@ -48,7 +48,7 @@ message TTableServiceConfig {
48
48
message TSpillingServiceConfig {
49
49
message TLocalFileConfig {
50
50
optional bool Enable = 1 [default = true ];
51
- optional string Root = 2 [default = "/tmp/kikimr_spilling/ " ];
51
+ optional string Root = 2 [default = "" ];
52
52
optional uint64 MaxTotalSize = 3 [default = 21474836480 ]; // 20 GiB
53
53
optional uint64 MaxFileSize = 4 [default = 5368709120 ]; // 5 GiB
54
54
optional uint64 MaxFilePartSize = 5 [default = 104857600 ]; // 100 MB
You can’t perform that action at this time.
0 commit comments