4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1273304 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
5 s
Locality Level Summary:
Node local: 3; Process local: 27
Shuffle Read Size / Records:
945.0 B / 6
Shuffle Write Size / Records:
1442.0 B / 2
Associated Job Ids:
41135
DAG Visualization
digraph G { id="graph_1273304"; subgraph graph_stage_1273304 { id="graph_stage_1273304"; isCluster="true"; label="Stage 1273304"; 334229 [id="node_334229" labelType="html" label="SQLExecutionRDD [334229] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; subgraph cluster_859614 { id="cluster_859614"; isCluster="true"; label="Exchange"; 334213 [id="node_334213" labelType="html" label="ShuffledRowRDD [334213] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_859611 { id="cluster_859611"; isCluster="true"; label="WholeStageCodegen (3)"; 334214 [id="node_334214" labelType="html" label="MapPartitionsRDD [334214] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_859629 { id="cluster_859629"; isCluster="true"; label="Exchange"; 334224 [id="node_334224" labelType="html" label="ShuffledRowRDD [334224] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_859626 { id="cluster_859626"; isCluster="true"; label="WholeStageCodegen (8)"; 334225 [id="node_334225" labelType="html" label="MapPartitionsRDD [334225] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_859607 { id="cluster_859607"; isCluster="true"; label="WholeStageCodegen (9)"; 334226 [id="node_334226" labelType="html" label="ZippedPartitionsRDD2 [334226] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; 334227 [id="node_334227" labelType="html" label="MapPartitionsRDD [334227] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_859606 { id="cluster_859606"; isCluster="true"; label="DeserializeToObject"; 334228 [id="node_334228" labelType="html" label="MapPartitionsRDD [334228] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_859649 { id="cluster_859649"; isCluster="true"; label="mapPartitions"; 334230 [id="node_334230" labelType="html" label="MapPartitionsRDD [334230] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_859650 { id="cluster_859650"; isCluster="true"; label="repartition"; 334231 [id="node_334231" labelType="html" label="MapPartitionsRDD [334231] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } } 334213->334214; 334224->334225; 334214->334226; 334225->334226; 334226->334227; 334227->334228; 334228->334229; 334229->334230; 334230->334231; }
334212,334213
334223,334224
334229
334213
334214
334224
334225
334226
334227
334228
334230
334231
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