4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 446123 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1 s
Locality Level Summary:
Node local: 20
Shuffle Read Size / Records:
19.9 KiB / 128
Associated Job Ids:
154800
DAG Visualization
digraph G { id="graph_446123"; subgraph graph_stage_446123 { id="graph_stage_446123"; isCluster="true"; label="Stage 446123"; subgraph cluster_3151001 { id="cluster_3151001"; isCluster="true"; label="Exchange"; 1242955 [id="node_1242955" labelType="html" label="ShuffledRowRDD [1242955] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150966 { id="cluster_3150966"; isCluster="true"; label="WholeStageCodegen (3)"; 1242956 [id="node_1242956" labelType="html" label="MapPartitionsRDD [1242956] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150965 { id="cluster_3150965"; isCluster="true"; label="ObjectHashAggregate"; 1242957 [id="node_1242957" labelType="html" label="MapPartitionsRDD [1242957] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150964 { id="cluster_3150964"; isCluster="true"; label="ObjectHashAggregate"; 1242958 [id="node_1242958" labelType="html" label="MapPartitionsRDD [1242958] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150963 { id="cluster_3150963"; isCluster="true"; label="DeserializeToObject"; 1242959 [id="node_1242959" labelType="html" label="MapPartitionsRDD [1242959] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 1242955->1242956; 1242956->1242957; 1242957->1242958; 1242958->1242959; }
1242954,1242955
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