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

Resource Profile Id: 0
Total Time Across All Tasks: 3 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: 18717

digraph G { id="graph_341140"; subgraph graph_stage_341140 { id="graph_stage_341140"; isCluster="true"; label="Stage 341140"; subgraph cluster_385398 { id="cluster_385398"; isCluster="true"; label="Exchange"; 154089 [id="node_154089" labelType="html" label="ShuffledRowRDD [154089] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385397 { id="cluster_385397"; isCluster="true"; label="InMemoryTableScan"; 154090 [id="node_154090" labelType="html" label="MapPartitionsRDD [154090] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154091 [id="node_154091" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3614461L, 30), REPARTITION_BY_NUM, [plan_id=1034705]\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=1034701]\n +- HashAggregate(keys=[demandChannel#3614464, shardId#3614460, knownfloatingpointnormalized(transform(kpis#3614466, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3614876)) null else named_struct(label, lambda arg#3614876.label, dateTime, lambda arg#3614876.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3614876.value)))), lambda ... [154091] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154092 [id="node_154092" labelType="html" label="MapPartitionsRDD [154092] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154093 [id="node_154093" labelType="html" label="MapPartitionsRDD [154093] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154094 [id="node_154094" labelType="html" label="MapPartitionsRDD [154094] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385394 { id="cluster_385394"; isCluster="true"; label="WholeStageCodegen (1)"; 154095 [id="node_154095" labelType="html" label="MapPartitionsRDD [154095] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385393 { id="cluster_385393"; isCluster="true"; label="Exchange"; 154096 [id="node_154096" labelType="html" label="MapPartitionsRDD [154096] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154089->154090; 154090->154091; 154091->154092; 154092->154093; 154093->154094; 154094->154095; 154095->154096; }

154088,154089

154091

Event Timeline

Enable zooming