4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1262852 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
18 ms
Locality Level Summary:
Process local: 30
Input Size / Records:
1495.0 B / 4
Shuffle Write Size / Records:
276.0 B / 3
Associated Job Ids:
40879
DAG Visualization
digraph G { id="graph_1262852"; subgraph graph_stage_1262852 { id="graph_stage_1262852"; isCluster="true"; label="Stage 1262852"; 331880 [id="node_331880" labelType="html" label="SQLExecutionRDD [331880] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; subgraph cluster_853630 { id="cluster_853630"; isCluster="true"; label="Exchange"; 331875 [id="node_331875" labelType="html" label="ShuffledRowRDD [331875] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853629 { id="cluster_853629"; isCluster="true"; label="ObjectHashAggregate"; 331876 [id="node_331876" labelType="html" label="MapPartitionsRDD [331876] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853608 { id="cluster_853608"; isCluster="true"; label="WholeStageCodegen (13)"; 331877 [id="node_331877" labelType="html" label="MapPartitionsRDD [331877] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853600 { id="cluster_853600"; isCluster="true"; label="DeserializeToObject"; 331878 [id="node_331878" labelType="html" label="MapPartitionsRDD [331878] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853594 { id="cluster_853594"; isCluster="true"; label="MapPartitions"; 331879 [id="node_331879" labelType="html" label="MapPartitionsRDD [331879] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853684 { id="cluster_853684"; isCluster="true"; label="mapPartitions"; 331881 [id="node_331881" labelType="html" label="MapPartitionsRDD [331881] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853874 { id="cluster_853874"; isCluster="true"; label="Scan"; 331925 [id="node_331925" labelType="html" label="MapPartitionsRDD [331925] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853863 { id="cluster_853863"; isCluster="true"; label="WholeStageCodegen (1)"; 331926 [id="node_331926" labelType="html" label="MapPartitionsRDD [331926] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853862 { id="cluster_853862"; isCluster="true"; label="Exchange"; 331927 [id="node_331927" labelType="html" label="MapPartitionsRDD [331927] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } } 331875->331876; 331876->331877; 331877->331878; 331878->331879; 331879->331880; 331880->331881; 331881->331925; 331925->331926; 331926->331927; }
331874,331875
331881
331880
331875
331876
331877
331878
331879
331881
331925
331926
331927
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