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

Resource Profile Id: 0
Total Time Across All Tasks: 0.1 s
Locality Level Summary: Node local: 10
Shuffle Read Size / Records: 1237.0 B / 10
Shuffle Write Size / Records: 1237.0 B / 10
Associated Job Ids: 331373

digraph G { subgraph clusterstage_512925 { label="Stage 512925"; subgraph cluster6301519 { label="Exchange"; 3623830 [labelType="html" label="ShuffledRowRDD [3623830] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6301512 { label="WholeStageCodegen (3)"; 3623831 [labelType="html" label="MapPartitionsRDD [3623831] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6301511 { label="InMemoryTableScan"; 3623832 [labelType="html" label="MapPartitionsRDD [3623832] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3623833 [labelType="html" label="*(3) Sort [fractile#94360745 ASC NULLS FIRST], true, 0\n+- Exchange rangepartitioning(fractile#94360745 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7533897]\n +- *(2) Project [fractile#94360745, size#94360747, value#94360748, growth#94360749, leverage#94360750, volatility#94360751, momentum#94360752, yield#94360753, ##94360754, min_date#94360755, max_date#94360756]\n +- *(2) BroadcastHashJoin [cap_description#94360769], [description#94160396], Inner, BuildRight, false\n :- *(2) Project [fractile#94360745, cap#94360746 AS cap_description#94360769, size#94360747, value#94360748, growth#94360749, leverage#94360750, volatility#94360751, momentum#94360752, yield#94360753, ##94360754, min_date#94360755, max_date#94360756]\n : +- *(2) Filter ((isnotnull(fractile#94360745) AND NOT (fractile#94360745 = -1)) AND isnotnull(cap#94360746))\n : +- InMemoryTableScan [##94360754, cap#94360746, fractile#94360745, growth#94360749, leverage#94360750, max_date#94360756, min_date#94360755, mo... [3623833] [Cached] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3623834 [labelType="html" label="MapPartitionsRDD [3623834] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3623835 [labelType="html" label="MapPartitionsRDD [3623835] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3623836 [labelType="html" label="MapPartitionsRDD [3623836] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6301510 { label="CollectLimit"; 3623837 [labelType="html" label="MapPartitionsRDD [3623837] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3623838 [labelType="html" label="MapPartitionsRDD [3623838] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } } 3623830->3623831; 3623831->3623832; 3623832->3623833; 3623833->3623834; 3623834->3623835; 3623835->3623836; 3623836->3623837; 3623837->3623838; }

3623829,3623830

3623833

Event Timeline

Enable zooming