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

Resource Profile Id: 0
Total Time Across All Tasks: 11 ms
Locality Level Summary: Process local: 37
Input Size / Records: 1725.0 B / 7
Shuffle Write Size / Records: 3.2 KiB / 39
Associated Job Ids: 40677

digraph G { id="graph_1253631"; subgraph graph_stage_1253631 { id="graph_stage_1253631"; isCluster="true"; label="Stage 1253631"; subgraph cluster_848635 { id="cluster_848635"; isCluster="true"; label="repartition"; 329892 [id="node_329892" labelType="html" label="ShuffledRDD [329892] [Indeterminate] repartition at OptimalQuantitiesCacheImpl.java:180}"]; 329893 [id="node_329893" labelType="html" label="CoalescedRDD [329893] [Indeterminate] repartition at OptimalQuantitiesCacheImpl.java:180}"]; 329894 [id="node_329894" labelType="html" label="MapPartitionsRDD [329894] [Cached] [Indeterminate] repartition at OptimalQuantitiesCacheImpl.java:180}"]; } subgraph cluster_848785 { id="cluster_848785"; isCluster="true"; label="map"; 329953 [id="node_329953" labelType="html" label="MapPartitionsRDD [329953] [Indeterminate] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_848788 { id="cluster_848788"; isCluster="true"; label="WholeStageCodegen (1)"; 329954 [id="node_329954" labelType="html" label="MapPartitionsRDD [329954] [Indeterminate] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_848787 { id="cluster_848787"; isCluster="true"; label="InMemoryTableScan"; 329955 [id="node_329955" labelType="html" label="MapPartitionsRDD [329955] [Indeterminate] start at FileStorageAdapterImpl.java:567}"]; 329956 [id="node_329956" labelType="html" label="*(1) Project [shardId#5571648, item#5571656L AS worklistShardItemId#5571657L]\n+- *(1) Generate explode(_extract_worklistShardItemId#5571660), [shardId#5571648], false, [item#5571656L]\n +- *(1) Project [shardId#5571648, items#5571650.worklistShardItemId AS _extract_worklistShardItemId#5571660]\n +- *(1) Filter ((isnotnull(shardId#5571648) AND ((shardId#5571648 = 0_1_10000000244) AND (isOptimal#5571652 <=> false))) AND ((size(items#5571650.worklistShardItemId, true) > 0) AND isnotnull(items#5571650.worklistShardItemId)))\n +- *(1) Scan ExistingRDD[shardId#5571648,orderProposalId#5571649L,items#5571650,optimizationGroups#5571651,isOptimal#5571652,lastModified#5571653,optimizationInsights#5571654]\n [329956] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_849037 { id="cluster_849037"; isCluster="true"; label="InMemoryTableScan"; 330037 [id="node_330037" labelType="html" label="MapPartitionsRDD [330037] [Indeterminate] start at FileStorageAdapterImpl.java:567}"]; 330038 [id="node_330038" labelType="html" label="MapPartitionsRDD [330038] [Indeterminate] start at FileStorageAdapterImpl.java:567}"]; 330039 [id="node_330039" labelType="html" label="MapPartitionsRDD [330039] [Indeterminate] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_849036 { id="cluster_849036"; isCluster="true"; label="Exchange"; 330040 [id="node_330040" labelType="html" label="MapPartitionsRDD [330040] [Indeterminate] start at FileStorageAdapterImpl.java:567}"]; } } 329892->329893; 329893->329894; 329894->329953; 329953->329954; 329954->329955; 329955->329956; 329956->330037; 330037->330038; 330038->330039; 330039->330040; }

329891,329892

329894

329956

329892

329893

329894

329953

329954

329955

329956

330037

330038

330039

330040

Event Timeline

Enable zooming