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

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

digraph G { subgraph clusterstage_512851 { label="Stage 512851"; subgraph cluster6300591 { label="Exchange"; 3623293 [labelType="html" label="ShuffledRowRDD [3623293] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6300584 { label="WholeStageCodegen (3)"; 3623294 [labelType="html" label="MapPartitionsRDD [3623294] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6300583 { label="InMemoryTableScan"; 3623295 [labelType="html" label="MapPartitionsRDD [3623295] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3623296 [labelType="html" label="*(3) Sort [fractile#94346420 ASC NULLS FIRST], true, 0\n+- Exchange rangepartitioning(fractile#94346420 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7532792]\n +- *(2) Project [fractile#94346420, size#94346422, value#94346423, growth#94346424, leverage#94346425, volatility#94346426, momentum#94346427, yield#94346428, ##94346429, min_date#94346430, max_date#94346431]\n +- *(2) BroadcastHashJoin [cap_description#94346444], [description#94160396], Inner, BuildRight, false\n :- *(2) Project [fractile#94346420, cap#94346421 AS cap_description#94346444, size#94346422, value#94346423, growth#94346424, leverage#94346425, volatility#94346426, momentum#94346427, yield#94346428, ##94346429, min_date#94346430, max_date#94346431]\n : +- *(2) Filter ((isnotnull(fractile#94346420) AND NOT (fractile#94346420 = -1)) AND isnotnull(cap#94346421))\n : +- InMemoryTableScan [##94346429, cap#94346421, fractile#94346420, growth#94346424, leverage#94346425, max_date#94346431, min_date#94346430, mo... [3623296] [Cached] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3623297 [labelType="html" label="MapPartitionsRDD [3623297] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3623298 [labelType="html" label="MapPartitionsRDD [3623298] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3623299 [labelType="html" label="MapPartitionsRDD [3623299] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6300582 { label="CollectLimit"; 3623300 [labelType="html" label="MapPartitionsRDD [3623300] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3623301 [labelType="html" label="MapPartitionsRDD [3623301] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } } 3623293->3623294; 3623294->3623295; 3623295->3623296; 3623296->3623297; 3623297->3623298; 3623298->3623299; 3623299->3623300; 3623300->3623301; }

3623292,3623293

3623296

Event Timeline

Enable zooming