4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1331960 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.1 s
Locality Level Summary:
Node local: 20; Process local: 10
Shuffle Read Size / Records:
136.9 KiB / 321
Shuffle Write Size / Records:
1748.0 B / 19
Associated Job Ids:
47066
DAG Visualization
digraph G { id="graph_1331960"; subgraph graph_stage_1331960 { id="graph_stage_1331960"; isCluster="true"; label="Stage 1331960"; subgraph cluster_1033934 { id="cluster_1033934"; isCluster="true"; label="Exchange"; 392592 [id="node_392592" labelType="html" label="ShuffledRowRDD [392592] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1033931 { id="cluster_1033931"; isCluster="true"; label="WholeStageCodegen (3)"; 392593 [id="node_392593" labelType="html" label="MapPartitionsRDD [392593] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1033940 { id="cluster_1033940"; isCluster="true"; label="Exchange"; 392596 [id="node_392596" labelType="html" label="ShuffledRowRDD [392596] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1033937 { id="cluster_1033937"; isCluster="true"; label="WholeStageCodegen (2)"; 392597 [id="node_392597" labelType="html" label="MapPartitionsRDD [392597] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1033924 { id="cluster_1033924"; isCluster="true"; label="WholeStageCodegen (4)"; 392598 [id="node_392598" labelType="html" label="ZippedPartitionsRDD2 [392598] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; 392599 [id="node_392599" labelType="html" label="MapPartitionsRDD [392599] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1033923 { id="cluster_1033923"; isCluster="true"; label="Exchange"; 392600 [id="node_392600" labelType="html" label="MapPartitionsRDD [392600] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } } 392592->392593; 392596->392597; 392593->392598; 392597->392598; 392598->392599; 392599->392600; }
392591,392592
392595,392596
392592
392593
392596
392597
392598
392599
392600
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