4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 111979 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
20 ms
Locality Level Summary:
Process local: 37
Input Size / Records:
1141.0 B / 1
Shuffle Write Size / Records:
92.0 B / 1
Associated Job Ids:
6105
DAG Visualization
digraph G { id="graph_111979"; subgraph graph_stage_111979 { id="graph_stage_111979"; isCluster="true"; label="Stage 111979"; subgraph cluster_139054 { id="cluster_139054"; isCluster="true"; label="Exchange"; 53436 [id="node_53436" labelType="html" label="ShuffledRowRDD [53436] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139053 { id="cluster_139053"; isCluster="true"; label="InMemoryTableScan"; 53437 [id="node_53437" labelType="html" label="MapPartitionsRDD [53437] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 53438 [id="node_53438" labelType="html" label="Exchange hashpartitioning(product#1011818, plant#1011819, 37), REPARTITION_BY_NUM, [plan_id=1690914]\n+- *(1) Scan ExistingRDD[shardId#1011815,worklistShardItemId#1011816L,version#1011817,product#1011818,plant#1011819,periodStart#1011820,periodEnd#1011821,qty#1011822]\n [53438] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139082 { id="cluster_139082"; isCluster="true"; label="InMemoryTableScan"; 53447 [id="node_53447" labelType="html" label="MapPartitionsRDD [53447] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 53448 [id="node_53448" labelType="html" label="MapPartitionsRDD [53448] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 53449 [id="node_53449" labelType="html" label="MapPartitionsRDD [53449] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139079 { id="cluster_139079"; isCluster="true"; label="WholeStageCodegen (1)"; 53450 [id="node_53450" labelType="html" label="MapPartitionsRDD [53450] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139078 { id="cluster_139078"; isCluster="true"; label="Exchange"; 53451 [id="node_53451" labelType="html" label="MapPartitionsRDD [53451] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } } 53436->53437; 53437->53438; 53438->53447; 53447->53448; 53448->53449; 53449->53450; 53450->53451; }
53435,53436
53438
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