PlusAMP App Middleware - Details for Stage 512349 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 1 s
Locality Level Summary: Node local: 200
Shuffle Read Size / Records: 100.9 KiB / 5034
Shuffle Write Size / Records: 100.9 KiB / 5034
Associated Job Ids: 330993

digraph G { subgraph clusterstage_512349 { label="Stage 512349"; subgraph cluster6294254 { label="Exchange"; 3619651 [labelType="html" label="ShuffledRowRDD [3619651] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6294251 { label="WholeStageCodegen (2)"; 3619652 [labelType="html" label="MapPartitionsRDD [3619652] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6294250 { label="InMemoryTableScan"; 3619653 [labelType="html" label="MapPartitionsRDD [3619653] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3619654 [labelType="html" label="*(2) Sort [date#94250291 ASC NULLS FIRST], true, 0\n+- Exchange rangepartitioning(date#94250291 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7525059]\n +- *(1) Project [date#94250291, allret#94250292 AS daily_gross#94250577, allretnet#94250296 AS daily_net#94250578]\n +- InMemoryTableScan [allret#94250292, allretnet#94250296, date#94250291]\n +- InMemoryRelation [date#94250291, allret#94250292, allcum#94250293, drawdown_gross#94250294, drawdown_length_gross#94250295, allretnet#94250296, allcumnet#94250297, drawdown_net#94250298, drawdown_length_net#94250299, numcos#94250300, largecum#94250301, largecumnet#94250325, largeret#94250326, largeretnet#94250352, midcum#94250353, midcumnet#94250354, midret#94250356, midretnet#94250357, smallcum#94250369, smallcumnet#94250370, smallret#94250371, smallretnet#94250372], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Project [CASE WHEN (date#94250069 = null) THEN null ELSE cast(date#94250069 as date) END AS date#942502... [3619654] [Cached] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3619655 [labelType="html" label="MapPartitionsRDD [3619655] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3619656 [labelType="html" label="MapPartitionsRDD [3619656] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3619657 [labelType="html" label="MapPartitionsRDD [3619657] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6294249 { label="CollectLimit"; 3619658 [labelType="html" label="MapPartitionsRDD [3619658] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3619659 [labelType="html" label="MapPartitionsRDD [3619659] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } } 3619651->3619652; 3619652->3619653; 3619653->3619654; 3619654->3619655; 3619655->3619656; 3619656->3619657; 3619657->3619658; 3619658->3619659; }

3619650,3619651

3619654

Event Timeline

Enable zooming