4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 55 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Process local: 20
Associated Job Ids:
28
DAG Visualization
digraph G { id="graph_55"; subgraph graph_stage_55 { id="graph_stage_55"; isCluster="true"; label="Stage 55"; subgraph cluster_423 { id="cluster_423"; isCluster="true"; label="Exchange"; 178 [id="node_178" labelType="html" label="ShuffledRowRDD [178] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_422 { id="cluster_422"; isCluster="true"; label="InMemoryTableScan"; 179 [id="node_179" labelType="html" label="MapPartitionsRDD [179] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 180 [id="node_180" labelType="html" label="Exchange hashpartitioning(product#1494, plant#1495, 20), REPARTITION_BY_NUM, [plan_id=1301]\n+- *(1) Scan ExistingRDD[shardId#1491,worklistShardItemId#1492L,version#1493,product#1494,plant#1495,periodStart#1496,periodEnd#1497,qty#1498]\n [180] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 181 [id="node_181" labelType="html" label="MapPartitionsRDD [181] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 182 [id="node_182" labelType="html" label="MapPartitionsRDD [182] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 183 [id="node_183" labelType="html" label="MapPartitionsRDD [183] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_421 { id="cluster_421"; isCluster="true"; label="CollectLimit"; 184 [id="node_184" labelType="html" label="MapPartitionsRDD [184] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 185 [id="node_185" labelType="html" label="MapPartitionsRDD [185] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 178->179; 179->180; 180->181; 181->182; 182->183; 183->184; 184->185; }
177,178
180
Event Timeline
Enable zooming
Tasks: 20. 1 Pages. Jump to
. Show
items in a page.
Go
Scheduler Delay
Task Deserialization Time
Shuffle Read Time
Executor Computing Time
Shuffle Write Time
Result Serialization Time
Getting Result Time