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

Resource Profile Id: 0
Total Time Across All Tasks: 6 ms
Locality Level Summary: Process local: 30
Input Size / Records: 794.0 B / 1
Shuffle Write Size / Records: 1909.0 B / 25
Associated Job Ids: 47073

digraph G { id="graph_1332029"; subgraph graph_stage_1332029 { id="graph_stage_1332029"; isCluster="true"; label="Stage 1332029"; subgraph cluster_1033465 { id="cluster_1033465"; isCluster="true"; label="repartition"; 392426 [id="node_392426" labelType="html" label="ShuffledRDD [392426] [Indeterminate] start at FileStorageAdapterImpl.java:598}"]; 392427 [id="node_392427" labelType="html" label="CoalescedRDD [392427] [Indeterminate] start at FileStorageAdapterImpl.java:598}"]; 392428 [id="node_392428" labelType="html" label="MapPartitionsRDD [392428] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1033796 { id="cluster_1033796"; isCluster="true"; label="map"; 392540 [id="node_392540" labelType="html" label="MapPartitionsRDD [392540] [Indeterminate] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1033799 { id="cluster_1033799"; isCluster="true"; label="WholeStageCodegen (1)"; 392541 [id="node_392541" labelType="html" label="MapPartitionsRDD [392541] [Indeterminate] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1033798 { id="cluster_1033798"; isCluster="true"; label="InMemoryTableScan"; 392542 [id="node_392542" labelType="html" label="MapPartitionsRDD [392542] [Indeterminate] start at FileStorageAdapterImpl.java:598}"]; 392543 [id="node_392543" labelType="html" label="*(1) Project [shardId#5573512, item#5573520L AS worklistShardItemId#5573521L]\n+- *(1) Generate explode(_extract_worklistShardItemId#5573524), [shardId#5573512], false, [item#5573520L]\n +- *(1) Project [shardId#5573512, items#5573514.worklistShardItemId AS _extract_worklistShardItemId#5573524]\n +- *(1) Filter ((isnotnull(shardId#5573512) AND ((shardId#5573512 = 0_1_10000001445) AND (isOptimal#5573516 <=> false))) AND ((size(items#5573514.worklistShardItemId, true) > 0) AND isnotnull(items#5573514.worklistShardItemId)))\n +- *(1) Scan ExistingRDD[shardId#5573512,orderProposalId#5573513L,items#5573514,optimizationGroups#5573515,isOptimal#5573516,lastModified#5573517,optimizationInsights#5573518]\n [392543] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034076 { id="cluster_1034076"; isCluster="true"; label="InMemoryTableScan"; 392633 [id="node_392633" labelType="html" label="MapPartitionsRDD [392633] [Indeterminate] start at FileStorageAdapterImpl.java:598}"]; 392634 [id="node_392634" labelType="html" label="MapPartitionsRDD [392634] [Indeterminate] start at FileStorageAdapterImpl.java:598}"]; 392635 [id="node_392635" labelType="html" label="MapPartitionsRDD [392635] [Indeterminate] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034075 { id="cluster_1034075"; isCluster="true"; label="Exchange"; 392636 [id="node_392636" labelType="html" label="MapPartitionsRDD [392636] [Indeterminate] start at FileStorageAdapterImpl.java:598}"]; } } 392426->392427; 392427->392428; 392428->392540; 392540->392541; 392541->392542; 392542->392543; 392543->392633; 392633->392634; 392634->392635; 392635->392636; }

392425,392426

392428

392543

392426

392427

392428

392540

392541

392542

392543

392633

392634

392635

392636

Event Timeline

Enable zooming