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

Resource Profile Id: 0
Total Time Across All Tasks: 0.9 s
Locality Level Summary: Node local: 30
Shuffle Read Size / Records: 5.5 MiB / 159872
Shuffle Write Size / Records: 2.8 KiB / 30
Associated Job Ids: 18509

digraph G { id="graph_332342"; subgraph graph_stage_332342 { id="graph_stage_332342"; isCluster="true"; label="Stage 332342"; subgraph cluster_379710 { id="cluster_379710"; isCluster="true"; label="Exchange"; 151822 [id="node_151822" labelType="html" label="ShuffledRowRDD [151822] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379709 { id="cluster_379709"; isCluster="true"; label="InMemoryTableScan"; 151823 [id="node_151823" labelType="html" label="MapPartitionsRDD [151823] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151824 [id="node_151824" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3571687L, 30), REPARTITION_BY_NUM, [plan_id=1022398]\n+- *(2) HashAggregate(keys=[demandChannel#3571690, shardId#3571686, kpis#3571692, version#3571688, qty#3571689, worklistShardItemId#3571687L, demandStream#3571691], functions=[], output=[shardId#3571686, worklistShardItemId#3571687L, version#3571688, qty#3571689, demandChannel#3571690, demandStream#3571691, kpis#3571692])\n +- Exchange hashpartitioning(demandChannel#3571690, shardId#3571686, kpis#3571692, version#3571688, qty#3571689, worklistShardItemId#3571687L, demandStream#3571691, 30), ENSURE_REQUIREMENTS, [plan_id=1022394]\n +- HashAggregate(keys=[demandChannel#3571690, shardId#3571686, knownfloatingpointnormalized(transform(kpis#3571692, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3573722)) null else named_struct(label, lambda arg#3573722.label, dateTime, lambda arg#3573722.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3573722.value)))), lambda ... [151824] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151825 [id="node_151825" labelType="html" label="MapPartitionsRDD [151825] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151826 [id="node_151826" labelType="html" label="MapPartitionsRDD [151826] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151827 [id="node_151827" labelType="html" label="MapPartitionsRDD [151827] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379706 { id="cluster_379706"; isCluster="true"; label="WholeStageCodegen (1)"; 151828 [id="node_151828" labelType="html" label="MapPartitionsRDD [151828] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379705 { id="cluster_379705"; isCluster="true"; label="Exchange"; 151829 [id="node_151829" labelType="html" label="MapPartitionsRDD [151829] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 151822->151823; 151823->151824; 151824->151825; 151825->151826; 151826->151827; 151827->151828; 151828->151829; }

151821,151822

151824

Event Timeline

Enable zooming