4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 446362 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Node local: 10; Process local: 10
Shuffle Read Size / Records:
12.3 KiB / 36
Shuffle Write Size / Records:
9.8 KiB / 15
Associated Job Ids:
154880
DAG Visualization
digraph G { id="graph_446362"; subgraph graph_stage_446362 { id="graph_stage_446362"; isCluster="true"; label="Stage 446362"; subgraph cluster_3152693 { id="cluster_3152693"; isCluster="true"; label="Exchange"; 1243639 [id="node_1243639" labelType="html" label="ShuffledRowRDD [1243639] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152690 { id="cluster_3152690"; isCluster="true"; label="WholeStageCodegen (6)"; 1243640 [id="node_1243640" labelType="html" label="MapPartitionsRDD [1243640] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152725 { id="cluster_3152725"; isCluster="true"; label="Exchange"; 1243650 [id="node_1243650" labelType="html" label="ShuffledRowRDD [1243650] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152722 { id="cluster_3152722"; isCluster="true"; label="WholeStageCodegen (12)"; 1243651 [id="node_1243651" labelType="html" label="MapPartitionsRDD [1243651] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152686 { id="cluster_3152686"; isCluster="true"; label="WholeStageCodegen (13)"; 1243652 [id="node_1243652" labelType="html" label="ZippedPartitionsRDD2 [1243652] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 1243653 [id="node_1243653" labelType="html" label="MapPartitionsRDD [1243653] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152685 { id="cluster_3152685"; isCluster="true"; label="ObjectHashAggregate"; 1243654 [id="node_1243654" labelType="html" label="MapPartitionsRDD [1243654] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152684 { id="cluster_3152684"; isCluster="true"; label="Exchange"; 1243655 [id="node_1243655" labelType="html" label="MapPartitionsRDD [1243655] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 1243639->1243640; 1243650->1243651; 1243640->1243652; 1243651->1243652; 1243652->1243653; 1243653->1243654; 1243654->1243655; }
1243638,1243639
1243649,1243650
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