here is the Scala code in github
It is hard to read the code to understand the mechanism of DAG. Wish someone could explain the mechanism of DAG. I know it schedules the job and tasks of Spark.But I don't know the detail.
here is the Scala code in github
It is hard to read the code to understand the mechanism of DAG. Wish someone could explain the mechanism of DAG. I know it schedules the job and tasks of Spark.But I don't know the detail.