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

Resource Profile Id: 0
Total Time Across All Tasks: 0.2 s
Locality Level Summary: Process local: 52
Input Size / Records: 17.9 MiB / 52
Shuffle Write Size / Records: 3.1 KiB / 52
Associated Job Ids: 52665

digraph G { id="graph_1032153"; subgraph graph_stage_1032153 { id="graph_stage_1032153"; isCluster="true"; label="Stage 1032153"; subgraph cluster_1087267 { id="cluster_1087267"; isCluster="true"; label="Exchange"; 433964 [id="node_433964" labelType="html" label="ShuffledRowRDD [433964] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087266 { id="cluster_1087266"; isCluster="true"; label="Project"; 433965 [id="node_433965" labelType="html" label="MapPartitionsRDD [433965] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087265 { id="cluster_1087265"; isCluster="true"; label="InMemoryTableScan"; 433966 [id="node_433966" labelType="html" label="MapPartitionsRDD [433966] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 433967 [id="node_433967" labelType="html" label="Project [shardId#10193744, orderProposals#10197888]\n+- Exchange rangepartitioning(shardId#10193744 ASC NULLS FIRST, resultSeparationId#10197884L ASC NULLS FIRST, 52), REPARTITION_BY_NUM, [plan_id=3015841]\n +- InMemoryTableScan [shardId#10193744, resultSeparationId#10197884L, orderProposals#10197888]\n +- InMemoryRelation [shardId#10193744, resultSeparationId#10197884L, orderProposals#10197888], StorageLevel(disk, memory, 2 replicas)\n +- ObjectHashAggregate(keys=[shardId#10193744, resultSeparationId#10197884L], functions=[collect_list(orderProposal#10196132, 0, 0)], output=[shardId#10193744, resultSeparationId#10197884L, orderProposals#10197888])\n +- Exchange hashpartitioning(shardId#10193744, resultSeparationId#10197884L, 30), ENSURE_REQUIREMENTS, [plan_id=3015798]\n +- ObjectHashAggregate(keys=[shardId#10193744, resultSeparationId#10197884L], functions=[partial_collect_list(orderProposal#10196132, 0, 0)], output=[shardId#10193744, resultSeparation... [433967] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087364 { id="cluster_1087364"; isCluster="true"; label="InMemoryTableScan"; 434003 [id="node_434003" labelType="html" label="MapPartitionsRDD [434003] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 434004 [id="node_434004" labelType="html" label="MapPartitionsRDD [434004] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 434005 [id="node_434005" labelType="html" label="MapPartitionsRDD [434005] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087363 { id="cluster_1087363"; isCluster="true"; label="CollectLimit"; 434006 [id="node_434006" labelType="html" label="MapPartitionsRDD [434006] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 434007 [id="node_434007" labelType="html" label="MapPartitionsRDD [434007] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 433964->433965; 433965->433966; 433966->433967; 433967->434003; 434003->434004; 434004->434005; 434005->434006; 434006->434007; }

433963,433964

433967

433964

433965

433966

433967

434003

434004

434005

434006

434007

Event Timeline

Enable zooming