4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 105700 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1 s
Locality Level Summary:
Node local: 1
Output Size / Records:
29.3 KiB / 1
Shuffle Read Size / Records:
264.0 B / 2
Associated Job Ids:
5800
DAG Visualization
digraph G { id="graph_105700"; subgraph graph_stage_105700 { id="graph_stage_105700"; isCluster="true"; label="Stage 105700"; subgraph cluster_131592 { id="cluster_131592"; isCluster="true"; label="AQEShuffleRead"; 50501 [id="node_50501" labelType="html" label="ShuffledRowRDD [50501] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_131589 { id="cluster_131589"; isCluster="true"; label="WholeStageCodegen (4)"; 50502 [id="node_50502" labelType="html" label="MapPartitionsRDD [50502] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_131597 { id="cluster_131597"; isCluster="true"; label="AQEShuffleRead"; 50503 [id="node_50503" labelType="html" label="ShuffledRowRDD [50503] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_131594 { id="cluster_131594"; isCluster="true"; label="WholeStageCodegen (5)"; 50504 [id="node_50504" labelType="html" label="MapPartitionsRDD [50504] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_131584 { id="cluster_131584"; isCluster="true"; label="WholeStageCodegen (6)"; 50505 [id="node_50505" labelType="html" label="ZippedPartitionsRDD2 [50505] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 50506 [id="node_50506" labelType="html" label="MapPartitionsRDD [50506] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_131583 { id="cluster_131583"; isCluster="true"; label="WriteFiles"; 50507 [id="node_50507" labelType="html" label="MapPartitionsRDD [50507] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 50501->50502; 50503->50504; 50502->50505; 50504->50505; 50505->50506; 50506->50507; }
50500,50501
50490,50503
Event Timeline
Enable zooming
Tasks: 1. 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