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

Resource Profile Id: 0
Total Time Across All Tasks: 58 ms
Locality Level Summary: Node local: 1; Process local: 1
Shuffle Read Size / Records: 133.0 B / 3
Shuffle Write Size / Records: 155.0 B / 3
Associated Job Ids: 331413

digraph G { subgraph clusterstage_512982 { label="Stage 512982"; subgraph cluster6302246 { label="Exchange"; 3624284 [labelType="html" label="ShuffledRowRDD [3624284] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6302235 { label="WholeStageCodegen (3)"; 3624285 [labelType="html" label="MapPartitionsRDD [3624285] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6302234 { label="InMemoryTableScan"; 3624286 [labelType="html" label="MapPartitionsRDD [3624286] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3624287 [labelType="html" label="*(3) Project [cap#94371319, turnover#94368165, (1.0 / cast(turnover#94368165 as double)) AS days_hold#94371349]\n+- *(3) Sort [cap_sort#94371230 ASC NULLS FIRST], true, 0\n +- Exchange rangepartitioning(cap_sort#94371230 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7534802]\n +- *(2) Project [turnover#94368165, cap_description#94371229 AS cap#94371319, cap_sort#94371230]\n +- *(2) BroadcastHashJoin [knownfloatingpointnormalized(normalizenanandzero(cap#94368001))], [knownfloatingpointnormalized(normalizenanandzero(cast(cap#94160394 as float)))], Inner, BuildLeft, false\n :- BroadcastExchange HashedRelationBroadcastMode(List(knownfloatingpointnormalized(normalizenanandzero(input[0, float, false]))),false), [id=#7534794]\n : +- *(1) Filter isnotnull(cap#94368001)\n : +- *(1) ColumnarToRow\n : +- InMemoryTableScan [cap#94368001, turnover#94368165], [isnotnull(cap#94368001)]\n : +- InMemoryRelation [cap#94368001, retIC#943... [3624287] [Cached] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3624288 [labelType="html" label="MapPartitionsRDD [3624288] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3624289 [labelType="html" label="MapPartitionsRDD [3624289] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3624290 [labelType="html" label="MapPartitionsRDD [3624290] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6302232 { label="CollectLimit"; 3624291 [labelType="html" label="MapPartitionsRDD [3624291] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3624292 [labelType="html" label="MapPartitionsRDD [3624292] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } } 3624284->3624285; 3624285->3624286; 3624286->3624287; 3624287->3624288; 3624288->3624289; 3624289->3624290; 3624290->3624291; 3624291->3624292; }

3624283,3624284

3624287

Event Timeline

Enable zooming