4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 278723 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.2 s
Locality Level Summary:
Process local: 30
Input Size / Records:
18.3 KiB / 29
Shuffle Write Size / Records:
2.1 KiB / 29
Associated Job Ids:
96736
DAG Visualization
digraph G { id="graph_278723"; subgraph graph_stage_278723 { id="graph_stage_278723"; isCluster="true"; label="Stage 278723"; subgraph cluster_1999658 { id="cluster_1999658"; isCluster="true"; label="Exchange"; 789852 [id="node_789852" labelType="html" label="ShuffledRowRDD [789852] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1999657 { id="cluster_1999657"; isCluster="true"; label="InMemoryTableScan"; 789853 [id="node_789853" labelType="html" label="MapPartitionsRDD [789853] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 789854 [id="node_789854" labelType="html" label="Exchange hashpartitioning(product#13791301, plant#13791302, 30), REPARTITION_BY_NUM, [plan_id=13568574]\n+- *(1) Scan ExistingRDD[shardId#13791298,worklistShardItemId#13791299L,version#13791300,product#13791301,plant#13791302,periodStart#13791303,periodEnd#13791304,qty#13791305]\n [789854] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1999733 { id="cluster_1999733"; isCluster="true"; label="InMemoryTableScan"; 789879 [id="node_789879" labelType="html" label="MapPartitionsRDD [789879] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 789880 [id="node_789880" labelType="html" label="MapPartitionsRDD [789880] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 789881 [id="node_789881" labelType="html" label="MapPartitionsRDD [789881] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1999730 { id="cluster_1999730"; isCluster="true"; label="WholeStageCodegen (12)"; 789885 [id="node_789885" labelType="html" label="MapPartitionsRDD [789885] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1999729 { id="cluster_1999729"; isCluster="true"; label="Exchange"; 789886 [id="node_789886" labelType="html" label="MapPartitionsRDD [789886] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 789852->789853; 789853->789854; 789854->789879; 789879->789880; 789880->789881; 789881->789885; 789885->789886; }
789851,789852
789854
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