diff --git a/pkg/ddc/alluxio/dataset.go b/pkg/ddc/alluxio/dataset.go index 3c21a13f2cd..6bed893112a 100644 --- a/pkg/ddc/alluxio/dataset.go +++ b/pkg/ddc/alluxio/dataset.go @@ -75,13 +75,6 @@ func (e *AlluxioEngine) UpdateCacheOfDataset() (err error) { // UpdateDatasetStatus updates the status of the dataset func (e *AlluxioEngine) UpdateDatasetStatus(phase datav1alpha1.DatasetPhase) (err error) { - // 1. update the runtime status - runtime, err := e.getRuntime() - if err != nil { - return err - } - - // 2.update the dataset status err = retry.RetryOnConflict(retry.DefaultBackoff, func() error { dataset, err := utils.GetDataset(e.Client, e.name, e.namespace) if err != nil { @@ -127,10 +120,6 @@ func (e *AlluxioEngine) UpdateDatasetStatus(phase datav1alpha1.DatasetPhase) (er cond) } - // TODO: Do we have to update cachestates here? It is updated in AlluxioEngine.UpdateCacheOfDataset() - datasetToUpdate.Status.CacheStates = runtime.Status.CacheStates - // datasetToUpdate.Status.CacheStates = - if datasetToUpdate.Status.HCFSStatus == nil { datasetToUpdate.Status.HCFSStatus, err = e.GetHCFSStatus() if err != nil {