4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 891 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.2 s
Locality Level Summary:
Process local: 8
Input Size / Records:
11.2 KiB / 8
Shuffle Write Size / Records:
7.7 KiB / 195
Associated Job Ids:
419
DAG Visualization
digraph G { id="graph_891"; subgraph graph_stage_891 { id="graph_stage_891"; isCluster="true"; label="Stage 891"; subgraph cluster_7121 { id="cluster_7121"; isCluster="true"; label="Exchange"; 2202 [id="node_2202" labelType="html" label="ShuffledRowRDD [2202] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7120 { id="cluster_7120"; isCluster="true"; label="InMemoryTableScan"; 2203 [id="node_2203" labelType="html" label="MapPartitionsRDD [2203] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 2204 [id="node_2204" labelType="html" label="Exchange hashpartitioning(product#25240, plant#25241, 8), REPARTITION_BY_NUM, [plan_id=215203]\n+- *(1) Scan ExistingRDD[shardId#25237,worklistShardItemId#25238L,version#25239,product#25240,plant#25241,periodStart#25242,periodEnd#25243,qty#25244]\n [2204] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7440 { id="cluster_7440"; isCluster="true"; label="InMemoryTableScan"; 2325 [id="node_2325" labelType="html" label="MapPartitionsRDD [2325] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 2326 [id="node_2326" labelType="html" label="MapPartitionsRDD [2326] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 2327 [id="node_2327" labelType="html" label="MapPartitionsRDD [2327] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7436 { id="cluster_7436"; isCluster="true"; label="WholeStageCodegen (1)"; 2328 [id="node_2328" labelType="html" label="MapPartitionsRDD [2328] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7435 { id="cluster_7435"; isCluster="true"; label="Exchange"; 2329 [id="node_2329" labelType="html" label="MapPartitionsRDD [2329] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 2202->2203; 2203->2204; 2204->2325; 2325->2326; 2326->2327; 2327->2328; 2328->2329; }
2201,2202
2204
Event Timeline
Enable zooming
Tasks: 8. 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