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

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 30
Input Size / Records: 6.5 MiB / 60
Shuffle Write Size / Records: 6.6 MiB / 351756
Associated Job Ids: 52585

digraph G { id="graph_190242"; subgraph graph_stage_190242 { id="graph_stage_190242"; isCluster="true"; label="Stage 190242"; subgraph cluster_1107048 { id="cluster_1107048"; isCluster="true"; label="Exchange"; 423522 [id="node_423522" labelType="html" label="ShuffledRowRDD [423522] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107045 { id="cluster_1107045"; isCluster="true"; label="WholeStageCodegen (7)"; 423523 [id="node_423523" labelType="html" label="MapPartitionsRDD [423523] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107044 { id="cluster_1107044"; isCluster="true"; label="SortAggregate"; 423524 [id="node_423524" labelType="html" label="MapPartitionsRDD [423524] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107043 { id="cluster_1107043"; isCluster="true"; label="InMemoryTableScan"; 423525 [id="node_423525" labelType="html" label="MapPartitionsRDD [423525] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 423526 [id="node_423526" labelType="html" label="SortAggregate(key=[demandChannel#6831811, shardId#6552497, qty#6831831, worklistShardItemId#6552498L, demandStream#6831812], functions=[first(kpis#6831840, false)], output=[shardId#6552497, worklistShardItemId#6552498L, qty#6831831, demandChannel#6831811, demandStream#6831812, kpis#6831953])\n+- *(7) Sort [demandChannel#6831811 ASC NULLS FIRST, shardId#6552497 ASC NULLS FIRST, qty#6831831 ASC NULLS FIRST, worklistShardItemId#6552498L ASC NULLS FIRST, demandStream#6831812 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#6831811, shardId#6552497, qty#6831831, worklistShardItemId#6552498L, demandStream#6831812, 30), ENSURE_REQUIREMENTS, [plan_id=29052320]\n +- SortAggregate(key=[demandChannel#6831811, shardId#6552497, knownfloatingpointnormalized(normalizenanandzero(qty#6831831)) AS qty#6831831, worklistShardItemId#6552498L, demandStream#6831812], functions=[partial_first(kpis#6831840, false)], output=[demandChannel#6831811, shardId#6552497, qty#6831831, worklistShardItemId#6552498L... [423526] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107155 { id="cluster_1107155"; isCluster="true"; label="InMemoryTableScan"; 423533 [id="node_423533" labelType="html" label="MapPartitionsRDD [423533] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 423534 [id="node_423534" labelType="html" label="MapPartitionsRDD [423534] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 423535 [id="node_423535" labelType="html" label="MapPartitionsRDD [423535] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107152 { id="cluster_1107152"; isCluster="true"; label="WholeStageCodegen (1)"; 423536 [id="node_423536" labelType="html" label="MapPartitionsRDD [423536] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107151 { id="cluster_1107151"; isCluster="true"; label="Exchange"; 423537 [id="node_423537" labelType="html" label="MapPartitionsRDD [423537] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 423522->423523; 423523->423524; 423524->423525; 423525->423526; 423526->423533; 423533->423534; 423534->423535; 423535->423536; 423536->423537; }

423521,423522

423526

Event Timeline

Enable zooming