4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1345567 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Process local: 30
Input Size / Records:
2.2 KiB / 2
Associated Job Ids:
47350
DAG Visualization
digraph G { id="graph_1345567"; subgraph graph_stage_1345567 { id="graph_stage_1345567"; isCluster="true"; label="Stage 1345567"; 395196 [id="node_395196" labelType="html" label="SQLExecutionRDD [395196] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; subgraph cluster_1039820 { id="cluster_1039820"; isCluster="true"; label="repartition"; 394802 [id="node_394802" labelType="html" label="ShuffledRDD [394802] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; 394803 [id="node_394803" labelType="html" label="CoalescedRDD [394803] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; 394804 [id="node_394804" labelType="html" label="MapPartitionsRDD [394804] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040842 { id="cluster_1040842"; isCluster="true"; label="map"; 395193 [id="node_395193" labelType="html" label="MapPartitionsRDD [395193] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040844 { id="cluster_1040844"; isCluster="true"; label="WholeStageCodegen (1)"; 395194 [id="node_395194" labelType="html" label="MapPartitionsRDD [395194] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040843 { id="cluster_1040843"; isCluster="true"; label="DeserializeToObject"; 395195 [id="node_395195" labelType="html" label="MapPartitionsRDD [395195] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040847 { id="cluster_1040847"; isCluster="true"; label="mapPartitions"; 395197 [id="node_395197" labelType="html" label="MapPartitionsRDD [395197] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040848 { id="cluster_1040848"; isCluster="true"; label="repartition"; 395198 [id="node_395198" labelType="html" label="MapPartitionsRDD [395198] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } } 394802->394803; 394803->394804; 394804->395193; 395193->395194; 395194->395195; 395195->395196; 395196->395197; 395197->395198; }
394801,394802
394804
395196
394802
394803
394804
395193
395194
395195
395197
395198
Event Timeline
Enable zooming
Tasks: 30. 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