diff --git a/internal/util/streamingutil/util/wal_selector.go b/internal/util/streamingutil/util/wal_selector.go index ef6c7abfba914..3c2f0c71f59b2 100644 --- a/internal/util/streamingutil/util/wal_selector.go +++ b/internal/util/streamingutil/util/wal_selector.go @@ -22,8 +22,8 @@ type walEnable struct { // MustSelectWALName select wal name. func MustSelectWALName() string { + standalone := paramtable.GetRole() == typeutil.StandaloneRole params := paramtable.Get() - standalone := params.RuntimeConfig.Role.GetAsString() == typeutil.StandaloneRole return mustSelectWALName(standalone, params.MQCfg.Type.GetValue(), walEnable{ params.RocksmqEnable(), params.PulsarEnable(),