4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 172494 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1 s
Locality Level Summary:
Process local: 30
Input Size / Records:
4.5 KiB / 10
Associated Job Ids:
60334
DAG Visualization
digraph G { id="graph_172494"; subgraph graph_stage_172494 { id="graph_stage_172494"; isCluster="true"; label="Stage 172494"; subgraph cluster_1238276 { id="cluster_1238276"; isCluster="true"; label="Exchange"; 481610 [id="node_481610" labelType="html" label="ShuffledRowRDD [481610] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238275 { id="cluster_1238275"; isCluster="true"; label="InMemoryTableScan"; 481611 [id="node_481611" labelType="html" label="MapPartitionsRDD [481611] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 481612 [id="node_481612" labelType="html" label="Exchange hashpartitioning(product#7905121, plant#7905122, 30), REPARTITION_BY_NUM, [plan_id=11177335]\n+- *(1) Scan ExistingRDD[shardId#7905118,worklistShardItemId#7905119L,version#7905120,product#7905121,plant#7905122,periodStart#7905123,periodEnd#7905124,qty#7905125]\n [481612] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238411 { id="cluster_1238411"; isCluster="true"; label="InMemoryTableScan"; 481654 [id="node_481654" labelType="html" label="MapPartitionsRDD [481654] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 481655 [id="node_481655" labelType="html" label="MapPartitionsRDD [481655] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 481656 [id="node_481656" labelType="html" label="MapPartitionsRDD [481656] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238390 { id="cluster_1238390"; isCluster="true"; label="WholeStageCodegen (4)"; 481660 [id="node_481660" labelType="html" label="MapPartitionsRDD [481660] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1238384 { id="cluster_1238384"; isCluster="true"; label="DeserializeToObject"; 481661 [id="node_481661" labelType="html" label="MapPartitionsRDD [481661] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 481610->481611; 481611->481612; 481612->481654; 481654->481655; 481655->481656; 481656->481660; 481660->481661; }
481609,481610
481612
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