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

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

digraph G { id="graph_1032001"; subgraph graph_stage_1032001 { id="graph_stage_1032001"; isCluster="true"; label="Stage 1032001"; 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_1087351 { id="cluster_1087351"; isCluster="true"; label="InMemoryTableScan"; 433995 [id="node_433995" labelType="html" label="MapPartitionsRDD [433995] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 433996 [id="node_433996" labelType="html" label="MapPartitionsRDD [433996] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 433997 [id="node_433997" labelType="html" label="MapPartitionsRDD [433997] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087348 { id="cluster_1087348"; isCluster="true"; label="WholeStageCodegen (1)"; 433998 [id="node_433998" labelType="html" label="MapPartitionsRDD [433998] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087347 { id="cluster_1087347"; isCluster="true"; label="Exchange"; 433999 [id="node_433999" labelType="html" label="MapPartitionsRDD [433999] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 433964->433965; 433965->433966; 433966->433967; 433967->433995; 433995->433996; 433996->433997; 433997->433998; 433998->433999; }

433963,433964

433967

433964

433965

433966

433967

433995

433996

433997

433998

433999

Event Timeline

Enable zooming