4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 69289 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1 s
Locality Level Summary:
Process local: 30
Input Size / Records:
41.5 KiB / 30
Associated Job Ids:
25711
DAG Visualization
digraph G { id="graph_69289"; subgraph graph_stage_69289 { id="graph_stage_69289"; isCluster="true"; label="Stage 69289"; subgraph cluster_514366 { id="cluster_514366"; isCluster="true"; label="Exchange"; 195206 [id="node_195206" labelType="html" label="ShuffledRowRDD [195206] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514365 { id="cluster_514365"; isCluster="true"; label="InMemoryTableScan"; 195207 [id="node_195207" labelType="html" label="MapPartitionsRDD [195207] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 195208 [id="node_195208" labelType="html" label="Exchange hashpartitioning(product#3371040, plant#3371041, 30), REPARTITION_BY_NUM, [plan_id=5494768]\n+- *(1) Scan ExistingRDD[shardId#3371037,worklistShardItemId#3371038L,version#3371039,product#3371040,plant#3371041,periodStart#3371042,periodEnd#3371043,qty#3371044]\n [195208] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514545 { id="cluster_514545"; isCluster="true"; label="InMemoryTableScan"; 195271 [id="node_195271" labelType="html" label="MapPartitionsRDD [195271] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 195272 [id="node_195272" labelType="html" label="MapPartitionsRDD [195272] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 195275 [id="node_195275" labelType="html" label="MapPartitionsRDD [195275] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514530 { id="cluster_514530"; isCluster="true"; label="WholeStageCodegen (4)"; 195278 [id="node_195278" labelType="html" label="MapPartitionsRDD [195278] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514523 { id="cluster_514523"; isCluster="true"; label="DeserializeToObject"; 195279 [id="node_195279" labelType="html" label="MapPartitionsRDD [195279] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 195206->195207; 195207->195208; 195208->195271; 195271->195272; 195272->195275; 195275->195278; 195278->195279; }
195205,195206
195208
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