4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 241216 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
11 s
Locality Level Summary:
Process local: 30
Input Size / Records:
1544.7 KiB / 30
Shuffle Write Size / Records:
370.4 KiB / 37040
Associated Job Ids:
66419
DAG Visualization
digraph G { id="graph_241216"; subgraph graph_stage_241216 { id="graph_stage_241216"; isCluster="true"; label="Stage 241216"; subgraph cluster_1408788 { id="cluster_1408788"; isCluster="true"; label="Exchange"; 539404 [id="node_539404" labelType="html" label="ShuffledRowRDD [539404] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1408787 { id="cluster_1408787"; isCluster="true"; label="InMemoryTableScan"; 539405 [id="node_539405" labelType="html" label="MapPartitionsRDD [539405] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 539406 [id="node_539406" labelType="html" label="Exchange hashpartitioning(product#8398759, plant#8398760, 30), REPARTITION_BY_NUM, [plan_id=36539579]\n+- *(1) Scan ExistingRDD[shardId#8398756,worklistShardItemId#8398757L,version#8398758,product#8398759,plant#8398760,periodStart#8398761,periodEnd#8398762,qty#8398763]\n [539406] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409643 { id="cluster_1409643"; isCluster="true"; label="InMemoryTableScan"; 539714 [id="node_539714" labelType="html" label="MapPartitionsRDD [539714] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 539715 [id="node_539715" labelType="html" label="MapPartitionsRDD [539715] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 539716 [id="node_539716" labelType="html" label="MapPartitionsRDD [539716] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409639 { id="cluster_1409639"; isCluster="true"; label="WholeStageCodegen (3)"; 539717 [id="node_539717" labelType="html" label="MapPartitionsRDD [539717] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409638 { id="cluster_1409638"; isCluster="true"; label="Exchange"; 539718 [id="node_539718" labelType="html" label="MapPartitionsRDD [539718] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 539404->539405; 539405->539406; 539406->539714; 539714->539715; 539715->539716; 539716->539717; 539717->539718; }
539403,539404
539406
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