crp-order-qty-opt-service - Details for Stage 332811 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 4 s
Locality Level Summary: Node local: 30
Shuffle Read Size / Records: 16.2 MiB / 475632
Shuffle Write Size / Records: 2.8 KiB / 30
Associated Job Ids: 18521

digraph G { id="graph_332811"; subgraph graph_stage_332811 { id="graph_stage_332811"; isCluster="true"; label="Stage 332811"; subgraph cluster_379947 { id="cluster_379947"; isCluster="true"; label="Exchange"; 151944 [id="node_151944" labelType="html" label="ShuffledRowRDD [151944] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379946 { id="cluster_379946"; isCluster="true"; label="InMemoryTableScan"; 151945 [id="node_151945" labelType="html" label="MapPartitionsRDD [151945] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151946 [id="node_151946" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3572038L, 30), REPARTITION_BY_NUM, [plan_id=1022926]\n+- *(2) HashAggregate(keys=[demandChannel#3572041, shardId#3572037, kpis#3572043, version#3572039, qty#3572040, worklistShardItemId#3572038L, demandStream#3572042], functions=[], output=[shardId#3572037, worklistShardItemId#3572038L, version#3572039, qty#3572040, demandChannel#3572041, demandStream#3572042, kpis#3572043])\n +- Exchange hashpartitioning(demandChannel#3572041, shardId#3572037, kpis#3572043, version#3572039, qty#3572040, worklistShardItemId#3572038L, demandStream#3572042, 30), ENSURE_REQUIREMENTS, [plan_id=1022922]\n +- HashAggregate(keys=[demandChannel#3572041, shardId#3572037, knownfloatingpointnormalized(transform(kpis#3572043, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3575089)) null else named_struct(label, lambda arg#3575089.label, dateTime, lambda arg#3575089.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3575089.value)))), lambda ... [151946] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151947 [id="node_151947" labelType="html" label="MapPartitionsRDD [151947] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151948 [id="node_151948" labelType="html" label="MapPartitionsRDD [151948] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151949 [id="node_151949" labelType="html" label="MapPartitionsRDD [151949] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379943 { id="cluster_379943"; isCluster="true"; label="WholeStageCodegen (1)"; 151950 [id="node_151950" labelType="html" label="MapPartitionsRDD [151950] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379942 { id="cluster_379942"; isCluster="true"; label="Exchange"; 151951 [id="node_151951" labelType="html" label="MapPartitionsRDD [151951] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 151944->151945; 151945->151946; 151946->151947; 151947->151948; 151948->151949; 151949->151950; 151950->151951; }

151943,151944

151946

Event Timeline

Enable zooming