4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 173179 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1 s
Locality Level Summary:
Process local: 60
Input Size / Records:
1990.0 B / 2
Associated Job Ids:
60564
DAG Visualization
digraph G { id="graph_173179"; subgraph graph_stage_173179 { id="graph_stage_173179"; isCluster="true"; label="Stage 173179"; subgraph cluster_1243081 { id="cluster_1243081"; isCluster="true"; label="Exchange"; 483570 [id="node_483570" labelType="html" label="ShuffledRowRDD [483570] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243080 { id="cluster_1243080"; isCluster="true"; label="InMemoryTableScan"; 483571 [id="node_483571" labelType="html" label="MapPartitionsRDD [483571] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 483572 [id="node_483572" labelType="html" label="Exchange hashpartitioning(product#7905121, plant#7905122, 30), REPARTITION_BY_NUM, [plan_id=11190756]\n+- *(1) Scan ExistingRDD[shardId#7905118,worklistShardItemId#7905119L,version#7905120,product#7905121,plant#7905122,periodStart#7905123,periodEnd#7905124,qty#7905125]\n [483572] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243218 { id="cluster_1243218"; isCluster="true"; label="InMemoryTableScan"; 483617 [id="node_483617" labelType="html" label="MapPartitionsRDD [483617] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 483618 [id="node_483618" labelType="html" label="MapPartitionsRDD [483618] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 483619 [id="node_483619" labelType="html" label="MapPartitionsRDD [483619] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243207 { id="cluster_1243207"; isCluster="true"; label="WholeStageCodegen (14)"; 483622 [id="node_483622" labelType="html" label="MapPartitionsRDD [483622] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243206 { id="cluster_1243206"; isCluster="true"; label="ObjectHashAggregate"; 483623 [id="node_483623" labelType="html" label="MapPartitionsRDD [483623] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243205 { id="cluster_1243205"; isCluster="true"; label="ObjectHashAggregate"; 483624 [id="node_483624" labelType="html" label="MapPartitionsRDD [483624] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243240 { id="cluster_1243240"; isCluster="true"; label="InMemoryTableScan"; 483628 [id="node_483628" labelType="html" label="MapPartitionsRDD [483628] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 483629 [id="node_483629" labelType="html" label="MapPartitionsRDD [483629] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 483631 [id="node_483631" labelType="html" label="MapPartitionsRDD [483631] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243234 { id="cluster_1243234"; isCluster="true"; label="WholeStageCodegen (15)"; 483634 [id="node_483634" labelType="html" label="MapPartitionsRDD [483634] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243203 { id="cluster_1243203"; isCluster="true"; label="Union"; 483635 [id="node_483635" labelType="html" label="UnionRDD [483635] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243189 { id="cluster_1243189"; isCluster="true"; label="DeserializeToObject"; 483636 [id="node_483636" labelType="html" label="MapPartitionsRDD [483636] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 483570->483571; 483571->483572; 483572->483617; 483617->483618; 483618->483619; 483619->483622; 483622->483623; 483623->483624; 483572->483628; 483628->483629; 483629->483631; 483631->483634; 483624->483635; 483634->483635; 483635->483636; }
483569,483570
483572
Event Timeline
Enable zooming
Tasks: 60. 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