4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 446135 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
7 s
Locality Level Summary:
Node local: 20
Shuffle Read Size / Records:
69.6 KiB / 123
Associated Job Ids:
154804
DAG Visualization
digraph G { id="graph_446135"; subgraph graph_stage_446135 { id="graph_stage_446135"; isCluster="true"; label="Stage 446135"; 1243001 [id="node_1243001" labelType="html" label="SQLExecutionRDD [1243001] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_3151063 { id="cluster_3151063"; isCluster="true"; label="Exchange"; 1242993 [id="node_1242993" labelType="html" label="ShuffledRowRDD [1242993] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151062 { id="cluster_3151062"; isCluster="true"; label="ObjectHashAggregate"; 1242994 [id="node_1242994" labelType="html" label="MapPartitionsRDD [1242994] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151061 { id="cluster_3151061"; isCluster="true"; label="Project"; 1242995 [id="node_1242995" labelType="html" label="MapPartitionsRDD [1242995] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151054 { id="cluster_3151054"; isCluster="true"; label="WholeStageCodegen (16)"; 1242996 [id="node_1242996" labelType="html" label="MapPartitionsRDD [1242996] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151053 { id="cluster_3151053"; isCluster="true"; label="DeserializeToObject"; 1242997 [id="node_1242997" labelType="html" label="MapPartitionsRDD [1242997] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151052 { id="cluster_3151052"; isCluster="true"; label="MapPartitions"; 1242998 [id="node_1242998" labelType="html" label="MapPartitionsRDD [1242998] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150984 { id="cluster_3150984"; isCluster="true"; label="WholeStageCodegen (19)"; 1242999 [id="node_1242999" labelType="html" label="MapPartitionsRDD [1242999] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150963 { id="cluster_3150963"; isCluster="true"; label="DeserializeToObject"; 1243000 [id="node_1243000" labelType="html" label="MapPartitionsRDD [1243000] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151140 { id="cluster_3151140"; isCluster="true"; label="mapPartitions"; 1243002 [id="node_1243002" labelType="html" label="MapPartitionsRDD [1243002] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151141 { id="cluster_3151141"; isCluster="true"; label="mapPartitions"; 1243003 [id="node_1243003" labelType="html" label="MapPartitionsRDD [1243003] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 1242993->1242994; 1242994->1242995; 1242995->1242996; 1242996->1242997; 1242997->1242998; 1242998->1242999; 1242999->1243000; 1243000->1243001; 1243001->1243002; 1243002->1243003; }
1242992,1242993
1243003
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