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

Resource Profile Id: 0
Total Time Across All Tasks: 47 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: 331364

digraph G { subgraph clusterstage_512908 { label="Stage 512908"; subgraph cluster6301286 { label="Exchange"; 3623741 [labelType="html" label="ShuffledRowRDD [3623741] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6301279 { label="WholeStageCodegen (3)"; 3623742 [labelType="html" label="MapPartitionsRDD [3623742] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6301278 { label="InMemoryTableScan"; 3623743 [labelType="html" label="MapPartitionsRDD [3623743] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3623744 [labelType="html" label="*(3) Project [cap#94356862, turnover#94354290, (1.0 / cast(turnover#94354290 as double)) AS days_hold#94356890]\n+- *(3) Sort [cap_sort#94356773 ASC NULLS FIRST], true, 0\n +- Exchange rangepartitioning(cap_sort#94356773 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7533670]\n +- *(2) Project [turnover#94354290, cap_description#94356772 AS cap#94356862, cap_sort#94356773]\n +- *(2) BroadcastHashJoin [knownfloatingpointnormalized(normalizenanandzero(cap#94354236))], [knownfloatingpointnormalized(normalizenanandzero(cast(cap#94160394 as float)))], Inner, BuildLeft, false\n :- BroadcastExchange HashedRelationBroadcastMode(List(knownfloatingpointnormalized(normalizenanandzero(input[0, float, false]))),false), [id=#7533662]\n : +- *(1) Filter isnotnull(cap#94354236)\n : +- InMemoryTableScan [cap#94354236, turnover#94354290], [isnotnull(cap#94354236)]\n : +- InMemoryRelation [cap#94354236, retIC#94354237, resretIC#94354238, numcos#94354239, num... [3623744] [Cached] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3623745 [labelType="html" label="MapPartitionsRDD [3623745] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3623746 [labelType="html" label="MapPartitionsRDD [3623746] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3623747 [labelType="html" label="MapPartitionsRDD [3623747] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6301277 { label="CollectLimit"; 3623748 [labelType="html" label="MapPartitionsRDD [3623748] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3623749 [labelType="html" label="MapPartitionsRDD [3623749] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } } 3623741->3623742; 3623742->3623743; 3623743->3623744; 3623744->3623745; 3623745->3623746; 3623746->3623747; 3623747->3623748; 3623748->3623749; }

3623740,3623741

3623744

Event Timeline

Enable zooming