4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 115479 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
3 s
Locality Level Summary:
Node local: 37
Shuffle Read Size / Records:
916.0 KiB / 4383
Associated Job Ids:
6345
DAG Visualization
digraph G { id="graph_115479"; subgraph graph_stage_115479 { id="graph_stage_115479"; isCluster="true"; label="Stage 115479"; 55546 [id="node_55546" labelType="html" label="SQLExecutionRDD [55546] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_144434 { id="cluster_144434"; isCluster="true"; label="Exchange"; 55537 [id="node_55537" labelType="html" label="ShuffledRowRDD [55537] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144428 { id="cluster_144428"; isCluster="true"; label="WholeStageCodegen (6)"; 55538 [id="node_55538" labelType="html" label="MapPartitionsRDD [55538] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144427 { id="cluster_144427"; isCluster="true"; label="SortAggregate"; 55539 [id="node_55539" labelType="html" label="MapPartitionsRDD [55539] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144426 { id="cluster_144426"; isCluster="true"; label="InMemoryTableScan"; 55540 [id="node_55540" labelType="html" label="MapPartitionsRDD [55540] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 55541 [id="node_55541" labelType="html" label="SortAggregate(key=[demandChannel#1114519, shardId#1100457, qty#1114539, worklistShardItemId#1100458L, demandStream#1114520], functions=[first(kpis#1114548, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1114539, demandChannel#1114519, demandStream#1114520, kpis#1114681])\n+- *(6) Sort [demandChannel#1114519 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1114539 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1114520 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1114519, shardId#1100457, qty#1114539, worklistShardItemId#1100458L, demandStream#1114520, 37), ENSURE_REQUIREMENTS, [plan_id=1751587]\n +- SortAggregate(key=[demandChannel#1114519, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1114539)) AS qty#1114539, worklistShardItemId#1100458L, demandStream#1114520], functions=[partial_first(kpis#1114548, false)], output=[demandChannel#1114519, shardId#1100457, qty#1114539, worklistShardItemId#1100458L,... [55541] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 55542 [id="node_55542" labelType="html" label="MapPartitionsRDD [55542] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 55543 [id="node_55543" labelType="html" label="MapPartitionsRDD [55543] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 55544 [id="node_55544" labelType="html" label="MapPartitionsRDD [55544] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144425 { id="cluster_144425"; isCluster="true"; label="DeserializeToObject"; 55545 [id="node_55545" labelType="html" label="MapPartitionsRDD [55545] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144482 { id="cluster_144482"; isCluster="true"; label="mapPartitions"; 55547 [id="node_55547" labelType="html" label="MapPartitionsRDD [55547] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } } 55537->55538; 55538->55539; 55539->55540; 55540->55541; 55541->55542; 55542->55543; 55543->55544; 55544->55545; 55545->55546; 55546->55547; }
55536,55537
55541
Event Timeline
Enable zooming
Tasks: 37. 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