4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 95708 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
3 s
Locality Level Summary:
Node local: 1; Process local: 36
Shuffle Read Size / Records:
4.2 KiB / 2
Shuffle Write Size / Records:
4.1 KiB / 1
Associated Job Ids:
4970
DAG Visualization
digraph G { id="graph_95708"; subgraph graph_stage_95708 { id="graph_stage_95708"; isCluster="true"; label="Stage 95708"; subgraph cluster_113097 { id="cluster_113097"; isCluster="true"; label="Exchange"; 43467 [id="node_43467" labelType="html" label="ShuffledRowRDD [43467] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113094 { id="cluster_113094"; isCluster="true"; label="WholeStageCodegen (10)"; 43468 [id="node_43468" labelType="html" label="MapPartitionsRDD [43468] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113159 { id="cluster_113159"; isCluster="true"; label="Exchange"; 43483 [id="node_43483" labelType="html" label="ShuffledRowRDD [43483] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113156 { id="cluster_113156"; isCluster="true"; label="WholeStageCodegen (13)"; 43484 [id="node_43484" labelType="html" label="MapPartitionsRDD [43484] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113090 { id="cluster_113090"; isCluster="true"; label="WholeStageCodegen (14)"; 43485 [id="node_43485" labelType="html" label="ZippedPartitionsRDD2 [43485] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43486 [id="node_43486" labelType="html" label="MapPartitionsRDD [43486] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113089 { id="cluster_113089"; isCluster="true"; label="ObjectHashAggregate"; 43487 [id="node_43487" labelType="html" label="MapPartitionsRDD [43487] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113088 { id="cluster_113088"; isCluster="true"; label="Exchange"; 43488 [id="node_43488" labelType="html" label="MapPartitionsRDD [43488] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 43467->43468; 43483->43484; 43468->43485; 43484->43485; 43485->43486; 43486->43487; 43487->43488; }
43466,43467
43482,43483
43483
43484
43485
43486
43487
43488
Event Timeline
Enable zooming
Tasks: 37. 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