4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 389 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Node local: 37
Shuffle Read Size / Records:
8.7 MiB / 156014
Shuffle Write Size / Records:
559.8 KiB / 9999
Associated Job Ids:
150
DAG Visualization
digraph G { id="graph_389"; subgraph graph_stage_389 { id="graph_stage_389"; isCluster="true"; label="Stage 389"; subgraph cluster_1851 { id="cluster_1851"; isCluster="true"; label="Exchange"; 670 [id="node_670" labelType="html" label="ShuffledRowRDD [670] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1934 { id="cluster_1934"; isCluster="true"; label="Exchange"; 699 [id="node_699" labelType="html" label="ShuffledRowRDD [699] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1930 { id="cluster_1930"; isCluster="true"; label="WholeStageCodegen (211)"; 700 [id="node_700" labelType="html" label="MapPartitionsRDD [700] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1936 { id="cluster_1936"; isCluster="true"; label="WholeStageCodegen (212)"; 701 [id="node_701" labelType="html" label="MapPartitionsRDD [701] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1927 { id="cluster_1927"; isCluster="true"; label="WholeStageCodegen (213)"; 702 [id="node_702" labelType="html" label="ZippedPartitionsRDD2 [702] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 703 [id="node_703" labelType="html" label="MapPartitionsRDD [703] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1926 { id="cluster_1926"; isCluster="true"; label="Project"; 704 [id="node_704" labelType="html" label="MapPartitionsRDD [704] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1920 { id="cluster_1920"; isCluster="true"; label="WholeStageCodegen (214)"; 705 [id="node_705" labelType="html" label="MapPartitionsRDD [705] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1919 { id="cluster_1919"; isCluster="true"; label="Exchange"; 706 [id="node_706" labelType="html" label="MapPartitionsRDD [706] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 699->700; 670->701; 700->702; 701->702; 702->703; 703->704; 704->705; 705->706; }
624,670
664,699
Event Timeline
Enable zooming
Tasks: 37. 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