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

Status: SUCCEEDED
Submitted: 2026/04/20 07:08:01
Duration: 0.2 s
Associated SQL Query: 111
Job Group: c871ced2-19a8-473b-bfe1-6d8b64ffe1bc
Completed Stages: 2
Skipped Stages: 19

Enable zooming

digraph G { id="graph_1078"; subgraph graph_stage_1078 { id="graph_stage_1078"; isCluster="true"; label="Stage 1078 (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_1079"; subgraph graph_stage_1079 { id="graph_stage_1079"; isCluster="true"; label="Stage 1079 (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_1080"; subgraph graph_stage_1080 { id="graph_stage_1080"; isCluster="true"; label="Stage 1080 (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_1081"; subgraph graph_stage_1081 { id="graph_stage_1081"; isCluster="true"; label="Stage 1081 (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_1082"; subgraph graph_stage_1082 { id="graph_stage_1082"; isCluster="true"; label="Stage 1082 (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_1083"; subgraph graph_stage_1083 { id="graph_stage_1083"; isCluster="true"; label="Stage 1083 (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_1084"; subgraph graph_stage_1084 { id="graph_stage_1084"; isCluster="true"; label="Stage 1084 (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_1085"; subgraph graph_stage_1085 { id="graph_stage_1085"; isCluster="true"; label="Stage 1085 (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_1086"; subgraph graph_stage_1086 { id="graph_stage_1086"; isCluster="true"; label="Stage 1086 (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_1087"; subgraph graph_stage_1087 { id="graph_stage_1087"; isCluster="true"; label="Stage 1087 (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_1088"; subgraph graph_stage_1088 { id="graph_stage_1088"; isCluster="true"; label="Stage 1088 (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_1089"; subgraph graph_stage_1089 { id="graph_stage_1089"; isCluster="true"; label="Stage 1089 (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_1090"; subgraph graph_stage_1090 { id="graph_stage_1090"; isCluster="true"; label="Stage 1090 (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_1091"; subgraph graph_stage_1091 { id="graph_stage_1091"; isCluster="true"; label="Stage 1091 (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_1092"; subgraph graph_stage_1092 { id="graph_stage_1092"; isCluster="true"; label="Stage 1092 (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_1093"; subgraph graph_stage_1093 { id="graph_stage_1093"; isCluster="true"; label="Stage 1093 (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_1094"; subgraph graph_stage_1094 { id="graph_stage_1094"; isCluster="true"; label="Stage 1094 (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_1095"; subgraph graph_stage_1095 { id="graph_stage_1095"; isCluster="true"; label="Stage 1095 (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_1096"; subgraph graph_stage_1096 { id="graph_stage_1096"; isCluster="true"; label="Stage 1096 (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_1097"; subgraph graph_stage_1097 { id="graph_stage_1097"; isCluster="true"; label="Stage 1097"; 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_4337 { id="cluster_4337"; isCluster="true"; label="InMemoryTableScan"; 1660 [id="node_1660" labelType="html" label="MapPartitionsRDD [1660] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1661 [id="node_1661" labelType="html" label="MapPartitionsRDD [1661] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1662 [id="node_1662" labelType="html" label="MapPartitionsRDD [1662] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4334 { id="cluster_4334"; isCluster="true"; label="WholeStageCodegen (1)"; 1663 [id="node_1663" labelType="html" label="MapPartitionsRDD [1663] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4333 { id="cluster_4333"; isCluster="true"; label="Exchange"; 1664 [id="node_1664" labelType="html" label="MapPartitionsRDD [1664] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1643->1644; 1644->1645; 1645->1646; 1646->1647; 1647->1660; 1660->1661; 1661->1662; 1662->1663; 1663->1664; }

1642,1643

1647

1643

1644

1645

1646

1647

1660

1661

1662

1663

1664

digraph G { id="graph_1098"; subgraph graph_stage_1098 { id="graph_stage_1098"; isCluster="true"; label="Stage 1098"; subgraph cluster_4333 { id="cluster_4333"; isCluster="true"; label="Exchange"; 1665 [id="node_1665" labelType="html" label="ShuffledRowRDD [1665] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4330 { id="cluster_4330"; isCluster="true"; label="WholeStageCodegen (2)"; 1666 [id="node_1666" labelType="html" label="MapPartitionsRDD [1666] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4338 { id="cluster_4338"; isCluster="true"; label="mapPartitionsInternal"; 1667 [id="node_1667" labelType="html" label="MapPartitionsRDD [1667] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1665->1666; 1666->1667; }

1664,1665

1665

1666

1667

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
1098	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:01	86 ms	37/37
1097	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: 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:01	0.1 s	37/37	777.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1098

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:01

86 ms

37/37

1097

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: 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:01

0.1 s

37/37

777.0 B

Page:

Skipped Stages (19)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
1096	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
1095	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
1094	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
1093	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
1092	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
1091	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
1090	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
1089	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
1088	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
1087	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
1086	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
1085	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
1084	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
1083	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
1082	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
1081	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
1080	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
1079	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
1078	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: