crp-order-qty-opt-service - Details for Stage 331980 (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 / 476584
Shuffle Write Size / Records: 2.8 KiB / 30
Associated Job Ids: 18497

digraph G { id="graph_331980"; subgraph graph_stage_331980 { id="graph_stage_331980"; isCluster="true"; label="Stage 331980"; subgraph cluster_379435 { id="cluster_379435"; isCluster="true"; label="Exchange"; 151691 [id="node_151691" labelType="html" label="ShuffledRowRDD [151691] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379434 { id="cluster_379434"; isCluster="true"; label="InMemoryTableScan"; 151692 [id="node_151692" labelType="html" label="MapPartitionsRDD [151692] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151693 [id="node_151693" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3571715L, 30), REPARTITION_BY_NUM, [plan_id=1021857]\n+- *(2) HashAggregate(keys=[demandChannel#3571718, shardId#3571714, kpis#3571720, version#3571716, qty#3571717, worklistShardItemId#3571715L, demandStream#3571719], functions=[], output=[shardId#3571714, worklistShardItemId#3571715L, version#3571716, qty#3571717, demandChannel#3571718, demandStream#3571719, kpis#3571720])\n +- Exchange hashpartitioning(demandChannel#3571718, shardId#3571714, kpis#3571720, version#3571716, qty#3571717, worklistShardItemId#3571715L, demandStream#3571719, 30), ENSURE_REQUIREMENTS, [plan_id=1021853]\n +- HashAggregate(keys=[demandChannel#3571718, shardId#3571714, knownfloatingpointnormalized(transform(kpis#3571720, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3572123)) null else named_struct(label, lambda arg#3572123.label, dateTime, lambda arg#3572123.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3572123.value)))), lambda ... [151693] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151694 [id="node_151694" labelType="html" label="MapPartitionsRDD [151694] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151695 [id="node_151695" labelType="html" label="MapPartitionsRDD [151695] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151696 [id="node_151696" labelType="html" label="MapPartitionsRDD [151696] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379431 { id="cluster_379431"; isCluster="true"; label="WholeStageCodegen (1)"; 151697 [id="node_151697" labelType="html" label="MapPartitionsRDD [151697] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379430 { id="cluster_379430"; isCluster="true"; label="Exchange"; 151698 [id="node_151698" labelType="html" label="MapPartitionsRDD [151698] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 151691->151692; 151692->151693; 151693->151694; 151694->151695; 151695->151696; 151696->151697; 151697->151698; }

151690,151691

151693

Event Timeline

Enable zooming