crp-order-quantity-kpi-service - Details for Stage 90488 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 0.7 s
Locality Level Summary: Process local: 37
Input Size / Records: 17.6 KiB / 30
Shuffle Write Size / Records: 2.7 KiB / 30
Associated Job Ids: 4846

digraph G { id="graph_90488"; subgraph graph_stage_90488 { id="graph_stage_90488"; isCluster="true"; label="Stage 90488"; subgraph cluster_109512 { id="cluster_109512"; isCluster="true"; label="Exchange"; 41940 [id="node_41940" labelType="html" label="ShuffledRowRDD [41940] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109507 { id="cluster_109507"; isCluster="true"; label="WholeStageCodegen (6)"; 41941 [id="node_41941" labelType="html" label="MapPartitionsRDD [41941] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109506 { id="cluster_109506"; isCluster="true"; label="SortAggregate"; 41942 [id="node_41942" labelType="html" label="MapPartitionsRDD [41942] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109505 { id="cluster_109505"; isCluster="true"; label="InMemoryTableScan"; 41943 [id="node_41943" labelType="html" label="MapPartitionsRDD [41943] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 41944 [id="node_41944" labelType="html" label="SortAggregate(key=[demandChannel#840750, shardId#815740, qty#840770, worklistShardItemId#815741L, demandStream#840751], functions=[first(kpis#840779, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#840770, demandChannel#840750, demandStream#840751, kpis#840912])\n+- *(6) Sort [demandChannel#840750 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#840770 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#840751 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#840750, shardId#815740, qty#840770, worklistShardItemId#815741L, demandStream#840751, 37), ENSURE_REQUIREMENTS, [plan_id=1376187]\n +- SortAggregate(key=[demandChannel#840750, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#840770)) AS qty#840770, worklistShardItemId#815741L, demandStream#840751], functions=[partial_first(kpis#840779, false)], output=[demandChannel#840750, shardId#815740, qty#840770, worklistShardItemId#815741L, demandStream#840751, first#84098... [41944] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109608 { id="cluster_109608"; isCluster="true"; label="InMemoryTableScan"; 41957 [id="node_41957" labelType="html" label="MapPartitionsRDD [41957] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 41958 [id="node_41958" labelType="html" label="MapPartitionsRDD [41958] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 41959 [id="node_41959" labelType="html" label="MapPartitionsRDD [41959] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109605 { id="cluster_109605"; isCluster="true"; label="WholeStageCodegen (1)"; 41960 [id="node_41960" labelType="html" label="MapPartitionsRDD [41960] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109604 { id="cluster_109604"; isCluster="true"; label="Exchange"; 41961 [id="node_41961" labelType="html" label="MapPartitionsRDD [41961] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 41940->41941; 41941->41942; 41942->41943; 41943->41944; 41944->41957; 41957->41958; 41958->41959; 41959->41960; 41960->41961; }

41939,41940

41944

41940

41941

41942

41943

41944

41957

41958

41959

41960

41961

Event Timeline

Enable zooming