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

Resource Profile Id: 0
Total Time Across All Tasks: 3 s
Locality Level Summary: Node local: 30
Shuffle Read Size / Records: 12.0 MiB / 351756
Shuffle Write Size / Records: 2.8 KiB / 30
Associated Job Ids: 18529

digraph G { id="graph_333016"; subgraph graph_stage_333016 { id="graph_stage_333016"; isCluster="true"; label="Stage 333016"; subgraph cluster_380095 { id="cluster_380095"; isCluster="true"; label="Exchange"; 152014 [id="node_152014" labelType="html" label="ShuffledRowRDD [152014] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380094 { id="cluster_380094"; isCluster="true"; label="InMemoryTableScan"; 152015 [id="node_152015" labelType="html" label="MapPartitionsRDD [152015] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 152016 [id="node_152016" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3571715L, 30), REPARTITION_BY_NUM, [plan_id=1023373]\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=1023369]\n +- HashAggregate(keys=[demandChannel#3571718, shardId#3571714, knownfloatingpointnormalized(transform(kpis#3571720, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3575998)) null else named_struct(label, lambda arg#3575998.label, dateTime, lambda arg#3575998.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3575998.value)))), lambda ... [152016] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 152017 [id="node_152017" labelType="html" label="MapPartitionsRDD [152017] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 152018 [id="node_152018" labelType="html" label="MapPartitionsRDD [152018] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 152019 [id="node_152019" labelType="html" label="MapPartitionsRDD [152019] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380091 { id="cluster_380091"; isCluster="true"; label="WholeStageCodegen (1)"; 152020 [id="node_152020" labelType="html" label="MapPartitionsRDD [152020] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380090 { id="cluster_380090"; isCluster="true"; label="Exchange"; 152021 [id="node_152021" labelType="html" label="MapPartitionsRDD [152021] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 152014->152015; 152015->152016; 152016->152017; 152017->152018; 152018->152019; 152019->152020; 152020->152021; }

152013,152014

152016

Event Timeline

Enable zooming