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

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Node local: 27; Process local: 3
Shuffle Read Size / Records: 20.6 MiB / 1280
Shuffle Write Size / Records: 2.2 KiB / 30
Associated Job Ids: 18608

digraph G { id="graph_335799"; subgraph graph_stage_335799 { id="graph_stage_335799"; isCluster="true"; label="Stage 335799"; subgraph cluster_382863 { id="cluster_382863"; isCluster="true"; label="Exchange"; 153144 [id="node_153144" labelType="html" label="ShuffledRowRDD [153144] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_382862 { id="cluster_382862"; isCluster="true"; label="ObjectHashAggregate"; 153145 [id="node_153145" labelType="html" label="MapPartitionsRDD [153145] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_382861 { id="cluster_382861"; isCluster="true"; label="InMemoryTableScan"; 153146 [id="node_153146" labelType="html" label="MapPartitionsRDD [153146] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153147 [id="node_153147" labelType="html" label="ObjectHashAggregate(keys=[shardId#3580449, resultSeparationId#3592447L], functions=[collect_list(orderProposal#3584099, 0, 0)], output=[shardId#3580449, resultSeparationId#3592447L, orderProposals#3592451])\n+- Exchange hashpartitioning(shardId#3580449, resultSeparationId#3592447L, 30), ENSURE_REQUIREMENTS, [plan_id=1029905]\n +- ObjectHashAggregate(keys=[shardId#3580449, resultSeparationId#3592447L], functions=[partial_collect_list(orderProposal#3584099, 0, 0)], output=[shardId#3580449, resultSeparationId#3592447L, buf#3592487])\n +- Project [shardId#3580449, orderProposal#3584099, CASE WHEN (size(orderProposal#3584099.parentItems, true) > 2000) THEN xxhash64(orderProposal#3584099.orderProposalId, 42) ELSE xxhash64(pmod(cast(orderProposal#3584099.orderProposalId as decimal(20,0)), 60), 42) END AS resultSeparationId#3592447L]\n +- InMemoryTableScan [orderProposal#3584099, shardId#3580449]\n +- InMemoryRelation [shardId#3580449, orderProposal#3584099], StorageLevel(disk, memory, 2 re... [153147] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153148 [id="node_153148" labelType="html" label="MapPartitionsRDD [153148] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153149 [id="node_153149" labelType="html" label="MapPartitionsRDD [153149] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153150 [id="node_153150" labelType="html" label="MapPartitionsRDD [153150] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_382858 { id="cluster_382858"; isCluster="true"; label="WholeStageCodegen (1)"; 153151 [id="node_153151" labelType="html" label="MapPartitionsRDD [153151] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_382857 { id="cluster_382857"; isCluster="true"; label="Exchange"; 153152 [id="node_153152" labelType="html" label="MapPartitionsRDD [153152] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 153144->153145; 153145->153146; 153146->153147; 153147->153148; 153148->153149; 153149->153150; 153150->153151; 153151->153152; }

153143,153144

153147

153144

153145

153146

153147

153148

153149

153150

153151

153152

Event Timeline

Enable zooming