diff --git a/pkg/ytconfig/node.go b/pkg/ytconfig/node.go index 1ff9fdd1..8c8b465c 100644 --- a/pkg/ytconfig/node.go +++ b/pkg/ytconfig/node.go @@ -325,7 +325,8 @@ func getDataNodeServerCarcass(spec *ytv1.DataNodesSpec) (DataNodeServer, error) } if quota != nil { storeLocation.Quota = *quota - + } + if location.LowWatermark != nil or storeLocation.Quota != nil { if location.LowWatermark != nil { storeLocation.LowWatermark = location.LowWatermark.Value() } else {