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

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

digraph G { subgraph clusterstage_513147 { label="Stage 513147"; subgraph cluster6304328 { label="Exchange"; 3625447 [labelType="html" label="ShuffledRowRDD [3625447] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6304321 { label="WholeStageCodegen (3)"; 3625448 [labelType="html" label="MapPartitionsRDD [3625448] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6304320 { label="InMemoryTableScan"; 3625449 [labelType="html" label="MapPartitionsRDD [3625449] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3625450 [labelType="html" label="*(3) Sort [fractile#94402992 ASC NULLS FIRST], true, 0\n+- Exchange rangepartitioning(fractile#94402992 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7537338]\n +- *(2) Project [fractile#94402992, size#94402994, value#94402995, growth#94402996, leverage#94402997, volatility#94402998, momentum#94402999, yield#94403000, ##94403001, min_date#94403002, max_date#94403003]\n +- *(2) BroadcastHashJoin [cap_description#94403016], [description#94160396], Inner, BuildRight, false\n :- *(2) Project [fractile#94402992, cap#94402993 AS cap_description#94403016, size#94402994, value#94402995, growth#94402996, leverage#94402997, volatility#94402998, momentum#94402999, yield#94403000, ##94403001, min_date#94403002, max_date#94403003]\n : +- *(2) Filter ((isnotnull(fractile#94402992) AND NOT (fractile#94402992 = -1)) AND isnotnull(cap#94402993))\n : +- InMemoryTableScan [##94403001, cap#94402993, fractile#94402992, growth#94402996, leverage#94402997, max_date#94403003, min_date#94403002, mo... [3625450] [Cached] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3625451 [labelType="html" label="MapPartitionsRDD [3625451] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3625452 [labelType="html" label="MapPartitionsRDD [3625452] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3625453 [labelType="html" label="MapPartitionsRDD [3625453] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6304319 { label="CollectLimit"; 3625454 [labelType="html" label="MapPartitionsRDD [3625454] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3625455 [labelType="html" label="MapPartitionsRDD [3625455] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } } 3625447->3625448; 3625448->3625449; 3625449->3625450; 3625450->3625451; 3625451->3625452; 3625452->3625453; 3625453->3625454; 3625454->3625455; }

3625446,3625447

3625450

Event Timeline

Enable zooming