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

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

digraph G { id="graph_1032498"; subgraph graph_stage_1032498 { id="graph_stage_1032498"; isCluster="true"; label="Stage 1032498"; subgraph cluster_1087500 { id="cluster_1087500"; isCluster="true"; label="Exchange"; 434074 [id="node_434074" labelType="html" label="ShuffledRowRDD [434074] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087499 { id="cluster_1087499"; isCluster="true"; label="InMemoryTableScan"; 434075 [id="node_434075" labelType="html" label="MapPartitionsRDD [434075] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 434076 [id="node_434076" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#9675734L, 30), REPARTITION_BY_NUM, [plan_id=3017737]\n+- *(2) HashAggregate(keys=[demandChannel#9675737, shardId#9675733, kpis#9675739, version#9675735, qty#9675736, worklistShardItemId#9675734L, demandStream#9675738], functions=[], output=[shardId#9675733, worklistShardItemId#9675734L, version#9675735, qty#9675736, demandChannel#9675737, demandStream#9675738, kpis#9675739])\n +- Exchange hashpartitioning(demandChannel#9675737, shardId#9675733, kpis#9675739, version#9675735, qty#9675736, worklistShardItemId#9675734L, demandStream#9675738, 30), ENSURE_REQUIREMENTS, [plan_id=3017733]\n +- HashAggregate(keys=[demandChannel#9675737, shardId#9675733, knownfloatingpointnormalized(transform(kpis#9675739, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#10205592)) null else named_struct(label, lambda arg#10205592.label, dateTime, lambda arg#10205592.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#10205592.value)))), lam... [434076] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 434077 [id="node_434077" labelType="html" label="MapPartitionsRDD [434077] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 434078 [id="node_434078" labelType="html" label="MapPartitionsRDD [434078] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 434079 [id="node_434079" labelType="html" label="MapPartitionsRDD [434079] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087496 { id="cluster_1087496"; isCluster="true"; label="WholeStageCodegen (1)"; 434080 [id="node_434080" labelType="html" label="MapPartitionsRDD [434080] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087495 { id="cluster_1087495"; isCluster="true"; label="Exchange"; 434081 [id="node_434081" labelType="html" label="MapPartitionsRDD [434081] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 434074->434075; 434075->434076; 434076->434077; 434077->434078; 434078->434079; 434079->434080; 434080->434081; }

434073,434074

434076

Event Timeline

Enable zooming