4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 101227 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
4 s
Locality Level Summary:
Node local: 34
Shuffle Read Size / Records:
2.9 MiB / 868
Shuffle Write Size / Records:
2.9 MiB / 434
Associated Job Ids:
5549
DAG Visualization
digraph G { id="graph_101227"; subgraph graph_stage_101227 { id="graph_stage_101227"; isCluster="true"; label="Stage 101227"; subgraph cluster_125089 { id="cluster_125089"; isCluster="true"; label="AQEShuffleRead"; 47861 [id="node_47861" labelType="html" label="ShuffledRowRDD [47861] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125086 { id="cluster_125086"; isCluster="true"; label="WholeStageCodegen (61)"; 47862 [id="node_47862" labelType="html" label="MapPartitionsRDD [47862] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125094 { id="cluster_125094"; isCluster="true"; label="AQEShuffleRead"; 47863 [id="node_47863" labelType="html" label="ShuffledRowRDD [47863] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125091 { id="cluster_125091"; isCluster="true"; label="WholeStageCodegen (62)"; 47864 [id="node_47864" labelType="html" label="MapPartitionsRDD [47864] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125082 { id="cluster_125082"; isCluster="true"; label="WholeStageCodegen (63)"; 47865 [id="node_47865" labelType="html" label="ZippedPartitionsRDD2 [47865] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 47866 [id="node_47866" labelType="html" label="MapPartitionsRDD [47866] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125081 { id="cluster_125081"; isCluster="true"; label="ObjectHashAggregate"; 47867 [id="node_47867" labelType="html" label="MapPartitionsRDD [47867] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125080 { id="cluster_125080"; isCluster="true"; label="Exchange"; 47868 [id="node_47868" labelType="html" label="MapPartitionsRDD [47868] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 47861->47862; 47863->47864; 47862->47865; 47864->47865; 47865->47866; 47866->47867; 47867->47868; }
47860,47861
47765,47863
Event Timeline
Enable zooming
Tasks: 34. 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