crp-order-quantity-kpi-service - 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

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] 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] 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] 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] 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] 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] start at FileStorageAdapterImpl.java:171}"]; 55542 [id="node_55542" labelType="html" label="MapPartitionsRDD [55542] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 55543 [id="node_55543" labelType="html" label="MapPartitionsRDD [55543] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 55544 [id="node_55544" labelType="html" label="MapPartitionsRDD [55544] [Unordered] 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] 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] 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