From 30f7be492fcd69bb5d702c028b155b19d6479647 Mon Sep 17 00:00:00 2001 From: haoranxu <3460172596@qq.com> Date: Sat, 9 May 2026 10:58:56 +0800 Subject: [PATCH] Add Notation to genDataLoadValue in pkg/ddc/alluxio/load_data.go Signed-off-by: haoranxu <3460172596@qq.com> --- pkg/ddc/alluxio/load_data.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pkg/ddc/alluxio/load_data.go b/pkg/ddc/alluxio/load_data.go index 5bfd8c6fad7..2fd3383c713 100644 --- a/pkg/ddc/alluxio/load_data.go +++ b/pkg/ddc/alluxio/load_data.go @@ -100,6 +100,10 @@ func (e *AlluxioEngine) generateDataLoadValueFile(r cruntime.ReconcileRequestCon return valueFile.Name(), nil } +// genDataLoadValue builds a DataLoadValue for the Fluid dataloader Helm chart from the Alluxio worker +// image, the target Dataset, and the DataLoad CR. It fills scheduling options (affinity including +// run-after injection, nodeSelector, tolerations, schedulerName), resolves target paths with +// Fluid-native mount detection, and attaches owner references for the rendered load Job. func (e *AlluxioEngine) genDataLoadValue(image string, targetDataset *datav1alpha1.Dataset, dataload *datav1alpha1.DataLoad) (*cdataload.DataLoadValue, error) { // image pull secrets // if the environment variable is not set, it is still an empty slice