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

Resource Profile Id: 0
Total Time Across All Tasks: 9 ms
Locality Level Summary: Process local: 30
Input Size / Records: 1182.0 B / 4
Shuffle Write Size / Records: 2.2 KiB / 28
Associated Job Ids: 40894

digraph G { id="graph_1263752"; subgraph graph_stage_1263752 { id="graph_stage_1263752"; isCluster="true"; label="Stage 1263752"; subgraph cluster_853770 { id="cluster_853770"; isCluster="true"; label="repartition"; 331908 [id="node_331908" labelType="html" label="ShuffledRDD [331908] [Indeterminate] start at FileStorageAdapterImpl.java:567}"]; 331909 [id="node_331909" labelType="html" label="CoalescedRDD [331909] [Indeterminate] start at FileStorageAdapterImpl.java:567}"]; 331910 [id="node_331910" labelType="html" label="MapPartitionsRDD [331910] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_854094 { id="cluster_854094"; isCluster="true"; label="map"; 332020 [id="node_332020" labelType="html" label="MapPartitionsRDD [332020] [Indeterminate] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_854097 { id="cluster_854097"; isCluster="true"; label="WholeStageCodegen (1)"; 332021 [id="node_332021" labelType="html" label="MapPartitionsRDD [332021] [Indeterminate] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_854096 { id="cluster_854096"; isCluster="true"; label="InMemoryTableScan"; 332022 [id="node_332022" labelType="html" label="MapPartitionsRDD [332022] [Indeterminate] start at FileStorageAdapterImpl.java:567}"]; 332023 [id="node_332023" labelType="html" label="*(1) Project [shardId#5600320, item#5600328L AS worklistShardItemId#5600329L]\n+- *(1) Generate explode(_extract_worklistShardItemId#5600332), [shardId#5600320], false, [item#5600328L]\n +- *(1) Project [shardId#5600320, items#5600322.worklistShardItemId AS _extract_worklistShardItemId#5600332]\n +- *(1) Filter ((isnotnull(shardId#5600320) AND ((shardId#5600320 = 0_1_10000000244) AND (isOptimal#5600324 <=> false))) AND ((size(items#5600322.worklistShardItemId, true) > 0) AND isnotnull(items#5600322.worklistShardItemId)))\n +- *(1) Scan ExistingRDD[shardId#5600320,orderProposalId#5600321L,items#5600322,optimizationGroups#5600323,isOptimal#5600324,lastModified#5600325,optimizationInsights#5600326]\n [332023] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_854188 { id="cluster_854188"; isCluster="true"; label="InMemoryTableScan"; 332052 [id="node_332052" labelType="html" label="MapPartitionsRDD [332052] [Indeterminate] start at FileStorageAdapterImpl.java:567}"]; 332053 [id="node_332053" labelType="html" label="MapPartitionsRDD [332053] [Indeterminate] start at FileStorageAdapterImpl.java:567}"]; 332054 [id="node_332054" labelType="html" label="MapPartitionsRDD [332054] [Indeterminate] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_854187 { id="cluster_854187"; isCluster="true"; label="Exchange"; 332055 [id="node_332055" labelType="html" label="MapPartitionsRDD [332055] [Indeterminate] start at FileStorageAdapterImpl.java:567}"]; } } 331908->331909; 331909->331910; 331910->332020; 332020->332021; 332021->332022; 332022->332023; 332023->332052; 332052->332053; 332053->332054; 332054->332055; }

331907,331908

331910

332023

331908

331909

331910

332020

332021

332022

332023

332052

332053

332054

332055

Event Timeline

Enable zooming