Skip to content

Commit 37e906c

Browse files
committed
server: clean up default TempStorageConfig
We currently create an invalid initial `TempStorageConfig` (the `Path` isn't set). In practice, this config is overridden by `cli.initTempStorageConfig()`. We clean this up by leaving the initial `TempStorageConfig` empty. Epic: none Release note: None
1 parent 4c0b9c9 commit 37e906c

File tree

2 files changed

+9
-10
lines changed

2 files changed

+9
-10
lines changed

pkg/server/config.go

Lines changed: 6 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -608,9 +608,9 @@ func SetOpenFileLimitForOneStore() (uint64, error) {
608608

609609
// MakeConfig returns a Config for the system tenant with default values.
610610
func MakeConfig(ctx context.Context, st *cluster.Settings) Config {
611-
storeSpec, tempStorageCfg := makeStorageCfg(ctx, st)
611+
storeSpec := makeStorageCfg(ctx, st)
612612
sqlCfg := MakeSQLConfig(roachpb.SystemTenantID,
613-
roachpb.TenantName(roachpb.SystemTenantID.String()), tempStorageCfg)
613+
roachpb.TenantName(roachpb.SystemTenantID.String()), base.TempStorageConfig{})
614614
tr := tracing.NewTracerWithOpt(ctx, tracing.WithClusterSettings(&st.SV))
615615
baseCfg := MakeBaseConfig(st, tr, storeSpec)
616616
kvCfg := MakeKVConfig()
@@ -628,23 +628,19 @@ func MakeConfig(ctx context.Context, st *cluster.Settings) Config {
628628
// preserving the base.Config reference. Enables running tests
629629
// multiple times.
630630
func (cfg *Config) SetDefaults(ctx context.Context, st *cluster.Settings) {
631-
storeSpec, tempStorageCfg := makeStorageCfg(ctx, st)
632-
cfg.SQLConfig.SetDefaults(tempStorageCfg)
631+
storeSpec := makeStorageCfg(ctx, st)
632+
cfg.SQLConfig.SetDefaults(base.TempStorageConfig{})
633633
cfg.KVConfig.SetDefaults()
634634
tr := tracing.NewTracerWithOpt(ctx, tracing.WithClusterSettings(&st.SV))
635635
cfg.BaseConfig.SetDefaults(st, tr, storeSpec)
636636
}
637637

638-
func makeStorageCfg(
639-
ctx context.Context, st *cluster.Settings,
640-
) (base.StoreSpec, base.TempStorageConfig) {
638+
func makeStorageCfg(ctx context.Context, st *cluster.Settings) base.StoreSpec {
641639
storeSpec, err := base.NewStoreSpec(DefaultStorePath)
642640
if err != nil {
643641
panic(err)
644642
}
645-
tempStorageCfg := base.TempStorageConfigFromEnv(
646-
ctx, st, storeSpec, "" /* parentDir */, base.DefaultTempStorageMaxSizeBytes)
647-
return storeSpec, tempStorageCfg
643+
return storeSpec
648644
}
649645

650646
// String implements the fmt.Stringer interface.

pkg/storage/temp_engine.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,9 @@ func newTempEngine(
6565
cacheSize = 8 << 20 // 8 MiB, smaller for in-memory, still non-zero
6666
baseFS = vfs.NewMem()
6767
} else {
68+
if tempStorage.Path == "" {
69+
return nil, nil, errors.AssertionFailedf("no path specified for temp storage")
70+
}
6871
baseFS = vfs.Default
6972
dir = tempStorage.Path
7073
}

0 commit comments

Comments
 (0)