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

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

digraph G { subgraph clusterstage_512999 { label="Stage 512999"; subgraph cluster6302462 { label="Exchange"; 3624373 [labelType="html" label="ShuffledRowRDD [3624373] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6302455 { label="WholeStageCodegen (3)"; 3624374 [labelType="html" label="MapPartitionsRDD [3624374] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6302454 { label="InMemoryTableScan"; 3624375 [labelType="html" label="MapPartitionsRDD [3624375] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3624376 [labelType="html" label="*(3) Sort [fractile#94375202 ASC NULLS FIRST], true, 0\n+- Exchange rangepartitioning(fractile#94375202 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7535042]\n +- *(2) Project [fractile#94375202, size#94375204, value#94375205, growth#94375206, leverage#94375207, volatility#94375208, momentum#94375209, yield#94375210, ##94375211, min_date#94375212, max_date#94375213]\n +- *(2) BroadcastHashJoin [cap_description#94375226], [description#94160396], Inner, BuildRight, false\n :- *(2) Project [fractile#94375202, cap#94375203 AS cap_description#94375226, size#94375204, value#94375205, growth#94375206, leverage#94375207, volatility#94375208, momentum#94375209, yield#94375210, ##94375211, min_date#94375212, max_date#94375213]\n : +- *(2) Filter ((isnotnull(fractile#94375202) AND NOT (fractile#94375202 = -1)) AND isnotnull(cap#94375203))\n : +- InMemoryTableScan [##94375211, cap#94375203, fractile#94375202, growth#94375206, leverage#94375207, max_date#94375213, min_date#94375212, mo... [3624376] [Cached] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3624377 [labelType="html" label="MapPartitionsRDD [3624377] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3624378 [labelType="html" label="MapPartitionsRDD [3624378] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3624379 [labelType="html" label="MapPartitionsRDD [3624379] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6302453 { label="CollectLimit"; 3624380 [labelType="html" label="MapPartitionsRDD [3624380] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3624381 [labelType="html" label="MapPartitionsRDD [3624381] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } } 3624373->3624374; 3624374->3624375; 3624375->3624376; 3624376->3624377; 3624377->3624378; 3624378->3624379; 3624379->3624380; 3624380->3624381; }

3624372,3624373

3624376

Event Timeline

Enable zooming