4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 189861 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
13 s
Locality Level Summary:
Any: 5; Node local: 25
Shuffle Read Size / Records:
39.9 MiB / 445104
Shuffle Write Size / Records:
32.1 MiB / 218936
Associated Job Ids:
52515
DAG Visualization
digraph G { id="graph_189861"; subgraph graph_stage_189861 { id="graph_stage_189861"; isCluster="true"; label="Stage 189861"; subgraph cluster_1104600 { id="cluster_1104600"; isCluster="true"; label="Exchange"; 422548 [id="node_422548" labelType="html" label="ShuffledRowRDD [422548] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104597 { id="cluster_1104597"; isCluster="true"; label="WholeStageCodegen (9)"; 422549 [id="node_422549" labelType="html" label="MapPartitionsRDD [422549] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104649 { id="cluster_1104649"; isCluster="true"; label="Exchange"; 422575 [id="node_422575" labelType="html" label="ShuffledRowRDD [422575] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104646 { id="cluster_1104646"; isCluster="true"; label="WholeStageCodegen (17)"; 422576 [id="node_422576" labelType="html" label="MapPartitionsRDD [422576] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104593 { id="cluster_1104593"; isCluster="true"; label="WholeStageCodegen (18)"; 422577 [id="node_422577" labelType="html" label="ZippedPartitionsRDD2 [422577] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 422578 [id="node_422578" labelType="html" label="MapPartitionsRDD [422578] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104592 { id="cluster_1104592"; isCluster="true"; label="ObjectHashAggregate"; 422579 [id="node_422579" labelType="html" label="MapPartitionsRDD [422579] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104591 { id="cluster_1104591"; isCluster="true"; label="Exchange"; 422580 [id="node_422580" labelType="html" label="MapPartitionsRDD [422580] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 422548->422549; 422575->422576; 422549->422577; 422576->422577; 422577->422578; 422578->422579; 422579->422580; }
422547,422548
422574,422575
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