crp-order-quantity-kpi-service - Details for Stage 102559 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 0.7 s
Locality Level Summary: Node local: 31; Process local: 80
Input Size / Records: 24.5 KiB / 37
Shuffle Read Size / Records: 29.3 KiB / 185
Shuffle Write Size / Records: 8.9 KiB / 88
Associated Job Ids: 5696

digraph G { id="graph_102559"; subgraph graph_stage_102559 { id="graph_stage_102559"; isCluster="true"; label="Stage 102559"; subgraph cluster_128514 { id="cluster_128514"; isCluster="true"; label="Exchange"; 49191 [id="node_49191" labelType="html" label="ShuffledRowRDD [49191] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128511 { id="cluster_128511"; isCluster="true"; label="WholeStageCodegen (1)"; 49192 [id="node_49192" labelType="html" label="MapPartitionsRDD [49192] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128534 { id="cluster_128534"; isCluster="true"; label="Exchange"; 49203 [id="node_49203" labelType="html" label="ShuffledRowRDD [49203] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128531 { id="cluster_128531"; isCluster="true"; label="WholeStageCodegen (4)"; 49204 [id="node_49204" labelType="html" label="MapPartitionsRDD [49204] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128569 { id="cluster_128569"; isCluster="true"; label="Exchange"; 49207 [id="node_49207" labelType="html" label="ShuffledRowRDD [49207] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128566 { id="cluster_128566"; isCluster="true"; label="WholeStageCodegen (6)"; 49208 [id="node_49208" labelType="html" label="MapPartitionsRDD [49208] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128523 { id="cluster_128523"; isCluster="true"; label="WholeStageCodegen (7)"; 49209 [id="node_49209" labelType="html" label="ZippedPartitionsRDD2 [49209] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 49210 [id="node_49210" labelType="html" label="MapPartitionsRDD [49210] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128522 { id="cluster_128522"; isCluster="true"; label="InMemoryTableScan"; 49211 [id="node_49211" labelType="html" label="MapPartitionsRDD [49211] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 49212 [id="node_49212" labelType="html" label="*(7) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, cachedQty#984307 AS qty#984309, demandChannel#984302, demandStream#984303, cachedKpis#984308 AS kpis#984310]\n+- *(7) SortMergeJoin [worklistShardItemId#943632L, shardId#943631], [cachedWorklistShardItemId#984306L, cachedShardId#984305], Inner\n :- *(4) Sort [worklistShardItemId#943632L ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#943632L, shardId#943631, 37), ENSURE_REQUIREMENTS, [plan_id=1625710]\n : +- *(3) HashAggregate(keys=[plant#943635, shardId#943631, version#943633, worklistShardItemId#943632L, product#943634], functions=[], output=[shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635])\n : +- Exchange hashpartitioning(plant#943635, shardId#943631, version#943633, worklistShardItemId#943632L, product#943634, 37), ENSURE_REQUIREMENTS, [plan_id=1625706]\n : +- *(2) Has... [49212] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128520 { id="cluster_128520"; isCluster="true"; label="Exchange"; 49219 [id="node_49219" labelType="html" label="ShuffledRowRDD [49219] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128517 { id="cluster_128517"; isCluster="true"; label="WholeStageCodegen (4)"; 49220 [id="node_49220" labelType="html" label="MapPartitionsRDD [49220] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128503 { id="cluster_128503"; isCluster="true"; label="WholeStageCodegen (5)"; 49221 [id="node_49221" labelType="html" label="ZippedPartitionsRDD2 [49221] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 49222 [id="node_49222" labelType="html" label="MapPartitionsRDD [49222] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128584 { id="cluster_128584"; isCluster="true"; label="InMemoryTableScan"; 49223 [id="node_49223" labelType="html" label="MapPartitionsRDD [49223] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 49224 [id="node_49224" labelType="html" label="MapPartitionsRDD [49224] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 49225 [id="node_49225" labelType="html" label="MapPartitionsRDD [49225] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128581 { id="cluster_128581"; isCluster="true"; label="WholeStageCodegen (6)"; 49226 [id="node_49226" labelType="html" label="MapPartitionsRDD [49226] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128502 { id="cluster_128502"; isCluster="true"; label="Union"; 49227 [id="node_49227" labelType="html" label="UnionRDD [49227] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128501 { id="cluster_128501"; isCluster="true"; label="InMemoryTableScan"; 49228 [id="node_49228" labelType="html" label="MapPartitionsRDD [49228] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 49229 [id="node_49229" labelType="html" label="Union\n:- *(5) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, null AS demandChannel#984542, null AS demandStream#984543, [] AS kpis#984577, true AS isNewlyCalculated#984545]\n: +- *(5) SortMergeJoin [coalesce(shardId#943631, ), isnull(shardId#943631), coalesce(worklistShardItemId#943632L, 0), isnull(worklistShardItemId#943632L), coalesce(version#943633, 0), isnull(version#943633), coalesce(product#943634, ), isnull(product#943634), coalesce(plant#943635, ), isnull(plant#943635), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#943638, 0.0))), isnull(qty#943638)], [coalesce(shardId#984534, ), isnull(shardId#984534), coalesce(worklistShardItemId#984535L, 0), isnull(worklistShardItemId#984535L), coalesce(version#984536, 0), isnull(version#984536), coalesce(product#984537, ), isnull(product#984537), coalesce(plant#984538, ), isnull(plant#984538), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#984309, 0.0))), isnull(qty#... [49229] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128712 { id="cluster_128712"; isCluster="true"; label="Exchange"; 49274 [id="node_49274" labelType="html" label="ShuffledRowRDD [49274] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128711 { id="cluster_128711"; isCluster="true"; label="ObjectHashAggregate"; 49275 [id="node_49275" labelType="html" label="MapPartitionsRDD [49275] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128723 { id="cluster_128723"; isCluster="true"; label="InMemoryTableScan"; 49276 [id="node_49276" labelType="html" label="MapPartitionsRDD [49276] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 49277 [id="node_49277" labelType="html" label="MapPartitionsRDD [49277] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 49278 [id="node_49278" labelType="html" label="MapPartitionsRDD [49278] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128719 { id="cluster_128719"; isCluster="true"; label="WholeStageCodegen (12)"; 49279 [id="node_49279" labelType="html" label="MapPartitionsRDD [49279] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128710 { id="cluster_128710"; isCluster="true"; label="Union"; 49280 [id="node_49280" labelType="html" label="UnionRDD [49280] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128709 { id="cluster_128709"; isCluster="true"; label="Exchange"; 49281 [id="node_49281" labelType="html" label="MapPartitionsRDD [49281] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 49191->49192; 49203->49204; 49207->49208; 49204->49209; 49208->49209; 49209->49210; 49210->49211; 49211->49212; 49219->49220; 49192->49221; 49220->49221; 49221->49222; 49212->49223; 49223->49224; 49224->49225; 49225->49226; 49222->49227; 49226->49227; 49227->49228; 49228->49229; 49274->49275; 49229->49276; 49276->49277; 49277->49278; 49278->49279; 49275->49280; 49279->49280; 49280->49281; }

49190,49191

49202,49203

49206,49207

49218,49219

49273,49274

49212

49229

49203

49204

49207

49208

49209

49210

49211

49212

49219

49220

49221

49222

49223

49224

49225

49226

49227

49228

49229

49274

49275

49276

49277

49278

49279

49280

49281

Event Timeline

Enable zooming