When I run the Spark application (streaming) in local mode I could see the execution progress as below..
[Stage 0:========================================================================> (1817 + 1) / 3125] .... [Stage 2:=======================================> (740 + 1) / 3125] One of the stages is taking long time for execution. How to find the transformations/ actions associated with a particular stage? Is there anyway to find the execution DAG of a Spark Application? Regards Vijay
