Method transformCommonPart

pkg/ddc/alluxio/transform.go:127–248

2. Transform the common part

(runtime *datav1alpha1.AlluxioRuntime,
	dataset *datav1alpha1.Dataset,
	value *Alluxio,
)

// 2. Transform the common part
func (e *AlluxioEngine) transformCommonPart(runtime *datav1alpha1.AlluxioRuntime,
	dataset *datav1alpha1.Dataset,
	value *Alluxio,
) (err error) {
	value.RuntimeIdentity.Namespace = runtime.Namespace
	value.RuntimeIdentity.Name = runtime.Name

	image := runtime.Spec.AlluxioVersion.Image
	imageTag := runtime.Spec.AlluxioVersion.ImageTag
	imagePullPolicy := runtime.Spec.AlluxioVersion.ImagePullPolicy
	imagePullSecrets := runtime.Spec.ImagePullSecrets

	value.Image, value.ImageTag, value.ImagePullPolicy, value.ImagePullSecrets = e.parseRuntimeImage(image, imageTag, imagePullPolicy, imagePullSecrets)

	value.UserInfo = common.UserInfo{
		User: 0,
		// FSGroup: 0,
		Group: 0,
	}

	// transform init users
	e.transformInitUsers(runtime, value)

	// TODO: support nodeAffinity

	if len(runtime.Spec.Properties) > 0 {
		value.Properties = runtime.Spec.Properties
	} else {
		value.Properties = map[string]string{}
	}

	// generate alluxio root ufs by dataset spec mounts
	e.Log.Info("input", "mounts", dataset.Spec.Mounts, "common.RootDirPath", common.RootDirPath)
	uRootPath, m := utils.UFSPathBuilder{}.GenAlluxioUFSRootPath(dataset.Spec.Mounts)
	// attach mount options when direct mount ufs endpoint
	if m != nil {
		extractEncryptOption := !IsMountWithConfigMap()
		if mOptions, err := e.genUFSMountOptions(*m, dataset.Spec.SharedOptions, dataset.Spec.SharedEncryptOptions, extractEncryptOption); err != nil {
			return err
		} else {
			for k, v := range mOptions {
				value.Properties[k] = v
			}
		}
	}
	e.Log.Info("output", "uRootPath", uRootPath, "m", m)
	// set alluxio root ufs
	value.Properties["alluxio.master.mount.table.root.ufs"] = uRootPath

	// Set the max replication
	dataReplicas := runtime.Spec.Data.Replicas
	if dataReplicas <= 0 {
		dataReplicas = 1
	}
	value.Properties["alluxio.user.file.replication.max"] = fmt.Sprintf("%d", dataReplicas)

	if len(runtime.Spec.JvmOptions) > 0 {
		value.JvmOptions = runtime.Spec.JvmOptions