diff --git a/controllers/druid/volume_expansion.go b/controllers/druid/volume_expansion.go index e8b64934..3ae6ee07 100644 --- a/controllers/druid/volume_expansion.go +++ b/controllers/druid/volume_expansion.go @@ -106,7 +106,7 @@ func scalePVCForSts(ctx context.Context, sdk client.Client, nodeSpec *v1alpha1.D } pvcLabels := map[string]string{ - "component": nodeSpec.NodeType, + "nodeSpecUniqueStr": nodeSpecUniqueStr, } pvcList, err := readers.List(ctx, sdk, drd, pvcLabels, emitEvent, func() objectList { return &v1.PersistentVolumeClaimList{} }, func(listObj runtime.Object) []object {