4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 445902 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
6 s
Locality Level Summary:
Node local: 8; Process local: 12
Shuffle Read Size / Records:
8.8 KiB / 15
Associated Job Ids:
154725
DAG Visualization
digraph G { id="graph_445902"; subgraph graph_stage_445902 { id="graph_stage_445902"; isCluster="true"; label="Stage 445902"; 1242309 [id="node_1242309" labelType="html" label="SQLExecutionRDD [1242309] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_3149393 { id="cluster_3149393"; isCluster="true"; label="Exchange"; 1242301 [id="node_1242301" labelType="html" label="ShuffledRowRDD [1242301] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149392 { id="cluster_3149392"; isCluster="true"; label="ObjectHashAggregate"; 1242302 [id="node_1242302" labelType="html" label="MapPartitionsRDD [1242302] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149391 { id="cluster_3149391"; isCluster="true"; label="Project"; 1242303 [id="node_1242303" labelType="html" label="MapPartitionsRDD [1242303] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149384 { id="cluster_3149384"; isCluster="true"; label="WholeStageCodegen (12)"; 1242304 [id="node_1242304" labelType="html" label="MapPartitionsRDD [1242304] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149383 { id="cluster_3149383"; isCluster="true"; label="DeserializeToObject"; 1242305 [id="node_1242305" labelType="html" label="MapPartitionsRDD [1242305] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149382 { id="cluster_3149382"; isCluster="true"; label="MapPartitions"; 1242306 [id="node_1242306" labelType="html" label="MapPartitionsRDD [1242306] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149333 { id="cluster_3149333"; isCluster="true"; label="WholeStageCodegen (15)"; 1242307 [id="node_1242307" labelType="html" label="MapPartitionsRDD [1242307] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149322 { id="cluster_3149322"; isCluster="true"; label="DeserializeToObject"; 1242308 [id="node_1242308" labelType="html" label="MapPartitionsRDD [1242308] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149448 { id="cluster_3149448"; isCluster="true"; label="mapPartitions"; 1242310 [id="node_1242310" labelType="html" label="MapPartitionsRDD [1242310] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149449 { id="cluster_3149449"; isCluster="true"; label="mapPartitions"; 1242311 [id="node_1242311" labelType="html" label="MapPartitionsRDD [1242311] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 1242301->1242302; 1242302->1242303; 1242303->1242304; 1242304->1242305; 1242305->1242306; 1242306->1242307; 1242307->1242308; 1242308->1242309; 1242309->1242310; 1242310->1242311; }
1242300,1242301
1242311
Event Timeline
Enable zooming
Tasks: 20. 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