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

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

digraph G { id="graph_341338"; subgraph graph_stage_341338 { id="graph_stage_341338"; isCluster="true"; label="Stage 341338"; subgraph cluster_386327 { id="cluster_386327"; isCluster="true"; label="Exchange"; 154498 [id="node_154498" labelType="html" label="ShuffledRowRDD [154498] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_386326 { id="cluster_386326"; isCluster="true"; label="InMemoryTableScan"; 154499 [id="node_154499" labelType="html" label="MapPartitionsRDD [154499] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154500 [id="node_154500" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3614461L, 30), REPARTITION_BY_NUM, [plan_id=1037329]\n+- *(2) HashAggregate(keys=[demandChannel#3614464, shardId#3614460, kpis#3614466, version#3614462, qty#3614463, worklistShardItemId#3614461L, demandStream#3614465], functions=[], output=[shardId#3614460, worklistShardItemId#3614461L, version#3614462, qty#3614463, demandChannel#3614464, demandStream#3614465, kpis#3614466])\n +- Exchange hashpartitioning(demandChannel#3614464, shardId#3614460, kpis#3614466, version#3614462, qty#3614463, worklistShardItemId#3614461L, demandStream#3614465, 30), ENSURE_REQUIREMENTS, [plan_id=1037325]\n +- HashAggregate(keys=[demandChannel#3614464, shardId#3614460, knownfloatingpointnormalized(transform(kpis#3614466, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3623877)) null else named_struct(label, lambda arg#3623877.label, dateTime, lambda arg#3623877.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3623877.value)))), lambda ... [154500] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154501 [id="node_154501" labelType="html" label="MapPartitionsRDD [154501] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154502 [id="node_154502" labelType="html" label="MapPartitionsRDD [154502] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154503 [id="node_154503" labelType="html" label="MapPartitionsRDD [154503] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_386323 { id="cluster_386323"; isCluster="true"; label="WholeStageCodegen (1)"; 154504 [id="node_154504" labelType="html" label="MapPartitionsRDD [154504] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_386322 { id="cluster_386322"; isCluster="true"; label="Exchange"; 154505 [id="node_154505" labelType="html" label="MapPartitionsRDD [154505] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154498->154499; 154499->154500; 154500->154501; 154501->154502; 154502->154503; 154503->154504; 154504->154505; }

154497,154498

154500

Event Timeline

Enable zooming