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

Resource Profile Id: 0
Total Time Across All Tasks: 3 s
Locality Level Summary: Process local: 60
Input Size / Records: 20.8 MiB / 60
Shuffle Write Size / Records: 5.4 KiB / 60
Associated Job Ids: 18702

digraph G { id="graph_339673"; subgraph graph_stage_339673 { id="graph_stage_339673"; isCluster="true"; label="Stage 339673"; subgraph cluster_384990 { id="cluster_384990"; isCluster="true"; label="Exchange"; 153898 [id="node_153898" labelType="html" label="ShuffledRowRDD [153898] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384989 { id="cluster_384989"; isCluster="true"; label="Project"; 153899 [id="node_153899" labelType="html" label="MapPartitionsRDD [153899] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384988 { id="cluster_384988"; isCluster="true"; label="InMemoryTableScan"; 153900 [id="node_153900" labelType="html" label="MapPartitionsRDD [153900] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153901 [id="node_153901" labelType="html" label="Project [shardId#3580449, orderProposals#3592451]\n+- Exchange rangepartitioning(shardId#3580449 ASC NULLS FIRST, resultSeparationId#3592447L ASC NULLS FIRST, 60), REPARTITION_BY_NUM, [plan_id=1029948]\n +- InMemoryTableScan [shardId#3580449, resultSeparationId#3592447L, orderProposals#3592451]\n +- InMemoryRelation [shardId#3580449, resultSeparationId#3592447L, orderProposals#3592451], StorageLevel(disk, memory, 2 replicas)\n +- 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#35924... [153901] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385156 { id="cluster_385156"; isCluster="true"; label="InMemoryTableScan"; 153956 [id="node_153956" labelType="html" label="MapPartitionsRDD [153956] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153957 [id="node_153957" labelType="html" label="MapPartitionsRDD [153957] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153958 [id="node_153958" labelType="html" label="MapPartitionsRDD [153958] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385153 { id="cluster_385153"; isCluster="true"; label="WholeStageCodegen (1)"; 153959 [id="node_153959" labelType="html" label="MapPartitionsRDD [153959] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385152 { id="cluster_385152"; isCluster="true"; label="Exchange"; 153960 [id="node_153960" labelType="html" label="MapPartitionsRDD [153960] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 153898->153899; 153899->153900; 153900->153901; 153901->153956; 153956->153957; 153957->153958; 153958->153959; 153959->153960; }

153897,153898

153901

153898

153899

153900

153901

153956

153957

153958

153959

153960

Event Timeline

Enable zooming