diff --git a/pkg/ytconfig/node.go b/pkg/ytconfig/node.go index 1ff9fdd1..dfa6b461 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 || quota != nil { if location.LowWatermark != nil { storeLocation.LowWatermark = location.LowWatermark.Value() } else { @@ -337,8 +338,8 @@ func getDataNodeServerCarcass(spec *ytv1.DataNodesSpec) (DataNodeServer, error) storeLocation.HighWatermark = storeLocation.LowWatermark / 2 storeLocation.DisableWritesWatermark = storeLocation.HighWatermark / 2 storeLocation.TrashCleanupWatermark = storeLocation.LowWatermark - storeLocation.MaxTrashTtl = location.MaxTrashMilliseconds } + storeLocation.MaxTrashTtl = location.MaxTrashMilliseconds c.DataNode.StoreLocations = append(c.DataNode.StoreLocations, storeLocation) }