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

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

Enable zooming

digraph G { id="graph_1099"; subgraph graph_stage_1099 { id="graph_stage_1099"; isCluster="true"; label="Stage 1099 (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_1100"; subgraph graph_stage_1100 { id="graph_stage_1100"; isCluster="true"; label="Stage 1100 (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_1101"; subgraph graph_stage_1101 { id="graph_stage_1101"; isCluster="true"; label="Stage 1101 (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_1102"; subgraph graph_stage_1102 { id="graph_stage_1102"; isCluster="true"; label="Stage 1102 (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_1103"; subgraph graph_stage_1103 { id="graph_stage_1103"; isCluster="true"; label="Stage 1103 (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_1104"; subgraph graph_stage_1104 { id="graph_stage_1104"; isCluster="true"; label="Stage 1104 (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_1105"; subgraph graph_stage_1105 { id="graph_stage_1105"; isCluster="true"; label="Stage 1105 (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_1106"; subgraph graph_stage_1106 { id="graph_stage_1106"; isCluster="true"; label="Stage 1106 (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_1107"; subgraph graph_stage_1107 { id="graph_stage_1107"; isCluster="true"; label="Stage 1107 (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_1108"; subgraph graph_stage_1108 { id="graph_stage_1108"; isCluster="true"; label="Stage 1108 (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_1109"; subgraph graph_stage_1109 { id="graph_stage_1109"; isCluster="true"; label="Stage 1109 (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_1110"; subgraph graph_stage_1110 { id="graph_stage_1110"; isCluster="true"; label="Stage 1110 (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_1111"; subgraph graph_stage_1111 { id="graph_stage_1111"; isCluster="true"; label="Stage 1111 (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_1112"; subgraph graph_stage_1112 { id="graph_stage_1112"; isCluster="true"; label="Stage 1112 (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_1113"; subgraph graph_stage_1113 { id="graph_stage_1113"; isCluster="true"; label="Stage 1113 (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_1114"; subgraph graph_stage_1114 { id="graph_stage_1114"; isCluster="true"; label="Stage 1114 (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_1115"; subgraph graph_stage_1115 { id="graph_stage_1115"; isCluster="true"; label="Stage 1115 (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_1116"; subgraph graph_stage_1116 { id="graph_stage_1116"; isCluster="true"; label="Stage 1116 (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_1117"; subgraph graph_stage_1117 { id="graph_stage_1117"; isCluster="true"; label="Stage 1117 (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_1118"; subgraph graph_stage_1118 { id="graph_stage_1118"; isCluster="true"; label="Stage 1118"; 1658 [id="node_1658" labelType="html" label="SQLExecutionRDD [1658] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 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_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_4328 { id="cluster_4328"; isCluster="true"; label="InMemoryTableScan"; 1654 [id="node_1654" labelType="html" label="MapPartitionsRDD [1654] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1655 [id="node_1655" labelType="html" label="MapPartitionsRDD [1655] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1656 [id="node_1656" labelType="html" label="MapPartitionsRDD [1656] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4327 { id="cluster_4327"; isCluster="true"; label="DeserializeToObject"; 1657 [id="node_1657" labelType="html" label="MapPartitionsRDD [1657] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4329 { id="cluster_4329"; isCluster="true"; label="mapPartitions"; 1659 [id="node_1659" labelType="html" label="MapPartitionsRDD [1659] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4349 { id="cluster_4349"; isCluster="true"; label="union"; 1668 [id="node_1668" labelType="html" label="UnionRDD [1668] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4350 { id="cluster_4350"; isCluster="true"; label="filter"; 1669 [id="node_1669" labelType="html" label="MapPartitionsRDD [1669] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4351 { id="cluster_4351"; isCluster="true"; label="distinct"; 1670 [id="node_1670" labelType="html" label="MapPartitionsRDD [1670] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1448->1447; 1643->1644; 1644->1645; 1645->1646; 1646->1647; 1647->1654; 1654->1655; 1655->1656; 1656->1657; 1657->1658; 1658->1659; 1447->1668; 1659->1668; 1668->1669; 1669->1670; }

1642,1643

1447

1647

1658

1447

1643

1644

1645

1646

1647

1654

1655

1656

1657

1659

1668

1669

1670

digraph G { id="graph_1119"; subgraph graph_stage_1119 { id="graph_stage_1119"; isCluster="true"; label="Stage 1119"; subgraph cluster_4351 { id="cluster_4351"; isCluster="true"; label="distinct"; 1671 [id="node_1671" labelType="html" label="ShuffledRDD [1671] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1672 [id="node_1672" labelType="html" label="MapPartitionsRDD [1672] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4352 { id="cluster_4352"; isCluster="true"; label="repartition"; 1673 [id="node_1673" labelType="html" label="MapPartitionsRDD [1673] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1671->1672; 1672->1673; }

1670,1671

1671

1672

1673

digraph G { id="graph_1120"; subgraph graph_stage_1120 { id="graph_stage_1120"; isCluster="true"; label="Stage 1120"; subgraph cluster_4352 { id="cluster_4352"; isCluster="true"; label="repartition"; 1674 [id="node_1674" labelType="html" label="ShuffledRDD [1674] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1675 [id="node_1675" labelType="html" label="CoalescedRDD [1675] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1676 [id="node_1676" labelType="html" label="MapPartitionsRDD [1676] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1674->1675; 1675->1676; }

1673,1674

1676

1674

1675

1676

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Shuffle Read	Shuffle Write
1120	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:46	0.7 s	37/37		2.9 MiB
1119	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:02	44 s	74/74		2.7 MiB	2.9 MiB
1118	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	1 s	74/74	1323.8 KiB		2.7 MiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1120

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

0.7 s

37/37

2.9 MiB

1119

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

44 s

74/74

2.7 MiB

2.9 MiB

1118

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

1 s

74/74

1323.8 KiB

2.7 MiB

Page:

Skipped Stages (19)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
1117	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
1116	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
1115	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
1114	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
1113	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
1112	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
1111	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
1110	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
1109	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
1108	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
1107	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
1106	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
1105	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
1104	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
1103	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
1102	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
1101	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
1100	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
1099	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: