crp-order-quantity-kpi-service - Details for Job 231

Status: SUCCEEDED
Submitted: 2026/04/20 07:08:46
Duration: 3 s
Associated SQL Query: 112
Job Group: c871ced2-19a8-473b-bfe1-6d8b64ffe1bc
Completed Stages: 4
Skipped Stages: 19

Enable zooming

digraph G { id="graph_1121"; subgraph graph_stage_1121 { id="graph_stage_1121"; isCluster="true"; label="Stage 1121 (skipped)"; 1452 [id="node_1452" labelType="html" label="SQLExecutionRDD [1452] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_3836 { id="cluster_3836"; isCluster="true"; label="Scan parquet "; 1449 [id="node_1449" labelType="html" label="FileScanRDD [1449] start at FileStorageAdapterImpl.java:171}"]; 1450 [id="node_1450" labelType="html" label="MapPartitionsRDD [1450] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3833 { id="cluster_3833"; isCluster="true"; label="WholeStageCodegen (1)"; 1451 [id="node_1451" labelType="html" label="MapPartitionsRDD [1451] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3840 { id="cluster_3840"; isCluster="true"; label="WholeStageCodegen (1)"; 1453 [id="node_1453" labelType="html" label="MapPartitionsRDD [1453] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3839 { id="cluster_3839"; isCluster="true"; label="Exchange"; 1454 [id="node_1454" labelType="html" label="MapPartitionsRDD [1454] start at FileStorageAdapterImpl.java:171}"]; } } 1449->1450; 1450->1451; 1451->1452; 1452->1453; 1453->1454; }

digraph G { id="graph_1122"; subgraph graph_stage_1122 { id="graph_stage_1122"; isCluster="true"; label="Stage 1122 (skipped)"; subgraph cluster_3839 { id="cluster_3839"; isCluster="true"; label="Exchange"; 1455 [id="node_1455" labelType="html" label="ShuffledRowRDD [1455] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3838 { id="cluster_3838"; isCluster="true"; label="InMemoryTableScan"; 1456 [id="node_1456" labelType="html" label="MapPartitionsRDD [1456] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1457 [id="node_1457" labelType="html" label="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]\n+- *(1) Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]\n [1457] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3981 { id="cluster_3981"; isCluster="true"; label="InMemoryTableScan"; 1514 [id="node_1514" labelType="html" label="MapPartitionsRDD [1514] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1515 [id="node_1515" labelType="html" label="MapPartitionsRDD [1515] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1516 [id="node_1516" labelType="html" label="MapPartitionsRDD [1516] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3978 { id="cluster_3978"; isCluster="true"; label="WholeStageCodegen (2)"; 1517 [id="node_1517" labelType="html" label="MapPartitionsRDD [1517] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3977 { id="cluster_3977"; isCluster="true"; label="Exchange"; 1518 [id="node_1518" labelType="html" label="MapPartitionsRDD [1518] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1455->1456; 1456->1457; 1457->1514; 1514->1515; 1515->1516; 1516->1517; 1517->1518; }

1454,1455

1457

digraph G { id="graph_1123"; subgraph graph_stage_1123 { id="graph_stage_1123"; isCluster="true"; label="Stage 1123 (skipped)"; subgraph cluster_3831 { id="cluster_3831"; isCluster="true"; label="map"; 1447 [id="node_1447" labelType="html" label="MapPartitionsRDD [1447] [Cached] [Indeterminate] map at PeriodicAsyncRDDCheckpointWriterImpl.java:207}"]; } subgraph cluster_3832 { id="cluster_3832"; isCluster="true"; label="checkpoint"; 1448 [id="node_1448" labelType="html" label="LocalCheckpointRDD [1448] count at CachePortImpl.java:132}"]; } subgraph cluster_3879 { id="cluster_3879"; isCluster="true"; label="map"; 1474 [id="node_1474" labelType="html" label="MapPartitionsRDD [1474] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3966 { id="cluster_3966"; isCluster="true"; label="WholeStageCodegen (6)"; 1503 [id="node_1503" labelType="html" label="MapPartitionsRDD [1503] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3965 { id="cluster_3965"; isCluster="true"; label="Exchange"; 1504 [id="node_1504" labelType="html" label="MapPartitionsRDD [1504] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1448->1447; 1447->1474; 1474->1503; 1503->1504; }

1447

1474

1503

1504

digraph G { id="graph_1124"; subgraph graph_stage_1124 { id="graph_stage_1124"; isCluster="true"; label="Stage 1124 (skipped)"; subgraph cluster_3839 { id="cluster_3839"; isCluster="true"; label="Exchange"; 1455 [id="node_1455" labelType="html" label="ShuffledRowRDD [1455] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3838 { id="cluster_3838"; isCluster="true"; label="InMemoryTableScan"; 1456 [id="node_1456" labelType="html" label="MapPartitionsRDD [1456] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1457 [id="node_1457" labelType="html" label="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]\n+- *(1) Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]\n [1457] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3951 { id="cluster_3951"; isCluster="true"; label="InMemoryTableScan"; 1483 [id="node_1483" labelType="html" label="MapPartitionsRDD [1483] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1484 [id="node_1484" labelType="html" label="MapPartitionsRDD [1484] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1485 [id="node_1485" labelType="html" label="MapPartitionsRDD [1485] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3948 { id="cluster_3948"; isCluster="true"; label="WholeStageCodegen (1)"; 1486 [id="node_1486" labelType="html" label="MapPartitionsRDD [1486] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3947 { id="cluster_3947"; isCluster="true"; label="Exchange"; 1487 [id="node_1487" labelType="html" label="MapPartitionsRDD [1487] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1455->1456; 1456->1457; 1457->1483; 1483->1484; 1484->1485; 1485->1486; 1486->1487; }

1454,1455

1457

digraph G { id="graph_1125"; subgraph graph_stage_1125 { id="graph_stage_1125"; isCluster="true"; label="Stage 1125 (skipped)"; subgraph cluster_3831 { id="cluster_3831"; isCluster="true"; label="map"; 1447 [id="node_1447" labelType="html" label="MapPartitionsRDD [1447] [Cached] [Indeterminate] map at PeriodicAsyncRDDCheckpointWriterImpl.java:207}"]; } subgraph cluster_3832 { id="cluster_3832"; isCluster="true"; label="checkpoint"; 1448 [id="node_1448" labelType="html" label="LocalCheckpointRDD [1448] count at CachePortImpl.java:132}"]; } subgraph cluster_3879 { id="cluster_3879"; isCluster="true"; label="map"; 1474 [id="node_1474" labelType="html" label="MapPartitionsRDD [1474] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3987 { id="cluster_3987"; isCluster="true"; label="WholeStageCodegen (4)"; 1521 [id="node_1521" labelType="html" label="MapPartitionsRDD [1521] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3986 { id="cluster_3986"; isCluster="true"; label="Exchange"; 1522 [id="node_1522" labelType="html" label="MapPartitionsRDD [1522] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1448->1447; 1447->1474; 1474->1521; 1521->1522; }

1447

1474

1521

1522

digraph G { id="graph_1126"; subgraph graph_stage_1126 { id="graph_stage_1126"; isCluster="true"; label="Stage 1126 (skipped)"; subgraph cluster_3831 { id="cluster_3831"; isCluster="true"; label="map"; 1447 [id="node_1447" labelType="html" label="MapPartitionsRDD [1447] [Cached] [Indeterminate] map at PeriodicAsyncRDDCheckpointWriterImpl.java:207}"]; } subgraph cluster_3832 { id="cluster_3832"; isCluster="true"; label="checkpoint"; 1448 [id="node_1448" labelType="html" label="LocalCheckpointRDD [1448] count at CachePortImpl.java:132}"]; } subgraph cluster_3879 { id="cluster_3879"; isCluster="true"; label="map"; 1474 [id="node_1474" labelType="html" label="MapPartitionsRDD [1474] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3957 { id="cluster_3957"; isCluster="true"; label="WholeStageCodegen (3)"; 1490 [id="node_1490" labelType="html" label="MapPartitionsRDD [1490] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3956 { id="cluster_3956"; isCluster="true"; label="Exchange"; 1491 [id="node_1491" labelType="html" label="MapPartitionsRDD [1491] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1448->1447; 1447->1474; 1474->1490; 1490->1491; }

1447

1474

1490

1491

digraph G { id="graph_1127"; subgraph graph_stage_1127 { id="graph_stage_1127"; isCluster="true"; label="Stage 1127 (skipped)"; subgraph cluster_3947 { id="cluster_3947"; isCluster="true"; label="Exchange"; 1488 [id="node_1488" labelType="html" label="ShuffledRowRDD [1488] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3944 { id="cluster_3944"; isCluster="true"; label="WholeStageCodegen (2)"; 1489 [id="node_1489" labelType="html" label="MapPartitionsRDD [1489] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3956 { id="cluster_3956"; isCluster="true"; label="Exchange"; 1492 [id="node_1492" labelType="html" label="ShuffledRowRDD [1492] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3953 { id="cluster_3953"; isCluster="true"; label="WholeStageCodegen (4)"; 1500 [id="node_1500" labelType="html" label="MapPartitionsRDD [1500] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3935 { id="cluster_3935"; isCluster="true"; label="WholeStageCodegen (5)"; 1501 [id="node_1501" labelType="html" label="ZippedPartitionsRDD2 [1501] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1502 [id="node_1502" labelType="html" label="MapPartitionsRDD [1502] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3965 { id="cluster_3965"; isCluster="true"; label="Exchange"; 1505 [id="node_1505" labelType="html" label="ShuffledRowRDD [1505] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3962 { id="cluster_3962"; isCluster="true"; label="WholeStageCodegen (7)"; 1506 [id="node_1506" labelType="html" label="MapPartitionsRDD [1506] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3931 { id="cluster_3931"; isCluster="true"; label="WholeStageCodegen (8)"; 1507 [id="node_1507" labelType="html" label="ZippedPartitionsRDD2 [1507] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1508 [id="node_1508" labelType="html" label="MapPartitionsRDD [1508] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3930 { id="cluster_3930"; isCluster="true"; label="InMemoryTableScan"; 1509 [id="node_1509" labelType="html" label="MapPartitionsRDD [1509] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1510 [id="node_1510" labelType="html" label="*(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455]\n+- *(8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner\n :- *(5) Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0\n : +- *(5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449])\n : +- *(5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448])\n : +- *(5) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]\n : +- *(5) SortMergeJoin [worklistShardItemId#446L, shardId#445]... [1510] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1511 [id="node_1511" labelType="html" label="MapPartitionsRDD [1511] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1512 [id="node_1512" labelType="html" label="MapPartitionsRDD [1512] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1513 [id="node_1513" labelType="html" label="MapPartitionsRDD [1513] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3977 { id="cluster_3977"; isCluster="true"; label="Exchange"; 1519 [id="node_1519" labelType="html" label="ShuffledRowRDD [1519] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3974 { id="cluster_3974"; isCluster="true"; label="WholeStageCodegen (3)"; 1520 [id="node_1520" labelType="html" label="MapPartitionsRDD [1520] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3986 { id="cluster_3986"; isCluster="true"; label="Exchange"; 1523 [id="node_1523" labelType="html" label="ShuffledRowRDD [1523] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3983 { id="cluster_3983"; isCluster="true"; label="WholeStageCodegen (5)"; 1524 [id="node_1524" labelType="html" label="MapPartitionsRDD [1524] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3970 { id="cluster_3970"; isCluster="true"; label="WholeStageCodegen (6)"; 1525 [id="node_1525" labelType="html" label="ZippedPartitionsRDD2 [1525] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1526 [id="node_1526" labelType="html" label="MapPartitionsRDD [1526] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3929 { id="cluster_3929"; isCluster="true"; label="Union"; 1527 [id="node_1527" labelType="html" label="UnionRDD [1527] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3928 { id="cluster_3928"; isCluster="true"; label="Exchange"; 1528 [id="node_1528" labelType="html" label="MapPartitionsRDD [1528] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1488->1489; 1492->1500; 1489->1501; 1500->1501; 1501->1502; 1505->1506; 1502->1507; 1506->1507; 1507->1508; 1508->1509; 1509->1510; 1510->1511; 1511->1512; 1512->1513; 1519->1520; 1523->1524; 1520->1525; 1524->1525; 1525->1526; 1513->1527; 1526->1527; 1527->1528; }

1487,1488

1491,1492

1504,1505

1518,1519

1522,1523

1510

1492

1500

1501

1502

1505

1506

1507

1508

1509

1510

1511

1512

1513

1523

1524

1525

1526

1527

1528

digraph G { id="graph_1128"; subgraph graph_stage_1128 { id="graph_stage_1128"; isCluster="true"; label="Stage 1128 (skipped)"; subgraph cluster_3839 { id="cluster_3839"; isCluster="true"; label="Exchange"; 1455 [id="node_1455" labelType="html" label="ShuffledRowRDD [1455] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3838 { id="cluster_3838"; isCluster="true"; label="InMemoryTableScan"; 1456 [id="node_1456" labelType="html" label="MapPartitionsRDD [1456] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1457 [id="node_1457" labelType="html" label="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]\n+- *(1) Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]\n [1457] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3923 { id="cluster_3923"; isCluster="true"; label="InMemoryTableScan"; 1477 [id="node_1477" labelType="html" label="MapPartitionsRDD [1477] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1478 [id="node_1478" labelType="html" label="MapPartitionsRDD [1478] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1479 [id="node_1479" labelType="html" label="MapPartitionsRDD [1479] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3922 { id="cluster_3922"; isCluster="true"; label="Exchange"; 1480 [id="node_1480" labelType="html" label="MapPartitionsRDD [1480] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1455->1456; 1456->1457; 1457->1477; 1477->1478; 1478->1479; 1479->1480; }

1454,1455

1457

digraph G { id="graph_1129"; subgraph graph_stage_1129 { id="graph_stage_1129"; isCluster="true"; label="Stage 1129 (skipped)"; subgraph cluster_3922 { id="cluster_3922"; isCluster="true"; label="Exchange"; 1481 [id="node_1481" labelType="html" label="ShuffledRowRDD [1481] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3919 { id="cluster_3919"; isCluster="true"; label="WholeStageCodegen (1)"; 1482 [id="node_1482" labelType="html" label="MapPartitionsRDD [1482] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3947 { id="cluster_3947"; isCluster="true"; label="Exchange"; 1488 [id="node_1488" labelType="html" label="ShuffledRowRDD [1488] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3944 { id="cluster_3944"; isCluster="true"; label="WholeStageCodegen (2)"; 1489 [id="node_1489" labelType="html" label="MapPartitionsRDD [1489] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3956 { id="cluster_3956"; isCluster="true"; label="Exchange"; 1492 [id="node_1492" labelType="html" label="ShuffledRowRDD [1492] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3953 { id="cluster_3953"; isCluster="true"; label="WholeStageCodegen (4)"; 1500 [id="node_1500" labelType="html" label="MapPartitionsRDD [1500] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3935 { id="cluster_3935"; isCluster="true"; label="WholeStageCodegen (5)"; 1501 [id="node_1501" labelType="html" label="ZippedPartitionsRDD2 [1501] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1502 [id="node_1502" labelType="html" label="MapPartitionsRDD [1502] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3965 { id="cluster_3965"; isCluster="true"; label="Exchange"; 1505 [id="node_1505" labelType="html" label="ShuffledRowRDD [1505] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3962 { id="cluster_3962"; isCluster="true"; label="WholeStageCodegen (7)"; 1506 [id="node_1506" labelType="html" label="MapPartitionsRDD [1506] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3931 { id="cluster_3931"; isCluster="true"; label="WholeStageCodegen (8)"; 1507 [id="node_1507" labelType="html" label="ZippedPartitionsRDD2 [1507] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1508 [id="node_1508" labelType="html" label="MapPartitionsRDD [1508] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3930 { id="cluster_3930"; isCluster="true"; label="InMemoryTableScan"; 1509 [id="node_1509" labelType="html" label="MapPartitionsRDD [1509] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1510 [id="node_1510" labelType="html" label="*(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455]\n+- *(8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner\n :- *(5) Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0\n : +- *(5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449])\n : +- *(5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448])\n : +- *(5) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]\n : +- *(5) SortMergeJoin [worklistShardItemId#446L, shardId#445]... [1510] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3928 { id="cluster_3928"; isCluster="true"; label="Exchange"; 1529 [id="node_1529" labelType="html" label="ShuffledRowRDD [1529] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3925 { id="cluster_3925"; isCluster="true"; label="WholeStageCodegen (7)"; 1530 [id="node_1530" labelType="html" label="MapPartitionsRDD [1530] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3911 { id="cluster_3911"; isCluster="true"; label="WholeStageCodegen (8)"; 1531 [id="node_1531" labelType="html" label="ZippedPartitionsRDD2 [1531] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1532 [id="node_1532" labelType="html" label="MapPartitionsRDD [1532] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3998 { id="cluster_3998"; isCluster="true"; label="InMemoryTableScan"; 1533 [id="node_1533" labelType="html" label="MapPartitionsRDD [1533] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1534 [id="node_1534" labelType="html" label="MapPartitionsRDD [1534] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1535 [id="node_1535" labelType="html" label="MapPartitionsRDD [1535] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3995 { id="cluster_3995"; isCluster="true"; label="WholeStageCodegen (9)"; 1536 [id="node_1536" labelType="html" label="MapPartitionsRDD [1536] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3910 { id="cluster_3910"; isCluster="true"; label="Union"; 1537 [id="node_1537" labelType="html" label="UnionRDD [1537] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3909 { id="cluster_3909"; isCluster="true"; label="InMemoryTableScan"; 1538 [id="node_1538" labelType="html" label="MapPartitionsRDD [1538] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1539 [id="node_1539" labelType="html" label="Union\n:- *(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#24687, null AS demandStream#24688, [] AS kpis#24722, true AS isNewlyCalculated#24690]\n: +- *(8) SortMergeJoin [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)], [coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454)], LeftAnti\n: :- *(1) Sort [coalesce(shardId#445, ) ASC NUL... [1539] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4157 { id="cluster_4157"; isCluster="true"; label="InMemoryTableScan"; 1580 [id="node_1580" labelType="html" label="MapPartitionsRDD [1580] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1581 [id="node_1581" labelType="html" label="MapPartitionsRDD [1581] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1582 [id="node_1582" labelType="html" label="MapPartitionsRDD [1582] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4153 { id="cluster_4153"; isCluster="true"; label="WholeStageCodegen (10)"; 1583 [id="node_1583" labelType="html" label="MapPartitionsRDD [1583] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4152 { id="cluster_4152"; isCluster="true"; label="ObjectHashAggregate"; 1584 [id="node_1584" labelType="html" label="MapPartitionsRDD [1584] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4151 { id="cluster_4151"; isCluster="true"; label="Exchange"; 1585 [id="node_1585" labelType="html" label="MapPartitionsRDD [1585] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1481->1482; 1488->1489; 1492->1500; 1489->1501; 1500->1501; 1501->1502; 1505->1506; 1502->1507; 1506->1507; 1507->1508; 1508->1509; 1509->1510; 1529->1530; 1482->1531; 1530->1531; 1531->1532; 1510->1533; 1533->1534; 1534->1535; 1535->1536; 1532->1537; 1536->1537; 1537->1538; 1538->1539; 1539->1580; 1580->1581; 1581->1582; 1582->1583; 1583->1584; 1584->1585; }

1480,1481

1487,1488

1491,1492

1504,1505

1528,1529

1510

1539

1492

1500

1501

1502

1505

1506

1507

1508

1509

1510

1529

1530

1531

1532

1533

1534

1535

1536

1537

1538

1539

1580

1581

1582

1583

1584

1585

digraph G { id="graph_1130"; subgraph graph_stage_1130 { id="graph_stage_1130"; isCluster="true"; label="Stage 1130 (skipped)"; subgraph cluster_3839 { id="cluster_3839"; isCluster="true"; label="Exchange"; 1455 [id="node_1455" labelType="html" label="ShuffledRowRDD [1455] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3838 { id="cluster_3838"; isCluster="true"; label="InMemoryTableScan"; 1456 [id="node_1456" labelType="html" label="MapPartitionsRDD [1456] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1457 [id="node_1457" labelType="html" label="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]\n+- *(1) Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]\n [1457] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4143 { id="cluster_4143"; isCluster="true"; label="InMemoryTableScan"; 1563 [id="node_1563" labelType="html" label="MapPartitionsRDD [1563] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1564 [id="node_1564" labelType="html" label="MapPartitionsRDD [1564] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1565 [id="node_1565" labelType="html" label="MapPartitionsRDD [1565] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4130 { id="cluster_4130"; isCluster="true"; label="WholeStageCodegen (6)"; 1566 [id="node_1566" labelType="html" label="MapPartitionsRDD [1566] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4129 { id="cluster_4129"; isCluster="true"; label="Exchange"; 1567 [id="node_1567" labelType="html" label="MapPartitionsRDD [1567] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1455->1456; 1456->1457; 1457->1563; 1563->1564; 1564->1565; 1565->1566; 1566->1567; }

1454,1455

1457

digraph G { id="graph_1131"; subgraph graph_stage_1131 { id="graph_stage_1131"; isCluster="true"; label="Stage 1131 (skipped)"; subgraph cluster_3839 { id="cluster_3839"; isCluster="true"; label="Exchange"; 1455 [id="node_1455" labelType="html" label="ShuffledRowRDD [1455] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3838 { id="cluster_3838"; isCluster="true"; label="InMemoryTableScan"; 1456 [id="node_1456" labelType="html" label="MapPartitionsRDD [1456] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1457 [id="node_1457" labelType="html" label="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]\n+- *(1) Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]\n [1457] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4124 { id="cluster_4124"; isCluster="true"; label="InMemoryTableScan"; 1556 [id="node_1556" labelType="html" label="MapPartitionsRDD [1556] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1557 [id="node_1557" labelType="html" label="MapPartitionsRDD [1557] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1558 [id="node_1558" labelType="html" label="MapPartitionsRDD [1558] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4114 { id="cluster_4114"; isCluster="true"; label="WholeStageCodegen (3)"; 1559 [id="node_1559" labelType="html" label="MapPartitionsRDD [1559] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4113 { id="cluster_4113"; isCluster="true"; label="Exchange"; 1560 [id="node_1560" labelType="html" label="MapPartitionsRDD [1560] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1455->1456; 1456->1457; 1457->1556; 1556->1557; 1557->1558; 1558->1559; 1559->1560; }

1454,1455

1457

digraph G { id="graph_1132"; subgraph graph_stage_1132 { id="graph_stage_1132"; isCluster="true"; label="Stage 1132 (skipped)"; subgraph cluster_4113 { id="cluster_4113"; isCluster="true"; label="Exchange"; 1561 [id="node_1561" labelType="html" label="ShuffledRowRDD [1561] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4110 { id="cluster_4110"; isCluster="true"; label="WholeStageCodegen (4)"; 1562 [id="node_1562" labelType="html" label="MapPartitionsRDD [1562] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4129 { id="cluster_4129"; isCluster="true"; label="Exchange"; 1568 [id="node_1568" labelType="html" label="ShuffledRowRDD [1568] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4126 { id="cluster_4126"; isCluster="true"; label="WholeStageCodegen (7)"; 1569 [id="node_1569" labelType="html" label="MapPartitionsRDD [1569] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4106 { id="cluster_4106"; isCluster="true"; label="WholeStageCodegen (8)"; 1570 [id="node_1570" labelType="html" label="ZippedPartitionsRDD2 [1570] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1571 [id="node_1571" labelType="html" label="MapPartitionsRDD [1571] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4105 { id="cluster_4105"; isCluster="true"; label="ObjectHashAggregate"; 1572 [id="node_1572" labelType="html" label="MapPartitionsRDD [1572] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4104 { id="cluster_4104"; isCluster="true"; label="Exchange"; 1573 [id="node_1573" labelType="html" label="MapPartitionsRDD [1573] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1561->1562; 1568->1569; 1562->1570; 1569->1570; 1570->1571; 1571->1572; 1572->1573; }

1560,1561

1567,1568

digraph G { id="graph_1133"; subgraph graph_stage_1133 { id="graph_stage_1133"; isCluster="true"; label="Stage 1133 (skipped)"; subgraph cluster_4104 { id="cluster_4104"; isCluster="true"; label="Exchange"; 1574 [id="node_1574" labelType="html" label="ShuffledRowRDD [1574] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4103 { id="cluster_4103"; isCluster="true"; label="ObjectHashAggregate"; 1575 [id="node_1575" labelType="html" label="MapPartitionsRDD [1575] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4102 { id="cluster_4102"; isCluster="true"; label="Project"; 1576 [id="node_1576" labelType="html" label="MapPartitionsRDD [1576] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4101 { id="cluster_4101"; isCluster="true"; label="Exchange"; 1577 [id="node_1577" labelType="html" label="MapPartitionsRDD [1577] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1574->1575; 1575->1576; 1576->1577; }

1573,1574

digraph G { id="graph_1134"; subgraph graph_stage_1134 { id="graph_stage_1134"; isCluster="true"; label="Stage 1134 (skipped)"; subgraph cluster_3922 { id="cluster_3922"; isCluster="true"; label="Exchange"; 1481 [id="node_1481" labelType="html" label="ShuffledRowRDD [1481] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3919 { id="cluster_3919"; isCluster="true"; label="WholeStageCodegen (1)"; 1482 [id="node_1482" labelType="html" label="MapPartitionsRDD [1482] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3947 { id="cluster_3947"; isCluster="true"; label="Exchange"; 1488 [id="node_1488" labelType="html" label="ShuffledRowRDD [1488] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3944 { id="cluster_3944"; isCluster="true"; label="WholeStageCodegen (2)"; 1489 [id="node_1489" labelType="html" label="MapPartitionsRDD [1489] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3956 { id="cluster_3956"; isCluster="true"; label="Exchange"; 1492 [id="node_1492" labelType="html" label="ShuffledRowRDD [1492] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3953 { id="cluster_3953"; isCluster="true"; label="WholeStageCodegen (4)"; 1500 [id="node_1500" labelType="html" label="MapPartitionsRDD [1500] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3935 { id="cluster_3935"; isCluster="true"; label="WholeStageCodegen (5)"; 1501 [id="node_1501" labelType="html" label="ZippedPartitionsRDD2 [1501] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1502 [id="node_1502" labelType="html" label="MapPartitionsRDD [1502] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3965 { id="cluster_3965"; isCluster="true"; label="Exchange"; 1505 [id="node_1505" labelType="html" label="ShuffledRowRDD [1505] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3962 { id="cluster_3962"; isCluster="true"; label="WholeStageCodegen (7)"; 1506 [id="node_1506" labelType="html" label="MapPartitionsRDD [1506] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3931 { id="cluster_3931"; isCluster="true"; label="WholeStageCodegen (8)"; 1507 [id="node_1507" labelType="html" label="ZippedPartitionsRDD2 [1507] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1508 [id="node_1508" labelType="html" label="MapPartitionsRDD [1508] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3930 { id="cluster_3930"; isCluster="true"; label="InMemoryTableScan"; 1509 [id="node_1509" labelType="html" label="MapPartitionsRDD [1509] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1510 [id="node_1510" labelType="html" label="*(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455]\n+- *(8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner\n :- *(5) Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0\n : +- *(5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449])\n : +- *(5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448])\n : +- *(5) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]\n : +- *(5) SortMergeJoin [worklistShardItemId#446L, shardId#445]... [1510] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3928 { id="cluster_3928"; isCluster="true"; label="Exchange"; 1529 [id="node_1529" labelType="html" label="ShuffledRowRDD [1529] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3925 { id="cluster_3925"; isCluster="true"; label="WholeStageCodegen (7)"; 1530 [id="node_1530" labelType="html" label="MapPartitionsRDD [1530] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3911 { id="cluster_3911"; isCluster="true"; label="WholeStageCodegen (8)"; 1531 [id="node_1531" labelType="html" label="ZippedPartitionsRDD2 [1531] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1532 [id="node_1532" labelType="html" label="MapPartitionsRDD [1532] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3998 { id="cluster_3998"; isCluster="true"; label="InMemoryTableScan"; 1533 [id="node_1533" labelType="html" label="MapPartitionsRDD [1533] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1534 [id="node_1534" labelType="html" label="MapPartitionsRDD [1534] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1535 [id="node_1535" labelType="html" label="MapPartitionsRDD [1535] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3995 { id="cluster_3995"; isCluster="true"; label="WholeStageCodegen (9)"; 1536 [id="node_1536" labelType="html" label="MapPartitionsRDD [1536] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3910 { id="cluster_3910"; isCluster="true"; label="Union"; 1537 [id="node_1537" labelType="html" label="UnionRDD [1537] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3909 { id="cluster_3909"; isCluster="true"; label="InMemoryTableScan"; 1538 [id="node_1538" labelType="html" label="MapPartitionsRDD [1538] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1539 [id="node_1539" labelType="html" label="Union\n:- *(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#24687, null AS demandStream#24688, [] AS kpis#24722, true AS isNewlyCalculated#24690]\n: +- *(8) SortMergeJoin [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)], [coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454)], LeftAnti\n: :- *(1) Sort [coalesce(shardId#445, ) ASC NUL... [1539] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4151 { id="cluster_4151"; isCluster="true"; label="Exchange"; 1586 [id="node_1586" labelType="html" label="ShuffledRowRDD [1586] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4150 { id="cluster_4150"; isCluster="true"; label="ObjectHashAggregate"; 1587 [id="node_1587" labelType="html" label="MapPartitionsRDD [1587] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4162 { id="cluster_4162"; isCluster="true"; label="InMemoryTableScan"; 1588 [id="node_1588" labelType="html" label="MapPartitionsRDD [1588] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1589 [id="node_1589" labelType="html" label="MapPartitionsRDD [1589] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1590 [id="node_1590" labelType="html" label="MapPartitionsRDD [1590] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4158 { id="cluster_4158"; isCluster="true"; label="WholeStageCodegen (11)"; 1591 [id="node_1591" labelType="html" label="MapPartitionsRDD [1591] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4149 { id="cluster_4149"; isCluster="true"; label="Union"; 1592 [id="node_1592" labelType="html" label="UnionRDD [1592] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4148 { id="cluster_4148"; isCluster="true"; label="Exchange"; 1593 [id="node_1593" labelType="html" label="MapPartitionsRDD [1593] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1481->1482; 1488->1489; 1492->1500; 1489->1501; 1500->1501; 1501->1502; 1505->1506; 1502->1507; 1506->1507; 1507->1508; 1508->1509; 1509->1510; 1529->1530; 1482->1531; 1530->1531; 1531->1532; 1510->1533; 1533->1534; 1534->1535; 1535->1536; 1532->1537; 1536->1537; 1537->1538; 1538->1539; 1586->1587; 1539->1588; 1588->1589; 1589->1590; 1590->1591; 1587->1592; 1591->1592; 1592->1593; }

1480,1481

1487,1488

1491,1492

1504,1505

1528,1529

1585,1586

1510

1539

1492

1500

1501

1502

1505

1506

1507

1508

1509

1510

1529

1530

1531

1532

1533

1534

1535

1536

1537

1538

1539

1586

1587

1588

1589

1590

1591

1592

1593

digraph G { id="graph_1135"; subgraph graph_stage_1135 { id="graph_stage_1135"; isCluster="true"; label="Stage 1135 (skipped)"; subgraph cluster_4101 { id="cluster_4101"; isCluster="true"; label="Exchange"; 1578 [id="node_1578" labelType="html" label="ShuffledRowRDD [1578] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4098 { id="cluster_4098"; isCluster="true"; label="WholeStageCodegen (9)"; 1579 [id="node_1579" labelType="html" label="MapPartitionsRDD [1579] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4148 { id="cluster_4148"; isCluster="true"; label="Exchange"; 1594 [id="node_1594" labelType="html" label="ShuffledRowRDD [1594] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4145 { id="cluster_4145"; isCluster="true"; label="WholeStageCodegen (12)"; 1595 [id="node_1595" labelType="html" label="MapPartitionsRDD [1595] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4094 { id="cluster_4094"; isCluster="true"; label="WholeStageCodegen (13)"; 1596 [id="node_1596" labelType="html" label="ZippedPartitionsRDD2 [1596] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1597 [id="node_1597" labelType="html" label="MapPartitionsRDD [1597] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4093 { id="cluster_4093"; isCluster="true"; label="ObjectHashAggregate"; 1598 [id="node_1598" labelType="html" label="MapPartitionsRDD [1598] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4092 { id="cluster_4092"; isCluster="true"; label="Exchange"; 1599 [id="node_1599" labelType="html" label="MapPartitionsRDD [1599] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1578->1579; 1594->1595; 1579->1596; 1595->1596; 1596->1597; 1597->1598; 1598->1599; }

1577,1578

1593,1594

1594

1595

1596

1597

1598

1599

digraph G { id="graph_1136"; subgraph graph_stage_1136 { id="graph_stage_1136"; isCluster="true"; label="Stage 1136 (skipped)"; subgraph cluster_3922 { id="cluster_3922"; isCluster="true"; label="Exchange"; 1481 [id="node_1481" labelType="html" label="ShuffledRowRDD [1481] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3919 { id="cluster_3919"; isCluster="true"; label="WholeStageCodegen (1)"; 1482 [id="node_1482" labelType="html" label="MapPartitionsRDD [1482] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3947 { id="cluster_3947"; isCluster="true"; label="Exchange"; 1488 [id="node_1488" labelType="html" label="ShuffledRowRDD [1488] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3944 { id="cluster_3944"; isCluster="true"; label="WholeStageCodegen (2)"; 1489 [id="node_1489" labelType="html" label="MapPartitionsRDD [1489] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3956 { id="cluster_3956"; isCluster="true"; label="Exchange"; 1492 [id="node_1492" labelType="html" label="ShuffledRowRDD [1492] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3953 { id="cluster_3953"; isCluster="true"; label="WholeStageCodegen (4)"; 1500 [id="node_1500" labelType="html" label="MapPartitionsRDD [1500] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3935 { id="cluster_3935"; isCluster="true"; label="WholeStageCodegen (5)"; 1501 [id="node_1501" labelType="html" label="ZippedPartitionsRDD2 [1501] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1502 [id="node_1502" labelType="html" label="MapPartitionsRDD [1502] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3965 { id="cluster_3965"; isCluster="true"; label="Exchange"; 1505 [id="node_1505" labelType="html" label="ShuffledRowRDD [1505] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3962 { id="cluster_3962"; isCluster="true"; label="WholeStageCodegen (7)"; 1506 [id="node_1506" labelType="html" label="MapPartitionsRDD [1506] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3931 { id="cluster_3931"; isCluster="true"; label="WholeStageCodegen (8)"; 1507 [id="node_1507" labelType="html" label="ZippedPartitionsRDD2 [1507] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1508 [id="node_1508" labelType="html" label="MapPartitionsRDD [1508] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3930 { id="cluster_3930"; isCluster="true"; label="InMemoryTableScan"; 1509 [id="node_1509" labelType="html" label="MapPartitionsRDD [1509] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1510 [id="node_1510" labelType="html" label="*(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455]\n+- *(8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner\n :- *(5) Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0\n : +- *(5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449])\n : +- *(5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448])\n : +- *(5) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]\n : +- *(5) SortMergeJoin [worklistShardItemId#446L, shardId#445]... [1510] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3928 { id="cluster_3928"; isCluster="true"; label="Exchange"; 1529 [id="node_1529" labelType="html" label="ShuffledRowRDD [1529] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3925 { id="cluster_3925"; isCluster="true"; label="WholeStageCodegen (7)"; 1530 [id="node_1530" labelType="html" label="MapPartitionsRDD [1530] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3911 { id="cluster_3911"; isCluster="true"; label="WholeStageCodegen (8)"; 1531 [id="node_1531" labelType="html" label="ZippedPartitionsRDD2 [1531] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1532 [id="node_1532" labelType="html" label="MapPartitionsRDD [1532] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3998 { id="cluster_3998"; isCluster="true"; label="InMemoryTableScan"; 1533 [id="node_1533" labelType="html" label="MapPartitionsRDD [1533] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1534 [id="node_1534" labelType="html" label="MapPartitionsRDD [1534] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1535 [id="node_1535" labelType="html" label="MapPartitionsRDD [1535] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3995 { id="cluster_3995"; isCluster="true"; label="WholeStageCodegen (9)"; 1536 [id="node_1536" labelType="html" label="MapPartitionsRDD [1536] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3910 { id="cluster_3910"; isCluster="true"; label="Union"; 1537 [id="node_1537" labelType="html" label="UnionRDD [1537] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3909 { id="cluster_3909"; isCluster="true"; label="InMemoryTableScan"; 1538 [id="node_1538" labelType="html" label="MapPartitionsRDD [1538] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1539 [id="node_1539" labelType="html" label="Union\n:- *(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#24687, null AS demandStream#24688, [] AS kpis#24722, true AS isNewlyCalculated#24690]\n: +- *(8) SortMergeJoin [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)], [coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454)], LeftAnti\n: :- *(1) Sort [coalesce(shardId#445, ) ASC NUL... [1539] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4274 { id="cluster_4274"; isCluster="true"; label="InMemoryTableScan"; 1629 [id="node_1629" labelType="html" label="MapPartitionsRDD [1629] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1630 [id="node_1630" labelType="html" label="MapPartitionsRDD [1630] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1631 [id="node_1631" labelType="html" label="MapPartitionsRDD [1631] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4269 { id="cluster_4269"; isCluster="true"; label="WholeStageCodegen (4)"; 1632 [id="node_1632" labelType="html" label="MapPartitionsRDD [1632] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4268 { id="cluster_4268"; isCluster="true"; label="Exchange"; 1633 [id="node_1633" labelType="html" label="MapPartitionsRDD [1633] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1481->1482; 1488->1489; 1492->1500; 1489->1501; 1500->1501; 1501->1502; 1505->1506; 1502->1507; 1506->1507; 1507->1508; 1508->1509; 1509->1510; 1529->1530; 1482->1531; 1530->1531; 1531->1532; 1510->1533; 1533->1534; 1534->1535; 1535->1536; 1532->1537; 1536->1537; 1537->1538; 1538->1539; 1539->1629; 1629->1630; 1630->1631; 1631->1632; 1632->1633; }

1480,1481

1487,1488

1491,1492

1504,1505

1528,1529

1510

1539

1492

1500

1501

1502

1505

1506

1507

1508

1509

1510

1529

1530

1531

1532

1533

1534

1535

1536

1537

1538

1539

1629

1630

1631

1632

1633

digraph G { id="graph_1137"; subgraph graph_stage_1137 { id="graph_stage_1137"; isCluster="true"; label="Stage 1137 (skipped)"; subgraph cluster_4268 { id="cluster_4268"; isCluster="true"; label="Exchange"; 1634 [id="node_1634" labelType="html" label="ShuffledRowRDD [1634] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4265 { id="cluster_4265"; isCluster="true"; label="WholeStageCodegen (5)"; 1635 [id="node_1635" labelType="html" label="MapPartitionsRDD [1635] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4264 { id="cluster_4264"; isCluster="true"; label="Exchange"; 1636 [id="node_1636" labelType="html" label="MapPartitionsRDD [1636] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1634->1635; 1635->1636; }

1633,1634

1634

1635

1636

digraph G { id="graph_1138"; subgraph graph_stage_1138 { id="graph_stage_1138"; isCluster="true"; label="Stage 1138 (skipped)"; 1605 [id="node_1605" labelType="html" label="SQLExecutionRDD [1605] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_4092 { id="cluster_4092"; isCluster="true"; label="Exchange"; 1600 [id="node_1600" labelType="html" label="ShuffledRowRDD [1600] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4091 { id="cluster_4091"; isCluster="true"; label="ObjectHashAggregate"; 1601 [id="node_1601" labelType="html" label="MapPartitionsRDD [1601] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4002 { id="cluster_4002"; isCluster="true"; label="WholeStageCodegen (16)"; 1602 [id="node_1602" labelType="html" label="MapPartitionsRDD [1602] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3897 { id="cluster_3897"; isCluster="true"; label="DeserializeToObject"; 1603 [id="node_1603" labelType="html" label="MapPartitionsRDD [1603] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3889 { id="cluster_3889"; isCluster="true"; label="MapPartitions"; 1604 [id="node_1604" labelType="html" label="MapPartitionsRDD [1604] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4163 { id="cluster_4163"; isCluster="true"; label="mapPartitions"; 1606 [id="node_1606" labelType="html" label="MapPartitionsRDD [1606] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4245 { id="cluster_4245"; isCluster="true"; label="Scan"; 1607 [id="node_1607" labelType="html" label="MapPartitionsRDD [1607] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4239 { id="cluster_4239"; isCluster="true"; label="WholeStageCodegen (1)"; 1608 [id="node_1608" labelType="html" label="MapPartitionsRDD [1608] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4238 { id="cluster_4238"; isCluster="true"; label="InMemoryTableScan"; 1609 [id="node_1609" labelType="html" label="MapPartitionsRDD [1609] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1610 [id="node_1610" labelType="html" label="*(1) Generate explode(prodPlantResults#27230), false, [prodPlantResults#27237]\n+- *(1) Project [prodPlantResults#27230]\n +- *(1) Filter ((size(prodPlantResults#27230, true) > 0) AND isnotnull(prodPlantResults#27230))\n +- *(1) SerializeFromObject [mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement)))) null else named_struct(measuredUnit, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true)... [1610] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1611 [id="node_1611" labelType="html" label="MapPartitionsRDD [1611] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1612 [id="node_1612" labelType="html" label="MapPartitionsRDD [1612] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1613 [id="node_1613" labelType="html" label="MapPartitionsRDD [1613] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4237 { id="cluster_4237"; isCluster="true"; label="Project"; 1614 [id="node_1614" labelType="html" label="MapPartitionsRDD [1614] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4252 { id="cluster_4252"; isCluster="true"; label="InMemoryTableScan"; 1615 [id="node_1615" labelType="html" label="MapPartitionsRDD [1615] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1616 [id="node_1616" labelType="html" label="MapPartitionsRDD [1616] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1617 [id="node_1617" labelType="html" label="MapPartitionsRDD [1617] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4247 { id="cluster_4247"; isCluster="true"; label="WholeStageCodegen (1)"; 1618 [id="node_1618" labelType="html" label="MapPartitionsRDD [1618] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4246 { id="cluster_4246"; isCluster="true"; label="Project"; 1619 [id="node_1619" labelType="html" label="MapPartitionsRDD [1619] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4259 { id="cluster_4259"; isCluster="true"; label="InMemoryTableScan"; 1620 [id="node_1620" labelType="html" label="MapPartitionsRDD [1620] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1621 [id="node_1621" labelType="html" label="MapPartitionsRDD [1621] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1622 [id="node_1622" labelType="html" label="MapPartitionsRDD [1622] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4254 { id="cluster_4254"; isCluster="true"; label="WholeStageCodegen (2)"; 1623 [id="node_1623" labelType="html" label="MapPartitionsRDD [1623] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4253 { id="cluster_4253"; isCluster="true"; label="Project"; 1624 [id="node_1624" labelType="html" label="MapPartitionsRDD [1624] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4236 { id="cluster_4236"; isCluster="true"; label="Union"; 1625 [id="node_1625" labelType="html" label="UnionRDD [1625] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4235 { id="cluster_4235"; isCluster="true"; label="Exchange"; 1626 [id="node_1626" labelType="html" label="MapPartitionsRDD [1626] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1600->1601; 1601->1602; 1602->1603; 1603->1604; 1604->1605; 1605->1606; 1606->1607; 1607->1608; 1608->1609; 1609->1610; 1610->1611; 1611->1612; 1612->1613; 1613->1614; 1610->1615; 1615->1616; 1616->1617; 1617->1618; 1618->1619; 1610->1620; 1620->1621; 1621->1622; 1622->1623; 1623->1624; 1614->1625; 1619->1625; 1624->1625; 1625->1626; }

1599,1600

1606

1610

1605

1600

1601

1602

1603

1604

1606

1607

1608

1609

1610

1611

1612

1613

1614

1615

1616

1617

1618

1619

1620

1621

1622

1623

1624

1625

1626

digraph G { id="graph_1139"; subgraph graph_stage_1139 { id="graph_stage_1139"; isCluster="true"; label="Stage 1139 (skipped)"; subgraph cluster_4235 { id="cluster_4235"; isCluster="true"; label="Exchange"; 1627 [id="node_1627" labelType="html" label="ShuffledRowRDD [1627] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4232 { id="cluster_4232"; isCluster="true"; label="WholeStageCodegen (3)"; 1628 [id="node_1628" labelType="html" label="MapPartitionsRDD [1628] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4264 { id="cluster_4264"; isCluster="true"; label="Exchange"; 1637 [id="node_1637" labelType="html" label="ShuffledRowRDD [1637] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4261 { id="cluster_4261"; isCluster="true"; label="WholeStageCodegen (6)"; 1638 [id="node_1638" labelType="html" label="MapPartitionsRDD [1638] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4227 { id="cluster_4227"; isCluster="true"; label="WholeStageCodegen (7)"; 1639 [id="node_1639" labelType="html" label="ZippedPartitionsRDD2 [1639] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1640 [id="node_1640" labelType="html" label="MapPartitionsRDD [1640] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4226 { id="cluster_4226"; isCluster="true"; label="SortAggregate"; 1641 [id="node_1641" labelType="html" label="MapPartitionsRDD [1641] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4225 { id="cluster_4225"; isCluster="true"; label="Exchange"; 1642 [id="node_1642" labelType="html" label="MapPartitionsRDD [1642] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1627->1628; 1637->1638; 1628->1639; 1638->1639; 1639->1640; 1640->1641; 1641->1642; }

1626,1627

1636,1637

1627

1628

1637

1638

1639

1640

1641

1642

digraph G { id="graph_1140"; subgraph graph_stage_1140 { id="graph_stage_1140"; isCluster="true"; label="Stage 1140"; subgraph cluster_3922 { id="cluster_3922"; isCluster="true"; label="Exchange"; 1481 [id="node_1481" labelType="html" label="ShuffledRowRDD [1481] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3919 { id="cluster_3919"; isCluster="true"; label="WholeStageCodegen (1)"; 1482 [id="node_1482" labelType="html" label="MapPartitionsRDD [1482] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3947 { id="cluster_3947"; isCluster="true"; label="Exchange"; 1488 [id="node_1488" labelType="html" label="ShuffledRowRDD [1488] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3944 { id="cluster_3944"; isCluster="true"; label="WholeStageCodegen (2)"; 1489 [id="node_1489" labelType="html" label="MapPartitionsRDD [1489] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3956 { id="cluster_3956"; isCluster="true"; label="Exchange"; 1492 [id="node_1492" labelType="html" label="ShuffledRowRDD [1492] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3953 { id="cluster_3953"; isCluster="true"; label="WholeStageCodegen (4)"; 1500 [id="node_1500" labelType="html" label="MapPartitionsRDD [1500] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3935 { id="cluster_3935"; isCluster="true"; label="WholeStageCodegen (5)"; 1501 [id="node_1501" labelType="html" label="ZippedPartitionsRDD2 [1501] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1502 [id="node_1502" labelType="html" label="MapPartitionsRDD [1502] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3965 { id="cluster_3965"; isCluster="true"; label="Exchange"; 1505 [id="node_1505" labelType="html" label="ShuffledRowRDD [1505] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3962 { id="cluster_3962"; isCluster="true"; label="WholeStageCodegen (7)"; 1506 [id="node_1506" labelType="html" label="MapPartitionsRDD [1506] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3931 { id="cluster_3931"; isCluster="true"; label="WholeStageCodegen (8)"; 1507 [id="node_1507" labelType="html" label="ZippedPartitionsRDD2 [1507] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1508 [id="node_1508" labelType="html" label="MapPartitionsRDD [1508] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3930 { id="cluster_3930"; isCluster="true"; label="InMemoryTableScan"; 1509 [id="node_1509" labelType="html" label="MapPartitionsRDD [1509] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1510 [id="node_1510" labelType="html" label="*(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455]\n+- *(8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner\n :- *(5) Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0\n : +- *(5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449])\n : +- *(5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448])\n : +- *(5) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]\n : +- *(5) SortMergeJoin [worklistShardItemId#446L, shardId#445]... [1510] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3928 { id="cluster_3928"; isCluster="true"; label="Exchange"; 1529 [id="node_1529" labelType="html" label="ShuffledRowRDD [1529] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3925 { id="cluster_3925"; isCluster="true"; label="WholeStageCodegen (7)"; 1530 [id="node_1530" labelType="html" label="MapPartitionsRDD [1530] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3911 { id="cluster_3911"; isCluster="true"; label="WholeStageCodegen (8)"; 1531 [id="node_1531" labelType="html" label="ZippedPartitionsRDD2 [1531] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1532 [id="node_1532" labelType="html" label="MapPartitionsRDD [1532] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3998 { id="cluster_3998"; isCluster="true"; label="InMemoryTableScan"; 1533 [id="node_1533" labelType="html" label="MapPartitionsRDD [1533] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1534 [id="node_1534" labelType="html" label="MapPartitionsRDD [1534] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1535 [id="node_1535" labelType="html" label="MapPartitionsRDD [1535] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3995 { id="cluster_3995"; isCluster="true"; label="WholeStageCodegen (9)"; 1536 [id="node_1536" labelType="html" label="MapPartitionsRDD [1536] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3910 { id="cluster_3910"; isCluster="true"; label="Union"; 1537 [id="node_1537" labelType="html" label="UnionRDD [1537] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3909 { id="cluster_3909"; isCluster="true"; label="InMemoryTableScan"; 1538 [id="node_1538" labelType="html" label="MapPartitionsRDD [1538] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1539 [id="node_1539" labelType="html" label="Union\n:- *(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#24687, null AS demandStream#24688, [] AS kpis#24722, true AS isNewlyCalculated#24690]\n: +- *(8) SortMergeJoin [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)], [coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454)], LeftAnti\n: :- *(1) Sort [coalesce(shardId#445, ) ASC NUL... [1539] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4400 { id="cluster_4400"; isCluster="true"; label="InMemoryTableScan"; 1689 [id="node_1689" labelType="html" label="MapPartitionsRDD [1689] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1690 [id="node_1690" labelType="html" label="MapPartitionsRDD [1690] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1691 [id="node_1691" labelType="html" label="MapPartitionsRDD [1691] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4396 { id="cluster_4396"; isCluster="true"; label="WholeStageCodegen (4)"; 1692 [id="node_1692" labelType="html" label="MapPartitionsRDD [1692] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4395 { id="cluster_4395"; isCluster="true"; label="Exchange"; 1693 [id="node_1693" labelType="html" label="MapPartitionsRDD [1693] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1481->1482; 1488->1489; 1492->1500; 1489->1501; 1500->1501; 1501->1502; 1505->1506; 1502->1507; 1506->1507; 1507->1508; 1508->1509; 1509->1510; 1529->1530; 1482->1531; 1530->1531; 1531->1532; 1510->1533; 1533->1534; 1534->1535; 1535->1536; 1532->1537; 1536->1537; 1537->1538; 1538->1539; 1539->1689; 1689->1690; 1690->1691; 1691->1692; 1692->1693; }

1480,1481

1487,1488

1491,1492

1504,1505

1528,1529

1510

1539

1492

1500

1501

1502

1505

1506

1507

1508

1509

1510

1529

1530

1531

1532

1533

1534

1535

1536

1537

1538

1539

1689

1690

1691

1692

1693

digraph G { id="graph_1141"; subgraph graph_stage_1141 { id="graph_stage_1141"; isCluster="true"; label="Stage 1141"; subgraph cluster_3922 { id="cluster_3922"; isCluster="true"; label="Exchange"; 1481 [id="node_1481" labelType="html" label="ShuffledRowRDD [1481] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3919 { id="cluster_3919"; isCluster="true"; label="WholeStageCodegen (1)"; 1482 [id="node_1482" labelType="html" label="MapPartitionsRDD [1482] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3947 { id="cluster_3947"; isCluster="true"; label="Exchange"; 1488 [id="node_1488" labelType="html" label="ShuffledRowRDD [1488] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3944 { id="cluster_3944"; isCluster="true"; label="WholeStageCodegen (2)"; 1489 [id="node_1489" labelType="html" label="MapPartitionsRDD [1489] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3956 { id="cluster_3956"; isCluster="true"; label="Exchange"; 1492 [id="node_1492" labelType="html" label="ShuffledRowRDD [1492] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3953 { id="cluster_3953"; isCluster="true"; label="WholeStageCodegen (4)"; 1500 [id="node_1500" labelType="html" label="MapPartitionsRDD [1500] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3935 { id="cluster_3935"; isCluster="true"; label="WholeStageCodegen (5)"; 1501 [id="node_1501" labelType="html" label="ZippedPartitionsRDD2 [1501] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1502 [id="node_1502" labelType="html" label="MapPartitionsRDD [1502] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3965 { id="cluster_3965"; isCluster="true"; label="Exchange"; 1505 [id="node_1505" labelType="html" label="ShuffledRowRDD [1505] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3962 { id="cluster_3962"; isCluster="true"; label="WholeStageCodegen (7)"; 1506 [id="node_1506" labelType="html" label="MapPartitionsRDD [1506] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3931 { id="cluster_3931"; isCluster="true"; label="WholeStageCodegen (8)"; 1507 [id="node_1507" labelType="html" label="ZippedPartitionsRDD2 [1507] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1508 [id="node_1508" labelType="html" label="MapPartitionsRDD [1508] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3930 { id="cluster_3930"; isCluster="true"; label="InMemoryTableScan"; 1509 [id="node_1509" labelType="html" label="MapPartitionsRDD [1509] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1510 [id="node_1510" labelType="html" label="*(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455]\n+- *(8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner\n :- *(5) Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0\n : +- *(5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449])\n : +- *(5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448])\n : +- *(5) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]\n : +- *(5) SortMergeJoin [worklistShardItemId#446L, shardId#445]... [1510] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3928 { id="cluster_3928"; isCluster="true"; label="Exchange"; 1529 [id="node_1529" labelType="html" label="ShuffledRowRDD [1529] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3925 { id="cluster_3925"; isCluster="true"; label="WholeStageCodegen (7)"; 1530 [id="node_1530" labelType="html" label="MapPartitionsRDD [1530] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3911 { id="cluster_3911"; isCluster="true"; label="WholeStageCodegen (8)"; 1531 [id="node_1531" labelType="html" label="ZippedPartitionsRDD2 [1531] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1532 [id="node_1532" labelType="html" label="MapPartitionsRDD [1532] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3998 { id="cluster_3998"; isCluster="true"; label="InMemoryTableScan"; 1533 [id="node_1533" labelType="html" label="MapPartitionsRDD [1533] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1534 [id="node_1534" labelType="html" label="MapPartitionsRDD [1534] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1535 [id="node_1535" labelType="html" label="MapPartitionsRDD [1535] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3995 { id="cluster_3995"; isCluster="true"; label="WholeStageCodegen (9)"; 1536 [id="node_1536" labelType="html" label="MapPartitionsRDD [1536] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3910 { id="cluster_3910"; isCluster="true"; label="Union"; 1537 [id="node_1537" labelType="html" label="UnionRDD [1537] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3909 { id="cluster_3909"; isCluster="true"; label="InMemoryTableScan"; 1538 [id="node_1538" labelType="html" label="MapPartitionsRDD [1538] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1539 [id="node_1539" labelType="html" label="Union\n:- *(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#24687, null AS demandStream#24688, [] AS kpis#24722, true AS isNewlyCalculated#24690]\n: +- *(8) SortMergeJoin [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)], [coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454)], LeftAnti\n: :- *(1) Sort [coalesce(shardId#445, ) ASC NUL... [1539] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4225 { id="cluster_4225"; isCluster="true"; label="Exchange"; 1643 [id="node_1643" labelType="html" label="ShuffledRowRDD [1643] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4222 { id="cluster_4222"; isCluster="true"; label="WholeStageCodegen (8)"; 1644 [id="node_1644" labelType="html" label="MapPartitionsRDD [1644] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4221 { id="cluster_4221"; isCluster="true"; label="SortAggregate"; 1645 [id="node_1645" labelType="html" label="MapPartitionsRDD [1645] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4220 { id="cluster_4220"; isCluster="true"; label="InMemoryTableScan"; 1646 [id="node_1646" labelType="html" label="MapPartitionsRDD [1646] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1647 [id="node_1647" labelType="html" label="SortAggregate(key=[demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264], functions=[first(kpis#27292, false)], output=[shardId#445, worklistShardItemId#446L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27425])\n+- *(8) Sort [demandChannel#27263 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, qty#27283 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#27264 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, 37), ENSURE_REQUIREMENTS, [plan_id=118557]\n +- SortAggregate(key=[demandChannel#27263, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#27283)) AS qty#27283, worklistShardItemId#446L, demandStream#27264], functions=[partial_first(kpis#27292, false)], output=[demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, first#27501, valueSet#27502])\n +- *(7) Sort [demandChannel#272... [1647] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4385 { id="cluster_4385"; isCluster="true"; label="InMemoryTableScan"; 1677 [id="node_1677" labelType="html" label="MapPartitionsRDD [1677] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1678 [id="node_1678" labelType="html" label="MapPartitionsRDD [1678] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1679 [id="node_1679" labelType="html" label="MapPartitionsRDD [1679] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4381 { id="cluster_4381"; isCluster="true"; label="WholeStageCodegen (1)"; 1680 [id="node_1680" labelType="html" label="MapPartitionsRDD [1680] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4389 { id="cluster_4389"; isCluster="true"; label="InMemoryTableScan"; 1681 [id="node_1681" labelType="html" label="MapPartitionsRDD [1681] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1682 [id="node_1682" labelType="html" label="MapPartitionsRDD [1682] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1683 [id="node_1683" labelType="html" label="MapPartitionsRDD [1683] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4386 { id="cluster_4386"; isCluster="true"; label="WholeStageCodegen (2)"; 1684 [id="node_1684" labelType="html" label="MapPartitionsRDD [1684] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4380 { id="cluster_4380"; isCluster="true"; label="Union"; 1685 [id="node_1685" labelType="html" label="UnionRDD [1685] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4379 { id="cluster_4379"; isCluster="true"; label="Exchange"; 1686 [id="node_1686" labelType="html" label="MapPartitionsRDD [1686] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1481->1482; 1488->1489; 1492->1500; 1489->1501; 1500->1501; 1501->1502; 1505->1506; 1502->1507; 1506->1507; 1507->1508; 1508->1509; 1509->1510; 1529->1530; 1482->1531; 1530->1531; 1531->1532; 1510->1533; 1533->1534; 1534->1535; 1535->1536; 1532->1537; 1536->1537; 1537->1538; 1538->1539; 1643->1644; 1644->1645; 1645->1646; 1646->1647; 1539->1677; 1677->1678; 1678->1679; 1679->1680; 1647->1681; 1681->1682; 1682->1683; 1683->1684; 1680->1685; 1684->1685; 1685->1686; }

1480,1481

1487,1488

1491,1492

1504,1505

1528,1529

1642,1643

1510

1539

1647

1492

1500

1501

1502

1505

1506

1507

1508

1509

1510

1529

1530

1531

1532

1533

1534

1535

1536

1537

1538

1539

1643

1644

1645

1646

1647

1677

1678

1679

1680

1681

1682

1683

1684

1685

1686

digraph G { id="graph_1142"; subgraph graph_stage_1142 { id="graph_stage_1142"; isCluster="true"; label="Stage 1142"; subgraph cluster_4379 { id="cluster_4379"; isCluster="true"; label="Exchange"; 1687 [id="node_1687" labelType="html" label="ShuffledRowRDD [1687] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4376 { id="cluster_4376"; isCluster="true"; label="WholeStageCodegen (3)"; 1688 [id="node_1688" labelType="html" label="MapPartitionsRDD [1688] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4395 { id="cluster_4395"; isCluster="true"; label="Exchange"; 1694 [id="node_1694" labelType="html" label="ShuffledRowRDD [1694] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4391 { id="cluster_4391"; isCluster="true"; label="WholeStageCodegen (5)"; 1695 [id="node_1695" labelType="html" label="MapPartitionsRDD [1695] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4372 { id="cluster_4372"; isCluster="true"; label="WholeStageCodegen (6)"; 1696 [id="node_1696" labelType="html" label="ZippedPartitionsRDD2 [1696] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1697 [id="node_1697" labelType="html" label="MapPartitionsRDD [1697] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4371 { id="cluster_4371"; isCluster="true"; label="InMemoryTableScan"; 1698 [id="node_1698" labelType="html" label="MapPartitionsRDD [1698] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1699 [id="node_1699" labelType="html" label="*(6) Project [shardId#445, worklistShardItemId#446L, version#28096, qty#452, demandChannel#24687, demandStream#24688, kpis#24722]\n+- *(6) SortMergeJoin [shardId#445, worklistShardItemId#446L], [shardId#28193, worklistShardItemId#28194L], Inner\n :- *(3) Sort [shardId#445 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(shardId#445, worklistShardItemId#446L, 37), ENSURE_REQUIREMENTS, [plan_id=118723]\n : +- Union\n : :- *(1) Project [shardId#445, worklistShardItemId#446L, qty#452, demandChannel#24687, demandStream#24688, kpis#24722]\n : : +- *(1) Filter ((NOT isNewlyCalculated#24690 AND isnotnull(shardId#445)) AND isnotnull(worklistShardItemId#446L))\n : : +- InMemoryTableScan [demandChannel#24687, demandStream#24688, isNewlyCalculated#24690, kpis#24722, qty#452, shardId#445, worklistShardItemId#446L], [NOT isNewlyCalculated#24690, isnotnull(shardId#445), isnotnull(worklistShardItemId#446L)]\n : : +- ... [1699] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1700 [id="node_1700" labelType="html" label="MapPartitionsRDD [1700] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1701 [id="node_1701" labelType="html" label="MapPartitionsRDD [1701] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1702 [id="node_1702" labelType="html" label="MapPartitionsRDD [1702] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4370 { id="cluster_4370"; isCluster="true"; label="CollectLimit"; 1703 [id="node_1703" labelType="html" label="MapPartitionsRDD [1703] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1704 [id="node_1704" labelType="html" label="MapPartitionsRDD [1704] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1687->1688; 1694->1695; 1688->1696; 1695->1696; 1696->1697; 1697->1698; 1698->1699; 1699->1700; 1700->1701; 1701->1702; 1702->1703; 1703->1704; }

1686,1687

1693,1694

1699

1687

1688

1694

1695

1696

1697

1698

1699

1700

1701

1702

1703

1704

digraph G { id="graph_1143"; subgraph graph_stage_1143 { id="graph_stage_1143"; isCluster="true"; label="Stage 1143"; subgraph cluster_4370 { id="cluster_4370"; isCluster="true"; label="CollectLimit"; 1705 [id="node_1705" labelType="html" label="ShuffledRowRDD [1705] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1706 [id="node_1706" labelType="html" label="MapPartitionsRDD [1706] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4401 { id="cluster_4401"; isCluster="true"; label="mapPartitionsInternal"; 1707 [id="node_1707" labelType="html" label="MapPartitionsRDD [1707] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1705->1706; 1706->1707; }

1704,1705

1705

1706

1707

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Shuffle Read	Shuffle Write
1143	tenants-pool-506	stream-10000000004-1 id = 0ca74851-d945-4eb8-90f7-ea42a7110a4d runId = c871ced2-19a8-473b-bfe1-6d8b64ffe1bc batch = 3 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/04/20 07:08:49	8 ms	1/1
1142	tenants-pool-506	stream-10000000004-1 id = 0ca74851-d945-4eb8-90f7-ea42a7110a4d runId = c871ced2-19a8-473b-bfe1-6d8b64ffe1bc batch = 3 start at FileStorageAdapterImpl.java:171 +details RDD: (6) Project [shardId#445, worklistShardItemId#446L, version#28096, qty#452, demandChannel#24687, demandStream#24688, kpis#24722] +- (6) SortMergeJoin [shardId#445, worklistShardItemId#446L], [shardId#28193, worklistShardItemId#28194L], Inner :- (3) Sort [shardId#445 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST], false, 0 : +- Exchange hashpartitioning(shardId#445, worklistShardItemId#446L, 37), ENSURE_REQUIREMENTS, [plan_id=118723] : +- Union : :- (1) Project [shardId#445, worklistShardItemId#446L, qty#452, demandChannel#24687, demandStream#24688, kpis#24722] : : +- *(1) Filter ((NOT isNewlyCalculated#24690 AND isnotnull(shardId#445)) AND isnotnull(worklistShardItemId#446L)) : : +- InMemoryTableScan [demandChannel#24687, demandStream#24688, isNewlyCalculated#24690, kpis#24722, qty#452, shardId#445, worklistShardItemId#446L], [NOT isNewlyCalculated#24690, isnotnull(shardId#445), isnotnull(worklistShardItemId#446L)] : : +- ... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/04/20 07:08:47	2 s	37/37		1921.2 KiB	2.2 KiB
1141	tenants-pool-506	stream-10000000004-1 id = 0ca74851-d945-4eb8-90f7-ea42a7110a4d runId = c871ced2-19a8-473b-bfe1-6d8b64ffe1bc batch = 3 start at FileStorageAdapterImpl.java:171 +details RDD: (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455] +- (8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner :- (5) Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0 : +- (5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]) : +- (5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448]) : +- (5) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449] : +- (5) SortMergeJoin [worklistShardItemId#446L, shardId#445]...Union :- (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#24687, null AS demandStream#24688, [] AS kpis#24722, true AS isNewlyCalculated#24690] : +- (8) SortMergeJoin [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)], [coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454)], LeftAnti : :- (1) Sort [coalesce(shardId#445, ) ASC NUL...SortAggregate(key=[demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264], functions=[first(kpis#27292, false)], output=[shardId#445, worklistShardItemId#446L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27425]) +- (8) Sort [demandChannel#27263 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, qty#27283 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#27264 ASC NULLS FIRST], false, 0 +- Exchange hashpartitioning(demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, 37), ENSURE_REQUIREMENTS, [plan_id=118557] +- SortAggregate(key=[demandChannel#27263, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#27283)) AS qty#27283, worklistShardItemId#446L, demandStream#27264], functions=[partial_first(kpis#27292, false)], output=[demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, first#27501, valueSet#27502]) +- (7) Sort [demandChannel#272... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/04/20 07:08:46	0.3 s	111/111	1224.2 KiB		1689.1 KiB
1140	tenants-pool-506	stream-10000000004-1 id = 0ca74851-d945-4eb8-90f7-ea42a7110a4d runId = c871ced2-19a8-473b-bfe1-6d8b64ffe1bc batch = 3 start at FileStorageAdapterImpl.java:171 +details RDD: (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455] +- (8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner :- (5) Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0 : +- (5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]) : +- (5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448]) : +- (5) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449] : +- (5) SortMergeJoin [worklistShardItemId#446L, shardId#445]...Union :- (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#24687, null AS demandStream#24688, [] AS kpis#24722, true AS isNewlyCalculated#24690] : +- (8) SortMergeJoin [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)], [coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454)], LeftAnti : :- (1) Sort [coalesce(shardId#445, ) ASC NUL... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/04/20 07:08:46	0.3 s	74/74	1223.5 KiB		232.1 KiB

Page:

Skipped Stages (19)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
1139	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
1138	default	start at FileStorageAdapterImpl.java:171 +details RDD: MapPartitionsRDD (1) Generate explode(prodPlantResults#27230), false, [prodPlantResults#27237] +- (1) Project [prodPlantResults#27230] +- (1) Filter ((size(prodPlantResults#27230, true) > 0) AND isnotnull(prodPlantResults#27230)) +- (1) SerializeFromObject [mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement)))) null else named_struct(measuredUnit, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true)... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/111
1137	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
1136	default	start at FileStorageAdapterImpl.java:171 +details RDD: (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455] +- (8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner :- (5) Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0 : +- (5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]) : +- (5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448]) : +- (5) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449] : +- (5) SortMergeJoin [worklistShardItemId#446L, shardId#445]...Union :- (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#24687, null AS demandStream#24688, [] AS kpis#24722, true AS isNewlyCalculated#24690] : +- (8) SortMergeJoin [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)], [coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454)], LeftAnti : :- (1) Sort [coalesce(shardId#445, ) ASC NUL... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/74
1135	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
1134	default	start at FileStorageAdapterImpl.java:171 +details RDD: (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455] +- (8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner :- (5) Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0 : +- (5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]) : +- (5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448]) : +- (5) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449] : +- (5) SortMergeJoin [worklistShardItemId#446L, shardId#445]...Union :- (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#24687, null AS demandStream#24688, [] AS kpis#24722, true AS isNewlyCalculated#24690] : +- (8) SortMergeJoin [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)], [coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454)], LeftAnti : :- (1) Sort [coalesce(shardId#445, ) ASC NUL... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/111
1133	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
1132	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
1131	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
1130	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
1129	default	start at FileStorageAdapterImpl.java:171 +details RDD: (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455] +- (8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner :- (5) Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0 : +- (5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]) : +- (5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448]) : +- (5) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449] : +- (5) SortMergeJoin [worklistShardItemId#446L, shardId#445]...Union :- (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#24687, null AS demandStream#24688, [] AS kpis#24722, true AS isNewlyCalculated#24690] : +- (8) SortMergeJoin [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)], [coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454)], LeftAnti : :- (1) Sort [coalesce(shardId#445, ) ASC NUL... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/74
1128	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
1127	default	start at FileStorageAdapterImpl.java:171 +details RDD: (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455] +- (8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner :- (5) Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0 : +- (5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]) : +- (5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448]) : +- (5) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449] : +- *(5) SortMergeJoin [worklistShardItemId#446L, shardId#445]... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/74
1126	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
1125	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
1124	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
1123	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
1122	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
1121	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37

Page: