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

Resource Profile Id: 0
Total Time Across All Tasks: 97 ms
Locality Level Summary: Node local: 10
Shuffle Read Size / Records: 1234.0 B / 10
Shuffle Write Size / Records: 1234.0 B / 10
Associated Job Ids: 331275

digraph G { subgraph clusterstage_512777 { label="Stage 512777"; subgraph cluster6299647 { label="Exchange"; 3622750 [labelType="html" label="ShuffledRowRDD [3622750] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6299640 { label="WholeStageCodegen (3)"; 3622751 [labelType="html" label="MapPartitionsRDD [3622751] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6299639 { label="InMemoryTableScan"; 3622752 [labelType="html" label="MapPartitionsRDD [3622752] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3622753 [labelType="html" label="*(3) Sort [fractile#94332073 ASC NULLS FIRST], true, 0\n+- Exchange rangepartitioning(fractile#94332073 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7531650]\n +- *(2) Project [fractile#94332073, size#94332075, value#94332076, growth#94332077, leverage#94332078, volatility#94332079, momentum#94332080, yield#94332081, ##94332082, min_date#94332083, max_date#94332084]\n +- *(2) BroadcastHashJoin [cap_description#94332097], [description#94160396], Inner, BuildRight, false\n :- *(2) Project [fractile#94332073, cap#94332074 AS cap_description#94332097, size#94332075, value#94332076, growth#94332077, leverage#94332078, volatility#94332079, momentum#94332080, yield#94332081, ##94332082, min_date#94332083, max_date#94332084]\n : +- *(2) Filter ((isnotnull(fractile#94332073) AND NOT (fractile#94332073 = -1)) AND isnotnull(cap#94332074))\n : +- InMemoryTableScan [##94332082, cap#94332074, fractile#94332073, growth#94332077, leverage#94332078, max_date#94332084, min_date#94332083, mo... [3622753] [Cached] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3622754 [labelType="html" label="MapPartitionsRDD [3622754] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3622755 [labelType="html" label="MapPartitionsRDD [3622755] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3622756 [labelType="html" label="MapPartitionsRDD [3622756] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6299638 { label="CollectLimit"; 3622757 [labelType="html" label="MapPartitionsRDD [3622757] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3622758 [labelType="html" label="MapPartitionsRDD [3622758] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } } 3622750->3622751; 3622751->3622752; 3622752->3622753; 3622753->3622754; 3622754->3622755; 3622755->3622756; 3622756->3622757; 3622757->3622758; }

3622749,3622750

3622753

Event Timeline

Enable zooming