4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 190310 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2.4 min
Locality Level Summary:
Any: 10; Node local: 20
Shuffle Read Size / Records:
17.7 MiB / 239722
Associated Job Ids:
52603
DAG Visualization
digraph G { id="graph_190310"; subgraph graph_stage_190310 { id="graph_stage_190310"; isCluster="true"; label="Stage 190310"; 423747 [id="node_423747" labelType="html" label="SQLExecutionRDD [423747] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1107460 { id="cluster_1107460"; isCluster="true"; label="Exchange"; 423725 [id="node_423725" labelType="html" label="ShuffledRowRDD [423725] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107457 { id="cluster_1107457"; isCluster="true"; label="WholeStageCodegen (19)"; 423726 [id="node_423726" labelType="html" label="MapPartitionsRDD [423726] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107582 { id="cluster_1107582"; isCluster="true"; label="Exchange"; 423739 [id="node_423739" labelType="html" label="ShuffledRowRDD [423739] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107579 { id="cluster_1107579"; isCluster="true"; label="WholeStageCodegen (22)"; 423740 [id="node_423740" labelType="html" label="MapPartitionsRDD [423740] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107452 { id="cluster_1107452"; isCluster="true"; label="WholeStageCodegen (23)"; 423741 [id="node_423741" labelType="html" label="ZippedPartitionsRDD2 [423741] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 423742 [id="node_423742" labelType="html" label="MapPartitionsRDD [423742] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107451 { id="cluster_1107451"; isCluster="true"; label="DeserializeToObject"; 423743 [id="node_423743" labelType="html" label="MapPartitionsRDD [423743] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107450 { id="cluster_1107450"; isCluster="true"; label="MapPartitions"; 423744 [id="node_423744" labelType="html" label="MapPartitionsRDD [423744] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107428 { id="cluster_1107428"; isCluster="true"; label="WholeStageCodegen (26)"; 423745 [id="node_423745" labelType="html" label="MapPartitionsRDD [423745] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107427 { id="cluster_1107427"; isCluster="true"; label="DeserializeToObject"; 423746 [id="node_423746" labelType="html" label="MapPartitionsRDD [423746] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107595 { id="cluster_1107595"; isCluster="true"; label="mapPartitions"; 423748 [id="node_423748" labelType="html" label="MapPartitionsRDD [423748] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107596 { id="cluster_1107596"; isCluster="true"; label="mapPartitions"; 423749 [id="node_423749" labelType="html" label="MapPartitionsRDD [423749] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 423725->423726; 423739->423740; 423726->423741; 423740->423741; 423741->423742; 423742->423743; 423743->423744; 423744->423745; 423745->423746; 423746->423747; 423747->423748; 423748->423749; }
423724,423725
423738,423739
423749
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