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

Resource Profile Id: 0
Total Time Across All Tasks: 37 ms
Locality Level Summary: Node local: 1; Process local: 1
Shuffle Read Size / Records: 134.0 B / 3
Shuffle Write Size / Records: 154.0 B / 3
Associated Job Ids: 331316

digraph G { subgraph clusterstage_512837 { label="Stage 512837"; subgraph cluster6300372 { label="Exchange"; 3623219 [labelType="html" label="ShuffledRowRDD [3623219] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6300362 { label="WholeStageCodegen (3)"; 3623220 [labelType="html" label="MapPartitionsRDD [3623220] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6300361 { label="InMemoryTableScan"; 3623221 [labelType="html" label="MapPartitionsRDD [3623221] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3623222 [labelType="html" label="*(3) Project [cap#94342537, turnover#94339491, (1.0 / cast(turnover#94339491 as double)) AS days_hold#94342568]\n+- *(3) Sort [cap_sort#94342448 ASC NULLS FIRST], true, 0\n +- Exchange rangepartitioning(cap_sort#94342448 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7532552]\n +- *(2) Project [turnover#94339491, cap_description#94342447 AS cap#94342537, cap_sort#94342448]\n +- *(2) BroadcastHashJoin [knownfloatingpointnormalized(normalizenanandzero(cap#94339344))], [knownfloatingpointnormalized(normalizenanandzero(cast(cap#94160394 as float)))], Inner, BuildLeft, false\n :- BroadcastExchange HashedRelationBroadcastMode(List(knownfloatingpointnormalized(normalizenanandzero(input[0, float, false]))),false), [id=#7532544]\n : +- *(1) Filter isnotnull(cap#94339344)\n : +- *(1) ColumnarToRow\n : +- InMemoryTableScan [cap#94339344, turnover#94339491], [isnotnull(cap#94339344)]\n : +- InMemoryRelation [cap#94339344, retIC#943... [3623222] [Cached] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3623223 [labelType="html" label="MapPartitionsRDD [3623223] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3623224 [labelType="html" label="MapPartitionsRDD [3623224] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3623225 [labelType="html" label="MapPartitionsRDD [3623225] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6300360 { label="CollectLimit"; 3623226 [labelType="html" label="MapPartitionsRDD [3623226] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3623227 [labelType="html" label="MapPartitionsRDD [3623227] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } } 3623219->3623220; 3623220->3623221; 3623221->3623222; 3623222->3623223; 3623223->3623224; 3623224->3623225; 3623225->3623226; 3623226->3623227; }

3623218,3623219

3623222

Event Timeline

Enable zooming