4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 285 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1.2 min
Locality Level Summary:
Any: 5; Node local: 32
Shuffle Read Size / Records:
2.2 GiB / 15986838
Shuffle Write Size / Records:
2.1 MiB / 9999
Associated Job Ids:
124
DAG Visualization
digraph G { id="graph_285"; subgraph graph_stage_285 { id="graph_stage_285"; isCluster="true"; label="Stage 285"; subgraph cluster_1543 { id="cluster_1543"; isCluster="true"; label="Exchange"; 572 [id="node_572" labelType="html" label="ShuffledRowRDD [572] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1539 { id="cluster_1539"; isCluster="true"; label="WholeStageCodegen (87)"; 573 [id="node_573" labelType="html" label="MapPartitionsRDD [573] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1549 { id="cluster_1549"; isCluster="true"; label="Exchange"; 574 [id="node_574" labelType="html" label="ShuffledRowRDD [574] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1545 { id="cluster_1545"; isCluster="true"; label="WholeStageCodegen (88)"; 575 [id="node_575" labelType="html" label="MapPartitionsRDD [575] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1536 { id="cluster_1536"; isCluster="true"; label="WholeStageCodegen (89)"; 576 [id="node_576" labelType="html" label="ZippedPartitionsRDD2 [576] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 577 [id="node_577" labelType="html" label="MapPartitionsRDD [577] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1535 { id="cluster_1535"; isCluster="true"; label="Exchange"; 578 [id="node_578" labelType="html" label="MapPartitionsRDD [578] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 572->573; 574->575; 573->576; 575->576; 576->577; 577->578; }
503,572
532,574
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