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

Status: SUCCEEDED
Submitted: 2026/04/20 06:21:40
Duration: 1.0 min
Associated SQL Query: 72
Job Group: c871ced2-19a8-473b-bfe1-6d8b64ffe1bc
Completed Stages: 3
Skipped Stages: 19

Enable zooming

digraph G { id="graph_585"; subgraph graph_stage_585 { id="graph_stage_585"; isCluster="true"; label="Stage 585 (skipped)"; 839 [id="node_839" labelType="html" label="SQLExecutionRDD [839] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_2385 { id="cluster_2385"; isCluster="true"; label="Scan parquet "; 836 [id="node_836" labelType="html" label="FileScanRDD [836] start at FileStorageAdapterImpl.java:171}"]; 837 [id="node_837" labelType="html" label="MapPartitionsRDD [837] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2382 { id="cluster_2382"; isCluster="true"; label="WholeStageCodegen (1)"; 838 [id="node_838" labelType="html" label="MapPartitionsRDD [838] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2389 { id="cluster_2389"; isCluster="true"; label="WholeStageCodegen (1)"; 840 [id="node_840" labelType="html" label="MapPartitionsRDD [840] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2388 { id="cluster_2388"; isCluster="true"; label="Exchange"; 841 [id="node_841" labelType="html" label="MapPartitionsRDD [841] start at FileStorageAdapterImpl.java:171}"]; } } 836->837; 837->838; 838->839; 839->840; 840->841; }

digraph G { id="graph_586"; subgraph graph_stage_586 { id="graph_stage_586"; isCluster="true"; label="Stage 586 (skipped)"; subgraph cluster_2388 { id="cluster_2388"; isCluster="true"; label="Exchange"; 842 [id="node_842" labelType="html" label="ShuffledRowRDD [842] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2387 { id="cluster_2387"; isCluster="true"; label="InMemoryTableScan"; 843 [id="node_843" labelType="html" label="MapPartitionsRDD [843] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 844 [id="node_844" labelType="html" label="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=113634]\n+- *(1) Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]\n [844] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2522 { id="cluster_2522"; isCluster="true"; label="InMemoryTableScan"; 885 [id="node_885" labelType="html" label="MapPartitionsRDD [885] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 886 [id="node_886" labelType="html" label="MapPartitionsRDD [886] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 887 [id="node_887" labelType="html" label="MapPartitionsRDD [887] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2521 { id="cluster_2521"; isCluster="true"; label="Exchange"; 888 [id="node_888" labelType="html" label="MapPartitionsRDD [888] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 842->843; 843->844; 844->885; 885->886; 886->887; 887->888; }

841,842

844

digraph G { id="graph_587"; subgraph graph_stage_587 { id="graph_stage_587"; isCluster="true"; label="Stage 587 (skipped)"; 3 [id="node_3" labelType="html" label="SQLExecutionRDD [3] javaRDD at CachePortImpl.java:66}"]; subgraph cluster_1 { id="cluster_1"; isCluster="true"; label="LocalTableScan"; 0 [id="node_0" labelType="html" label="EmptyRDD [0] javaRDD at CachePortImpl.java:66}"]; 1 [id="node_1" labelType="html" label="MapPartitionsRDD [1] javaRDD at CachePortImpl.java:66}"]; } subgraph cluster_0 { id="cluster_0"; isCluster="true"; label="DeserializeToObject"; 2 [id="node_2" labelType="html" label="MapPartitionsRDD [2] javaRDD at CachePortImpl.java:66}"]; } subgraph cluster_2 { id="cluster_2"; isCluster="true"; label="mapPartitions"; 4 [id="node_4" labelType="html" label="MapPartitionsRDD [4] javaRDD at CachePortImpl.java:66}"]; } subgraph cluster_2442 { id="cluster_2442"; isCluster="true"; label="map"; 867 [id="node_867" labelType="html" label="MapPartitionsRDD [867] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2558 { id="cluster_2558"; isCluster="true"; label="WholeStageCodegen (3)"; 907 [id="node_907" labelType="html" label="MapPartitionsRDD [907] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2557 { id="cluster_2557"; isCluster="true"; label="Exchange"; 908 [id="node_908" labelType="html" label="MapPartitionsRDD [908] start at FileStorageAdapterImpl.java:171}"]; } } 0->1; 1->2; 2->3; 3->4; 4->867; 867->907; 907->908; }

digraph G { id="graph_588"; subgraph graph_stage_588 { id="graph_stage_588"; isCluster="true"; label="Stage 588 (skipped)"; 3 [id="node_3" labelType="html" label="SQLExecutionRDD [3] javaRDD at CachePortImpl.java:66}"]; subgraph cluster_1 { id="cluster_1"; isCluster="true"; label="LocalTableScan"; 0 [id="node_0" labelType="html" label="EmptyRDD [0] javaRDD at CachePortImpl.java:66}"]; 1 [id="node_1" labelType="html" label="MapPartitionsRDD [1] javaRDD at CachePortImpl.java:66}"]; } subgraph cluster_0 { id="cluster_0"; isCluster="true"; label="DeserializeToObject"; 2 [id="node_2" labelType="html" label="MapPartitionsRDD [2] javaRDD at CachePortImpl.java:66}"]; } subgraph cluster_2 { id="cluster_2"; isCluster="true"; label="mapPartitions"; 4 [id="node_4" labelType="html" label="MapPartitionsRDD [4] javaRDD at CachePortImpl.java:66}"]; } subgraph cluster_2442 { id="cluster_2442"; isCluster="true"; label="map"; 867 [id="node_867" labelType="html" label="MapPartitionsRDD [867] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2588 { id="cluster_2588"; isCluster="true"; label="WholeStageCodegen (4)"; 931 [id="node_931" labelType="html" label="MapPartitionsRDD [931] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2587 { id="cluster_2587"; isCluster="true"; label="Exchange"; 932 [id="node_932" labelType="html" label="MapPartitionsRDD [932] start at FileStorageAdapterImpl.java:171}"]; } } 0->1; 1->2; 2->3; 3->4; 4->867; 867->931; 931->932; }

digraph G { id="graph_589"; subgraph graph_stage_589 { id="graph_stage_589"; isCluster="true"; label="Stage 589 (skipped)"; subgraph cluster_2388 { id="cluster_2388"; isCluster="true"; label="Exchange"; 842 [id="node_842" labelType="html" label="ShuffledRowRDD [842] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2387 { id="cluster_2387"; isCluster="true"; label="InMemoryTableScan"; 843 [id="node_843" labelType="html" label="MapPartitionsRDD [843] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 844 [id="node_844" labelType="html" label="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=113634]\n+- *(1) Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]\n [844] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2552 { id="cluster_2552"; isCluster="true"; label="InMemoryTableScan"; 900 [id="node_900" labelType="html" label="MapPartitionsRDD [900] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 901 [id="node_901" labelType="html" label="MapPartitionsRDD [901] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 902 [id="node_902" labelType="html" label="MapPartitionsRDD [902] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2549 { id="cluster_2549"; isCluster="true"; label="WholeStageCodegen (1)"; 903 [id="node_903" labelType="html" label="MapPartitionsRDD [903] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2548 { id="cluster_2548"; isCluster="true"; label="Exchange"; 904 [id="node_904" labelType="html" label="MapPartitionsRDD [904] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 842->843; 843->844; 844->900; 900->901; 901->902; 902->903; 903->904; }

841,842

844

digraph G { id="graph_590"; subgraph graph_stage_590 { id="graph_stage_590"; isCluster="true"; label="Stage 590 (skipped)"; 3 [id="node_3" labelType="html" label="SQLExecutionRDD [3] javaRDD at CachePortImpl.java:66}"]; subgraph cluster_1 { id="cluster_1"; isCluster="true"; label="LocalTableScan"; 0 [id="node_0" labelType="html" label="EmptyRDD [0] javaRDD at CachePortImpl.java:66}"]; 1 [id="node_1" labelType="html" label="MapPartitionsRDD [1] javaRDD at CachePortImpl.java:66}"]; } subgraph cluster_0 { id="cluster_0"; isCluster="true"; label="DeserializeToObject"; 2 [id="node_2" labelType="html" label="MapPartitionsRDD [2] javaRDD at CachePortImpl.java:66}"]; } subgraph cluster_2 { id="cluster_2"; isCluster="true"; label="mapPartitions"; 4 [id="node_4" labelType="html" label="MapPartitionsRDD [4] javaRDD at CachePortImpl.java:66}"]; } subgraph cluster_2442 { id="cluster_2442"; isCluster="true"; label="map"; 867 [id="node_867" labelType="html" label="MapPartitionsRDD [867] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2567 { id="cluster_2567"; isCluster="true"; label="WholeStageCodegen (6)"; 913 [id="node_913" labelType="html" label="MapPartitionsRDD [913] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2566 { id="cluster_2566"; isCluster="true"; label="Exchange"; 914 [id="node_914" labelType="html" label="MapPartitionsRDD [914] start at FileStorageAdapterImpl.java:171}"]; } } 0->1; 1->2; 2->3; 3->4; 4->867; 867->913; 913->914; }

digraph G { id="graph_591"; subgraph graph_stage_591 { id="graph_stage_591"; isCluster="true"; label="Stage 591 (skipped)"; subgraph cluster_2388 { id="cluster_2388"; isCluster="true"; label="Exchange"; 842 [id="node_842" labelType="html" label="ShuffledRowRDD [842] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2387 { id="cluster_2387"; isCluster="true"; label="InMemoryTableScan"; 843 [id="node_843" labelType="html" label="MapPartitionsRDD [843] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 844 [id="node_844" labelType="html" label="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=113634]\n+- *(1) Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]\n [844] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2582 { id="cluster_2582"; isCluster="true"; label="InMemoryTableScan"; 924 [id="node_924" labelType="html" label="MapPartitionsRDD [924] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 925 [id="node_925" labelType="html" label="MapPartitionsRDD [925] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 926 [id="node_926" labelType="html" label="MapPartitionsRDD [926] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2579 { id="cluster_2579"; isCluster="true"; label="WholeStageCodegen (2)"; 927 [id="node_927" labelType="html" label="MapPartitionsRDD [927] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2578 { id="cluster_2578"; isCluster="true"; label="Exchange"; 928 [id="node_928" labelType="html" label="MapPartitionsRDD [928] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 842->843; 843->844; 844->924; 924->925; 925->926; 926->927; 927->928; }

841,842

844

digraph G { id="graph_592"; subgraph graph_stage_592 { id="graph_stage_592"; isCluster="true"; label="Stage 592 (skipped)"; subgraph cluster_2548 { id="cluster_2548"; isCluster="true"; label="Exchange"; 905 [id="node_905" labelType="html" label="ShuffledRowRDD [905] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2545 { id="cluster_2545"; isCluster="true"; label="WholeStageCodegen (2)"; 906 [id="node_906" labelType="html" label="MapPartitionsRDD [906] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2557 { id="cluster_2557"; isCluster="true"; label="Exchange"; 909 [id="node_909" labelType="html" label="ShuffledRowRDD [909] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2554 { id="cluster_2554"; isCluster="true"; label="WholeStageCodegen (4)"; 910 [id="node_910" labelType="html" label="MapPartitionsRDD [910] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2538 { id="cluster_2538"; isCluster="true"; label="WholeStageCodegen (5)"; 911 [id="node_911" labelType="html" label="ZippedPartitionsRDD2 [911] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 912 [id="node_912" labelType="html" label="MapPartitionsRDD [912] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2566 { id="cluster_2566"; isCluster="true"; label="Exchange"; 915 [id="node_915" labelType="html" label="ShuffledRowRDD [915] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2563 { id="cluster_2563"; isCluster="true"; label="WholeStageCodegen (7)"; 916 [id="node_916" labelType="html" label="MapPartitionsRDD [916] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2534 { id="cluster_2534"; isCluster="true"; label="WholeStageCodegen (8)"; 917 [id="node_917" labelType="html" label="ZippedPartitionsRDD2 [917] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 918 [id="node_918" labelType="html" label="MapPartitionsRDD [918] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2533 { id="cluster_2533"; isCluster="true"; label="InMemoryTableScan"; 919 [id="node_919" labelType="html" label="MapPartitionsRDD [919] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 920 [id="node_920" labelType="html" label="*(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#13010 AS qty#13012, demandChannel#13005, demandStream#13006, cachedKpis#13011 AS kpis#13013]\n+- *(8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#13009L, cachedShardId#13008], 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]... [920] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 921 [id="node_921" labelType="html" label="MapPartitionsRDD [921] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 922 [id="node_922" labelType="html" label="MapPartitionsRDD [922] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 923 [id="node_923" labelType="html" label="MapPartitionsRDD [923] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2578 { id="cluster_2578"; isCluster="true"; label="Exchange"; 929 [id="node_929" labelType="html" label="ShuffledRowRDD [929] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2575 { id="cluster_2575"; isCluster="true"; label="WholeStageCodegen (3)"; 930 [id="node_930" labelType="html" label="MapPartitionsRDD [930] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2587 { id="cluster_2587"; isCluster="true"; label="Exchange"; 933 [id="node_933" labelType="html" label="ShuffledRowRDD [933] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2584 { id="cluster_2584"; isCluster="true"; label="WholeStageCodegen (5)"; 934 [id="node_934" labelType="html" label="MapPartitionsRDD [934] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2571 { id="cluster_2571"; isCluster="true"; label="WholeStageCodegen (6)"; 935 [id="node_935" labelType="html" label="ZippedPartitionsRDD2 [935] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 936 [id="node_936" labelType="html" label="MapPartitionsRDD [936] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2532 { id="cluster_2532"; isCluster="true"; label="Union"; 937 [id="node_937" labelType="html" label="UnionRDD [937] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2531 { id="cluster_2531"; isCluster="true"; label="Exchange"; 938 [id="node_938" labelType="html" label="MapPartitionsRDD [938] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 905->906; 909->910; 906->911; 910->911; 911->912; 915->916; 912->917; 916->917; 917->918; 918->919; 919->920; 920->921; 921->922; 922->923; 929->930; 933->934; 930->935; 934->935; 935->936; 923->937; 936->937; 937->938; }

904,905

908,909

914,915

928,929

932,933

920

digraph G { id="graph_593"; subgraph graph_stage_593 { id="graph_stage_593"; isCluster="true"; label="Stage 593 (skipped)"; subgraph cluster_2521 { id="cluster_2521"; isCluster="true"; label="Exchange"; 889 [id="node_889" labelType="html" label="ShuffledRowRDD [889] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2518 { id="cluster_2518"; isCluster="true"; label="WholeStageCodegen (1)"; 890 [id="node_890" labelType="html" label="MapPartitionsRDD [890] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2548 { id="cluster_2548"; isCluster="true"; label="Exchange"; 905 [id="node_905" labelType="html" label="ShuffledRowRDD [905] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2545 { id="cluster_2545"; isCluster="true"; label="WholeStageCodegen (2)"; 906 [id="node_906" labelType="html" label="MapPartitionsRDD [906] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2557 { id="cluster_2557"; isCluster="true"; label="Exchange"; 909 [id="node_909" labelType="html" label="ShuffledRowRDD [909] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2554 { id="cluster_2554"; isCluster="true"; label="WholeStageCodegen (4)"; 910 [id="node_910" labelType="html" label="MapPartitionsRDD [910] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2538 { id="cluster_2538"; isCluster="true"; label="WholeStageCodegen (5)"; 911 [id="node_911" labelType="html" label="ZippedPartitionsRDD2 [911] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 912 [id="node_912" labelType="html" label="MapPartitionsRDD [912] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2566 { id="cluster_2566"; isCluster="true"; label="Exchange"; 915 [id="node_915" labelType="html" label="ShuffledRowRDD [915] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2563 { id="cluster_2563"; isCluster="true"; label="WholeStageCodegen (7)"; 916 [id="node_916" labelType="html" label="MapPartitionsRDD [916] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2534 { id="cluster_2534"; isCluster="true"; label="WholeStageCodegen (8)"; 917 [id="node_917" labelType="html" label="ZippedPartitionsRDD2 [917] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 918 [id="node_918" labelType="html" label="MapPartitionsRDD [918] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2533 { id="cluster_2533"; isCluster="true"; label="InMemoryTableScan"; 919 [id="node_919" labelType="html" label="MapPartitionsRDD [919] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 920 [id="node_920" labelType="html" label="*(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#13010 AS qty#13012, demandChannel#13005, demandStream#13006, cachedKpis#13011 AS kpis#13013]\n+- *(8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#13009L, cachedShardId#13008], 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]... [920] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2531 { id="cluster_2531"; isCluster="true"; label="Exchange"; 939 [id="node_939" labelType="html" label="ShuffledRowRDD [939] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2524 { id="cluster_2524"; isCluster="true"; label="WholeStageCodegen (7)"; 940 [id="node_940" labelType="html" label="MapPartitionsRDD [940] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2512 { id="cluster_2512"; isCluster="true"; label="WholeStageCodegen (8)"; 941 [id="node_941" labelType="html" label="ZippedPartitionsRDD2 [941] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 942 [id="node_942" labelType="html" label="MapPartitionsRDD [942] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2595 { id="cluster_2595"; isCluster="true"; label="InMemoryTableScan"; 943 [id="node_943" labelType="html" label="MapPartitionsRDD [943] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 944 [id="node_944" labelType="html" label="MapPartitionsRDD [944] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 945 [id="node_945" labelType="html" label="MapPartitionsRDD [945] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2592 { id="cluster_2592"; isCluster="true"; label="WholeStageCodegen (9)"; 946 [id="node_946" labelType="html" label="MapPartitionsRDD [946] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2511 { id="cluster_2511"; isCluster="true"; label="Union"; 947 [id="node_947" labelType="html" label="UnionRDD [947] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2510 { id="cluster_2510"; isCluster="true"; label="InMemoryTableScan"; 948 [id="node_948" labelType="html" label="MapPartitionsRDD [948] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 949 [id="node_949" labelType="html" label="Union\n:- *(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#13245, null AS demandStream#13246, [] AS kpis#13280, true AS isNewlyCalculated#13248]\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#13237, ), isnull(shardId#13237), coalesce(worklistShardItemId#13238L, 0), isnull(worklistShardItemId#13238L), coalesce(version#13239, 0), isnull(version#13239), coalesce(product#13240, ), isnull(product#13240), coalesce(plant#13241, ), isnull(plant#13241), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#13012, 0.0))), isnull(qty#13012)], LeftAnti\n: :- *(1) Sort [coalesce(shardId#445, ) ASC NUL... [949] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2938 { id="cluster_2938"; isCluster="true"; label="InMemoryTableScan"; 1060 [id="node_1060" labelType="html" label="MapPartitionsRDD [1060] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1061 [id="node_1061" labelType="html" label="MapPartitionsRDD [1061] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1062 [id="node_1062" labelType="html" label="MapPartitionsRDD [1062] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2933 { id="cluster_2933"; isCluster="true"; label="WholeStageCodegen (4)"; 1063 [id="node_1063" labelType="html" label="MapPartitionsRDD [1063] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2932 { id="cluster_2932"; isCluster="true"; label="Exchange"; 1064 [id="node_1064" labelType="html" label="MapPartitionsRDD [1064] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 889->890; 905->906; 909->910; 906->911; 910->911; 911->912; 915->916; 912->917; 916->917; 917->918; 918->919; 919->920; 939->940; 890->941; 940->941; 941->942; 920->943; 943->944; 944->945; 945->946; 942->947; 946->947; 947->948; 948->949; 949->1060; 1060->1061; 1061->1062; 1062->1063; 1063->1064; }

888,889

904,905

908,909

914,915

938,939

920

949

digraph G { id="graph_594"; subgraph graph_stage_594 { id="graph_stage_594"; isCluster="true"; label="Stage 594 (skipped)"; subgraph cluster_2521 { id="cluster_2521"; isCluster="true"; label="Exchange"; 889 [id="node_889" labelType="html" label="ShuffledRowRDD [889] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2518 { id="cluster_2518"; isCluster="true"; label="WholeStageCodegen (1)"; 890 [id="node_890" labelType="html" label="MapPartitionsRDD [890] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2548 { id="cluster_2548"; isCluster="true"; label="Exchange"; 905 [id="node_905" labelType="html" label="ShuffledRowRDD [905] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2545 { id="cluster_2545"; isCluster="true"; label="WholeStageCodegen (2)"; 906 [id="node_906" labelType="html" label="MapPartitionsRDD [906] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2557 { id="cluster_2557"; isCluster="true"; label="Exchange"; 909 [id="node_909" labelType="html" label="ShuffledRowRDD [909] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2554 { id="cluster_2554"; isCluster="true"; label="WholeStageCodegen (4)"; 910 [id="node_910" labelType="html" label="MapPartitionsRDD [910] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2538 { id="cluster_2538"; isCluster="true"; label="WholeStageCodegen (5)"; 911 [id="node_911" labelType="html" label="ZippedPartitionsRDD2 [911] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 912 [id="node_912" labelType="html" label="MapPartitionsRDD [912] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2566 { id="cluster_2566"; isCluster="true"; label="Exchange"; 915 [id="node_915" labelType="html" label="ShuffledRowRDD [915] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2563 { id="cluster_2563"; isCluster="true"; label="WholeStageCodegen (7)"; 916 [id="node_916" labelType="html" label="MapPartitionsRDD [916] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2534 { id="cluster_2534"; isCluster="true"; label="WholeStageCodegen (8)"; 917 [id="node_917" labelType="html" label="ZippedPartitionsRDD2 [917] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 918 [id="node_918" labelType="html" label="MapPartitionsRDD [918] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2533 { id="cluster_2533"; isCluster="true"; label="InMemoryTableScan"; 919 [id="node_919" labelType="html" label="MapPartitionsRDD [919] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 920 [id="node_920" labelType="html" label="*(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#13010 AS qty#13012, demandChannel#13005, demandStream#13006, cachedKpis#13011 AS kpis#13013]\n+- *(8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#13009L, cachedShardId#13008], 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]... [920] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2531 { id="cluster_2531"; isCluster="true"; label="Exchange"; 939 [id="node_939" labelType="html" label="ShuffledRowRDD [939] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2524 { id="cluster_2524"; isCluster="true"; label="WholeStageCodegen (7)"; 940 [id="node_940" labelType="html" label="MapPartitionsRDD [940] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2512 { id="cluster_2512"; isCluster="true"; label="WholeStageCodegen (8)"; 941 [id="node_941" labelType="html" label="ZippedPartitionsRDD2 [941] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 942 [id="node_942" labelType="html" label="MapPartitionsRDD [942] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2595 { id="cluster_2595"; isCluster="true"; label="InMemoryTableScan"; 943 [id="node_943" labelType="html" label="MapPartitionsRDD [943] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 944 [id="node_944" labelType="html" label="MapPartitionsRDD [944] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 945 [id="node_945" labelType="html" label="MapPartitionsRDD [945] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2592 { id="cluster_2592"; isCluster="true"; label="WholeStageCodegen (9)"; 946 [id="node_946" labelType="html" label="MapPartitionsRDD [946] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2511 { id="cluster_2511"; isCluster="true"; label="Union"; 947 [id="node_947" labelType="html" label="UnionRDD [947] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2510 { id="cluster_2510"; isCluster="true"; label="InMemoryTableScan"; 948 [id="node_948" labelType="html" label="MapPartitionsRDD [948] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 949 [id="node_949" labelType="html" label="Union\n:- *(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#13245, null AS demandStream#13246, [] AS kpis#13280, true AS isNewlyCalculated#13248]\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#13237, ), isnull(shardId#13237), coalesce(worklistShardItemId#13238L, 0), isnull(worklistShardItemId#13238L), coalesce(version#13239, 0), isnull(version#13239), coalesce(product#13240, ), isnull(product#13240), coalesce(plant#13241, ), isnull(plant#13241), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#13012, 0.0))), isnull(qty#13012)], LeftAnti\n: :- *(1) Sort [coalesce(shardId#445, ) ASC NUL... [949] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2775 { id="cluster_2775"; isCluster="true"; label="InMemoryTableScan"; 995 [id="node_995" labelType="html" label="MapPartitionsRDD [995] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 996 [id="node_996" labelType="html" label="MapPartitionsRDD [996] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 997 [id="node_997" labelType="html" label="MapPartitionsRDD [997] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2771 { id="cluster_2771"; isCluster="true"; label="WholeStageCodegen (10)"; 998 [id="node_998" labelType="html" label="MapPartitionsRDD [998] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2770 { id="cluster_2770"; isCluster="true"; label="ObjectHashAggregate"; 999 [id="node_999" labelType="html" label="MapPartitionsRDD [999] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2769 { id="cluster_2769"; isCluster="true"; label="Exchange"; 1000 [id="node_1000" labelType="html" label="MapPartitionsRDD [1000] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 889->890; 905->906; 909->910; 906->911; 910->911; 911->912; 915->916; 912->917; 916->917; 917->918; 918->919; 919->920; 939->940; 890->941; 940->941; 941->942; 920->943; 943->944; 944->945; 945->946; 942->947; 946->947; 947->948; 948->949; 949->995; 995->996; 996->997; 997->998; 998->999; 999->1000; }

888,889

904,905

908,909

914,915

938,939

920

949

digraph G { id="graph_595"; subgraph graph_stage_595 { id="graph_stage_595"; isCluster="true"; label="Stage 595 (skipped)"; subgraph cluster_2388 { id="cluster_2388"; isCluster="true"; label="Exchange"; 842 [id="node_842" labelType="html" label="ShuffledRowRDD [842] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2387 { id="cluster_2387"; isCluster="true"; label="InMemoryTableScan"; 843 [id="node_843" labelType="html" label="MapPartitionsRDD [843] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 844 [id="node_844" labelType="html" label="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=113634]\n+- *(1) Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]\n [844] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2761 { id="cluster_2761"; isCluster="true"; label="InMemoryTableScan"; 978 [id="node_978" labelType="html" label="MapPartitionsRDD [978] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 979 [id="node_979" labelType="html" label="MapPartitionsRDD [979] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 980 [id="node_980" labelType="html" label="MapPartitionsRDD [980] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2748 { id="cluster_2748"; isCluster="true"; label="WholeStageCodegen (6)"; 981 [id="node_981" labelType="html" label="MapPartitionsRDD [981] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2747 { id="cluster_2747"; isCluster="true"; label="Exchange"; 982 [id="node_982" labelType="html" label="MapPartitionsRDD [982] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 842->843; 843->844; 844->978; 978->979; 979->980; 980->981; 981->982; }

841,842

844

digraph G { id="graph_596"; subgraph graph_stage_596 { id="graph_stage_596"; isCluster="true"; label="Stage 596 (skipped)"; subgraph cluster_2388 { id="cluster_2388"; isCluster="true"; label="Exchange"; 842 [id="node_842" labelType="html" label="ShuffledRowRDD [842] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2387 { id="cluster_2387"; isCluster="true"; label="InMemoryTableScan"; 843 [id="node_843" labelType="html" label="MapPartitionsRDD [843] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 844 [id="node_844" labelType="html" label="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=113634]\n+- *(1) Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]\n [844] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2742 { id="cluster_2742"; isCluster="true"; label="InMemoryTableScan"; 971 [id="node_971" labelType="html" label="MapPartitionsRDD [971] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 972 [id="node_972" labelType="html" label="MapPartitionsRDD [972] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 973 [id="node_973" labelType="html" label="MapPartitionsRDD [973] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2732 { id="cluster_2732"; isCluster="true"; label="WholeStageCodegen (3)"; 974 [id="node_974" labelType="html" label="MapPartitionsRDD [974] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2731 { id="cluster_2731"; isCluster="true"; label="Exchange"; 975 [id="node_975" labelType="html" label="MapPartitionsRDD [975] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 842->843; 843->844; 844->971; 971->972; 972->973; 973->974; 974->975; }

841,842

844

digraph G { id="graph_597"; subgraph graph_stage_597 { id="graph_stage_597"; isCluster="true"; label="Stage 597 (skipped)"; subgraph cluster_2731 { id="cluster_2731"; isCluster="true"; label="Exchange"; 976 [id="node_976" labelType="html" label="ShuffledRowRDD [976] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2728 { id="cluster_2728"; isCluster="true"; label="WholeStageCodegen (4)"; 977 [id="node_977" labelType="html" label="MapPartitionsRDD [977] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2747 { id="cluster_2747"; isCluster="true"; label="Exchange"; 983 [id="node_983" labelType="html" label="ShuffledRowRDD [983] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2744 { id="cluster_2744"; isCluster="true"; label="WholeStageCodegen (7)"; 984 [id="node_984" labelType="html" label="MapPartitionsRDD [984] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2724 { id="cluster_2724"; isCluster="true"; label="WholeStageCodegen (8)"; 985 [id="node_985" labelType="html" label="ZippedPartitionsRDD2 [985] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 986 [id="node_986" labelType="html" label="MapPartitionsRDD [986] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2723 { id="cluster_2723"; isCluster="true"; label="ObjectHashAggregate"; 987 [id="node_987" labelType="html" label="MapPartitionsRDD [987] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2722 { id="cluster_2722"; isCluster="true"; label="Exchange"; 988 [id="node_988" labelType="html" label="MapPartitionsRDD [988] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 976->977; 983->984; 977->985; 984->985; 985->986; 986->987; 987->988; }

975,976

982,983

digraph G { id="graph_598"; subgraph graph_stage_598 { id="graph_stage_598"; isCluster="true"; label="Stage 598 (skipped)"; subgraph cluster_2722 { id="cluster_2722"; isCluster="true"; label="Exchange"; 989 [id="node_989" labelType="html" label="ShuffledRowRDD [989] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2721 { id="cluster_2721"; isCluster="true"; label="ObjectHashAggregate"; 990 [id="node_990" labelType="html" label="MapPartitionsRDD [990] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2720 { id="cluster_2720"; isCluster="true"; label="Project"; 991 [id="node_991" labelType="html" label="MapPartitionsRDD [991] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2719 { id="cluster_2719"; isCluster="true"; label="Exchange"; 992 [id="node_992" labelType="html" label="MapPartitionsRDD [992] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 989->990; 990->991; 991->992; }

988,989

digraph G { id="graph_599"; subgraph graph_stage_599 { id="graph_stage_599"; isCluster="true"; label="Stage 599 (skipped)"; subgraph cluster_2521 { id="cluster_2521"; isCluster="true"; label="Exchange"; 889 [id="node_889" labelType="html" label="ShuffledRowRDD [889] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2518 { id="cluster_2518"; isCluster="true"; label="WholeStageCodegen (1)"; 890 [id="node_890" labelType="html" label="MapPartitionsRDD [890] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2548 { id="cluster_2548"; isCluster="true"; label="Exchange"; 905 [id="node_905" labelType="html" label="ShuffledRowRDD [905] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2545 { id="cluster_2545"; isCluster="true"; label="WholeStageCodegen (2)"; 906 [id="node_906" labelType="html" label="MapPartitionsRDD [906] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2557 { id="cluster_2557"; isCluster="true"; label="Exchange"; 909 [id="node_909" labelType="html" label="ShuffledRowRDD [909] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2554 { id="cluster_2554"; isCluster="true"; label="WholeStageCodegen (4)"; 910 [id="node_910" labelType="html" label="MapPartitionsRDD [910] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2538 { id="cluster_2538"; isCluster="true"; label="WholeStageCodegen (5)"; 911 [id="node_911" labelType="html" label="ZippedPartitionsRDD2 [911] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 912 [id="node_912" labelType="html" label="MapPartitionsRDD [912] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2566 { id="cluster_2566"; isCluster="true"; label="Exchange"; 915 [id="node_915" labelType="html" label="ShuffledRowRDD [915] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2563 { id="cluster_2563"; isCluster="true"; label="WholeStageCodegen (7)"; 916 [id="node_916" labelType="html" label="MapPartitionsRDD [916] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2534 { id="cluster_2534"; isCluster="true"; label="WholeStageCodegen (8)"; 917 [id="node_917" labelType="html" label="ZippedPartitionsRDD2 [917] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 918 [id="node_918" labelType="html" label="MapPartitionsRDD [918] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2533 { id="cluster_2533"; isCluster="true"; label="InMemoryTableScan"; 919 [id="node_919" labelType="html" label="MapPartitionsRDD [919] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 920 [id="node_920" labelType="html" label="*(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#13010 AS qty#13012, demandChannel#13005, demandStream#13006, cachedKpis#13011 AS kpis#13013]\n+- *(8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#13009L, cachedShardId#13008], 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]... [920] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2531 { id="cluster_2531"; isCluster="true"; label="Exchange"; 939 [id="node_939" labelType="html" label="ShuffledRowRDD [939] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2524 { id="cluster_2524"; isCluster="true"; label="WholeStageCodegen (7)"; 940 [id="node_940" labelType="html" label="MapPartitionsRDD [940] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2512 { id="cluster_2512"; isCluster="true"; label="WholeStageCodegen (8)"; 941 [id="node_941" labelType="html" label="ZippedPartitionsRDD2 [941] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 942 [id="node_942" labelType="html" label="MapPartitionsRDD [942] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2595 { id="cluster_2595"; isCluster="true"; label="InMemoryTableScan"; 943 [id="node_943" labelType="html" label="MapPartitionsRDD [943] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 944 [id="node_944" labelType="html" label="MapPartitionsRDD [944] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 945 [id="node_945" labelType="html" label="MapPartitionsRDD [945] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2592 { id="cluster_2592"; isCluster="true"; label="WholeStageCodegen (9)"; 946 [id="node_946" labelType="html" label="MapPartitionsRDD [946] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2511 { id="cluster_2511"; isCluster="true"; label="Union"; 947 [id="node_947" labelType="html" label="UnionRDD [947] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2510 { id="cluster_2510"; isCluster="true"; label="InMemoryTableScan"; 948 [id="node_948" labelType="html" label="MapPartitionsRDD [948] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 949 [id="node_949" labelType="html" label="Union\n:- *(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#13245, null AS demandStream#13246, [] AS kpis#13280, true AS isNewlyCalculated#13248]\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#13237, ), isnull(shardId#13237), coalesce(worklistShardItemId#13238L, 0), isnull(worklistShardItemId#13238L), coalesce(version#13239, 0), isnull(version#13239), coalesce(product#13240, ), isnull(product#13240), coalesce(plant#13241, ), isnull(plant#13241), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#13012, 0.0))), isnull(qty#13012)], LeftAnti\n: :- *(1) Sort [coalesce(shardId#445, ) ASC NUL... [949] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2769 { id="cluster_2769"; isCluster="true"; label="Exchange"; 1001 [id="node_1001" labelType="html" label="ShuffledRowRDD [1001] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2768 { id="cluster_2768"; isCluster="true"; label="ObjectHashAggregate"; 1002 [id="node_1002" labelType="html" label="MapPartitionsRDD [1002] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2780 { id="cluster_2780"; isCluster="true"; label="InMemoryTableScan"; 1003 [id="node_1003" labelType="html" label="MapPartitionsRDD [1003] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1004 [id="node_1004" labelType="html" label="MapPartitionsRDD [1004] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1005 [id="node_1005" labelType="html" label="MapPartitionsRDD [1005] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2776 { id="cluster_2776"; isCluster="true"; label="WholeStageCodegen (11)"; 1006 [id="node_1006" labelType="html" label="MapPartitionsRDD [1006] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2767 { id="cluster_2767"; isCluster="true"; label="Union"; 1007 [id="node_1007" labelType="html" label="UnionRDD [1007] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2766 { id="cluster_2766"; isCluster="true"; label="Exchange"; 1008 [id="node_1008" labelType="html" label="MapPartitionsRDD [1008] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 889->890; 905->906; 909->910; 906->911; 910->911; 911->912; 915->916; 912->917; 916->917; 917->918; 918->919; 919->920; 939->940; 890->941; 940->941; 941->942; 920->943; 943->944; 944->945; 945->946; 942->947; 946->947; 947->948; 948->949; 1001->1002; 949->1003; 1003->1004; 1004->1005; 1005->1006; 1002->1007; 1006->1007; 1007->1008; }

888,889

904,905

908,909

914,915

938,939

1000,1001

920

949

digraph G { id="graph_600"; subgraph graph_stage_600 { id="graph_stage_600"; isCluster="true"; label="Stage 600 (skipped)"; subgraph cluster_2719 { id="cluster_2719"; isCluster="true"; label="Exchange"; 993 [id="node_993" labelType="html" label="ShuffledRowRDD [993] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2716 { id="cluster_2716"; isCluster="true"; label="WholeStageCodegen (9)"; 994 [id="node_994" labelType="html" label="MapPartitionsRDD [994] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2766 { id="cluster_2766"; isCluster="true"; label="Exchange"; 1009 [id="node_1009" labelType="html" label="ShuffledRowRDD [1009] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2763 { id="cluster_2763"; isCluster="true"; label="WholeStageCodegen (12)"; 1010 [id="node_1010" labelType="html" label="MapPartitionsRDD [1010] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2712 { id="cluster_2712"; isCluster="true"; label="WholeStageCodegen (13)"; 1011 [id="node_1011" labelType="html" label="ZippedPartitionsRDD2 [1011] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1012 [id="node_1012" labelType="html" label="MapPartitionsRDD [1012] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2711 { id="cluster_2711"; isCluster="true"; label="ObjectHashAggregate"; 1013 [id="node_1013" labelType="html" label="MapPartitionsRDD [1013] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2710 { id="cluster_2710"; isCluster="true"; label="Exchange"; 1014 [id="node_1014" labelType="html" label="MapPartitionsRDD [1014] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 993->994; 1009->1010; 994->1011; 1010->1011; 1011->1012; 1012->1013; 1013->1014; }

992,993

1008,1009

digraph G { id="graph_601"; subgraph graph_stage_601 { id="graph_stage_601"; isCluster="true"; label="Stage 601 (skipped)"; 1020 [id="node_1020" labelType="html" label="SQLExecutionRDD [1020] [Unordered] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_2710 { id="cluster_2710"; isCluster="true"; label="Exchange"; 1015 [id="node_1015" labelType="html" label="ShuffledRowRDD [1015] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2709 { id="cluster_2709"; isCluster="true"; label="ObjectHashAggregate"; 1016 [id="node_1016" labelType="html" label="MapPartitionsRDD [1016] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2599 { id="cluster_2599"; isCluster="true"; label="WholeStageCodegen (16)"; 1017 [id="node_1017" labelType="html" label="MapPartitionsRDD [1017] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2494 { id="cluster_2494"; isCluster="true"; label="DeserializeToObject"; 1018 [id="node_1018" labelType="html" label="MapPartitionsRDD [1018] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2486 { id="cluster_2486"; isCluster="true"; label="MapPartitions"; 1019 [id="node_1019" labelType="html" label="MapPartitionsRDD [1019] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2781 { id="cluster_2781"; isCluster="true"; label="mapPartitions"; 1021 [id="node_1021" labelType="html" label="MapPartitionsRDD [1021] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2909 { id="cluster_2909"; isCluster="true"; label="Scan"; 1038 [id="node_1038" labelType="html" label="MapPartitionsRDD [1038] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2903 { id="cluster_2903"; isCluster="true"; label="WholeStageCodegen (1)"; 1039 [id="node_1039" labelType="html" label="MapPartitionsRDD [1039] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2902 { id="cluster_2902"; isCluster="true"; label="InMemoryTableScan"; 1040 [id="node_1040" labelType="html" label="MapPartitionsRDD [1040] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1041 [id="node_1041" labelType="html" label="*(1) Generate explode(prodPlantResults#15956), false, [prodPlantResults#15963]\n+- *(1) Project [prodPlantResults#15956]\n +- *(1) Filter ((size(prodPlantResults#15956, true) > 0) AND isnotnull(prodPlantResults#15956))\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)... [1041] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1042 [id="node_1042" labelType="html" label="MapPartitionsRDD [1042] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1043 [id="node_1043" labelType="html" label="MapPartitionsRDD [1043] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1044 [id="node_1044" labelType="html" label="MapPartitionsRDD [1044] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2901 { id="cluster_2901"; isCluster="true"; label="Project"; 1045 [id="node_1045" labelType="html" label="MapPartitionsRDD [1045] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2916 { id="cluster_2916"; isCluster="true"; label="InMemoryTableScan"; 1046 [id="node_1046" labelType="html" label="MapPartitionsRDD [1046] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1047 [id="node_1047" labelType="html" label="MapPartitionsRDD [1047] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1048 [id="node_1048" labelType="html" label="MapPartitionsRDD [1048] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2911 { id="cluster_2911"; isCluster="true"; label="WholeStageCodegen (1)"; 1049 [id="node_1049" labelType="html" label="MapPartitionsRDD [1049] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2910 { id="cluster_2910"; isCluster="true"; label="Project"; 1050 [id="node_1050" labelType="html" label="MapPartitionsRDD [1050] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2923 { id="cluster_2923"; isCluster="true"; label="InMemoryTableScan"; 1051 [id="node_1051" labelType="html" label="MapPartitionsRDD [1051] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1052 [id="node_1052" labelType="html" label="MapPartitionsRDD [1052] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1053 [id="node_1053" labelType="html" label="MapPartitionsRDD [1053] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2918 { id="cluster_2918"; isCluster="true"; label="WholeStageCodegen (2)"; 1054 [id="node_1054" labelType="html" label="MapPartitionsRDD [1054] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2917 { id="cluster_2917"; isCluster="true"; label="Project"; 1055 [id="node_1055" labelType="html" label="MapPartitionsRDD [1055] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2900 { id="cluster_2900"; isCluster="true"; label="Union"; 1056 [id="node_1056" labelType="html" label="UnionRDD [1056] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2899 { id="cluster_2899"; isCluster="true"; label="Exchange"; 1057 [id="node_1057" labelType="html" label="MapPartitionsRDD [1057] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1015->1016; 1016->1017; 1017->1018; 1018->1019; 1019->1020; 1020->1021; 1021->1038; 1038->1039; 1039->1040; 1040->1041; 1041->1042; 1042->1043; 1043->1044; 1044->1045; 1041->1046; 1046->1047; 1047->1048; 1048->1049; 1049->1050; 1041->1051; 1051->1052; 1052->1053; 1053->1054; 1054->1055; 1045->1056; 1050->1056; 1055->1056; 1056->1057; }

1014,1015

1021

1041

digraph G { id="graph_602"; subgraph graph_stage_602 { id="graph_stage_602"; isCluster="true"; label="Stage 602 (skipped)"; subgraph cluster_2932 { id="cluster_2932"; isCluster="true"; label="Exchange"; 1065 [id="node_1065" labelType="html" label="ShuffledRowRDD [1065] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2929 { id="cluster_2929"; isCluster="true"; label="WholeStageCodegen (5)"; 1066 [id="node_1066" labelType="html" label="MapPartitionsRDD [1066] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2928 { id="cluster_2928"; isCluster="true"; label="Exchange"; 1067 [id="node_1067" labelType="html" label="MapPartitionsRDD [1067] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1065->1066; 1066->1067; }

1064,1065

digraph G { id="graph_603"; subgraph graph_stage_603 { id="graph_stage_603"; isCluster="true"; label="Stage 603 (skipped)"; subgraph cluster_2899 { id="cluster_2899"; isCluster="true"; label="Exchange"; 1058 [id="node_1058" labelType="html" label="ShuffledRowRDD [1058] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2896 { id="cluster_2896"; isCluster="true"; label="WholeStageCodegen (3)"; 1059 [id="node_1059" labelType="html" label="MapPartitionsRDD [1059] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2928 { id="cluster_2928"; isCluster="true"; label="Exchange"; 1068 [id="node_1068" labelType="html" label="ShuffledRowRDD [1068] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2925 { id="cluster_2925"; isCluster="true"; label="WholeStageCodegen (6)"; 1069 [id="node_1069" labelType="html" label="MapPartitionsRDD [1069] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2891 { id="cluster_2891"; isCluster="true"; label="WholeStageCodegen (7)"; 1070 [id="node_1070" labelType="html" label="ZippedPartitionsRDD2 [1070] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1071 [id="node_1071" labelType="html" label="MapPartitionsRDD [1071] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2890 { id="cluster_2890"; isCluster="true"; label="SortAggregate"; 1072 [id="node_1072" labelType="html" label="MapPartitionsRDD [1072] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2889 { id="cluster_2889"; isCluster="true"; label="Exchange"; 1073 [id="node_1073" labelType="html" label="MapPartitionsRDD [1073] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1058->1059; 1068->1069; 1059->1070; 1069->1070; 1070->1071; 1071->1072; 1072->1073; }

1057,1058

1067,1068

digraph G { id="graph_604"; subgraph graph_stage_604 { id="graph_stage_604"; isCluster="true"; label="Stage 604"; 1089 [id="node_1089" labelType="html" label="SQLExecutionRDD [1089] [Unordered] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_2889 { id="cluster_2889"; isCluster="true"; label="Exchange"; 1074 [id="node_1074" labelType="html" label="ShuffledRowRDD [1074] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2886 { id="cluster_2886"; isCluster="true"; label="WholeStageCodegen (8)"; 1075 [id="node_1075" labelType="html" label="MapPartitionsRDD [1075] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2885 { id="cluster_2885"; isCluster="true"; label="SortAggregate"; 1076 [id="node_1076" labelType="html" label="MapPartitionsRDD [1076] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2884 { id="cluster_2884"; isCluster="true"; label="InMemoryTableScan"; 1077 [id="node_1077" labelType="html" label="MapPartitionsRDD [1077] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1078 [id="node_1078" labelType="html" label="SortAggregate(key=[demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990], functions=[first(kpis#16018, false)], output=[shardId#445, worklistShardItemId#446L, qty#16009, demandChannel#15989, demandStream#15990, kpis#16151])\n+- *(8) Sort [demandChannel#15989 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, qty#16009 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#15990 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990, 37), ENSURE_REQUIREMENTS, [plan_id=115377]\n +- SortAggregate(key=[demandChannel#15989, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#16009)) AS qty#16009, worklistShardItemId#446L, demandStream#15990], functions=[partial_first(kpis#16018, false)], output=[demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990, first#16227, valueSet#16228])\n +- *(7) Sort [demandChannel#159... [1078] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2992 { id="cluster_2992"; isCluster="true"; label="InMemoryTableScan"; 1085 [id="node_1085" labelType="html" label="MapPartitionsRDD [1085] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1086 [id="node_1086" labelType="html" label="MapPartitionsRDD [1086] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1087 [id="node_1087" labelType="html" label="MapPartitionsRDD [1087] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2991 { id="cluster_2991"; isCluster="true"; label="DeserializeToObject"; 1088 [id="node_1088" labelType="html" label="MapPartitionsRDD [1088] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2993 { id="cluster_2993"; isCluster="true"; label="mapPartitions"; 1090 [id="node_1090" labelType="html" label="MapPartitionsRDD [1090] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3013 { id="cluster_3013"; isCluster="true"; label="union"; 1099 [id="node_1099" labelType="html" label="UnionRDD [1099] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3014 { id="cluster_3014"; isCluster="true"; label="filter"; 1100 [id="node_1100" labelType="html" label="MapPartitionsRDD [1100] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3015 { id="cluster_3015"; isCluster="true"; label="distinct"; 1101 [id="node_1101" labelType="html" label="MapPartitionsRDD [1101] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1074->1075; 1075->1076; 1076->1077; 1077->1078; 1078->1085; 1085->1086; 1086->1087; 1087->1088; 1088->1089; 1089->1090; 1090->1099; 1099->1100; 1100->1101; }

1073,1074

1078

digraph G { id="graph_605"; subgraph graph_stage_605 { id="graph_stage_605"; isCluster="true"; label="Stage 605"; subgraph cluster_3015 { id="cluster_3015"; isCluster="true"; label="distinct"; 1102 [id="node_1102" labelType="html" label="ShuffledRDD [1102] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1103 [id="node_1103" labelType="html" label="MapPartitionsRDD [1103] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3016 { id="cluster_3016"; isCluster="true"; label="repartition"; 1104 [id="node_1104" labelType="html" label="MapPartitionsRDD [1104] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1102->1103; 1103->1104; }

1101,1102

1104

digraph G { id="graph_606"; subgraph graph_stage_606 { id="graph_stage_606"; isCluster="true"; label="Stage 606"; subgraph cluster_3016 { id="cluster_3016"; isCluster="true"; label="repartition"; 1105 [id="node_1105" labelType="html" label="ShuffledRDD [1105] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1106 [id="node_1106" labelType="html" label="CoalescedRDD [1106] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1107 [id="node_1107" labelType="html" label="MapPartitionsRDD [1107] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1105->1106; 1106->1107; }

1104,1105

1107

1105

1106

1107

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Shuffle Read	Shuffle Write
606	tenants-pool-506	stream-10000000004-1 id = 0ca74851-d945-4eb8-90f7-ea42a7110a4d runId = c871ced2-19a8-473b-bfe1-6d8b64ffe1bc batch = 1 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 06:22:37	2 s	37/37		1839.6 KiB
605	tenants-pool-506	stream-10000000004-1 id = 0ca74851-d945-4eb8-90f7-ea42a7110a4d runId = c871ced2-19a8-473b-bfe1-6d8b64ffe1bc batch = 1 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 06:21:44	48 s	37/37		1673.4 KiB	1839.6 KiB
604	tenants-pool-506	stream-10000000004-1 id = 0ca74851-d945-4eb8-90f7-ea42a7110a4d runId = c871ced2-19a8-473b-bfe1-6d8b64ffe1bc batch = 1 start at FileStorageAdapterImpl.java:171 +details RDD: SortAggregate(key=[demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990], functions=[first(kpis#16018, false)], output=[shardId#445, worklistShardItemId#446L, qty#16009, demandChannel#15989, demandStream#15990, kpis#16151]) +- (8) Sort [demandChannel#15989 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, qty#16009 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#15990 ASC NULLS FIRST], false, 0 +- Exchange hashpartitioning(demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990, 37), ENSURE_REQUIREMENTS, [plan_id=115377] +- SortAggregate(key=[demandChannel#15989, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#16009)) AS qty#16009, worklistShardItemId#446L, demandStream#15990], functions=[partial_first(kpis#16018, false)], output=[demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990, first#16227, valueSet#16228]) +- (7) Sort [demandChannel#159... 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 06:21:40	3 s	37/37	576.1 KiB		1673.4 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

606

tenants-pool-506

stream-10000000004-1 id = 0ca74851-d945-4eb8-90f7-ea42a7110a4d runId = c871ced2-19a8-473b-bfe1-6d8b64ffe1bc batch = 1 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 06:22:37

2 s

37/37

1839.6 KiB

605

tenants-pool-506

stream-10000000004-1 id = 0ca74851-d945-4eb8-90f7-ea42a7110a4d runId = c871ced2-19a8-473b-bfe1-6d8b64ffe1bc batch = 1 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 06:21:44

48 s

37/37

1673.4 KiB

1839.6 KiB

604

tenants-pool-506

stream-10000000004-1 id = 0ca74851-d945-4eb8-90f7-ea42a7110a4d runId = c871ced2-19a8-473b-bfe1-6d8b64ffe1bc batch = 1 start at FileStorageAdapterImpl.java:171 +details

RDD: SortAggregate(key=[demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990], functions=[first(kpis#16018, false)], output=[shardId#445, worklistShardItemId#446L, qty#16009, demandChannel#15989, demandStream#15990, kpis#16151]) +- *(8) Sort [demandChannel#15989 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, qty#16009 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#15990 ASC NULLS FIRST], false, 0 +- Exchange hashpartitioning(demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990, 37), ENSURE_REQUIREMENTS, [plan_id=115377] +- SortAggregate(key=[demandChannel#15989, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#16009)) AS qty#16009, worklistShardItemId#446L, demandStream#15990], functions=[partial_first(kpis#16018, false)], output=[demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990, first#16227, valueSet#16228]) +- *(7) Sort [demandChannel#159...

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 06:21:40

3 s

37/37

576.1 KiB

1673.4 KiB

Page:

Skipped Stages (19)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
603	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
602	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
601	default	start at FileStorageAdapterImpl.java:171 +details RDD: MapPartitionsRDD (1) Generate explode(prodPlantResults#15956), false, [prodPlantResults#15963] +- (1) Project [prodPlantResults#15956] +- (1) Filter ((size(prodPlantResults#15956, true) > 0) AND isnotnull(prodPlantResults#15956)) +- (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
600	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
599	default	start at FileStorageAdapterImpl.java:171 +details RDD: (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#13010 AS qty#13012, demandChannel#13005, demandStream#13006, cachedKpis#13011 AS kpis#13013] +- (8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#13009L, cachedShardId#13008], 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#13245, null AS demandStream#13246, [] AS kpis#13280, true AS isNewlyCalculated#13248] : +- (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#13237, ), isnull(shardId#13237), coalesce(worklistShardItemId#13238L, 0), isnull(worklistShardItemId#13238L), coalesce(version#13239, 0), isnull(version#13239), coalesce(product#13240, ), isnull(product#13240), coalesce(plant#13241, ), isnull(plant#13241), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#13012, 0.0))), isnull(qty#13012)], 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
598	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
597	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
596	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
595	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
594	default	start at FileStorageAdapterImpl.java:171 +details RDD: (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#13010 AS qty#13012, demandChannel#13005, demandStream#13006, cachedKpis#13011 AS kpis#13013] +- (8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#13009L, cachedShardId#13008], 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#13245, null AS demandStream#13246, [] AS kpis#13280, true AS isNewlyCalculated#13248] : +- (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#13237, ), isnull(shardId#13237), coalesce(worklistShardItemId#13238L, 0), isnull(worklistShardItemId#13238L), coalesce(version#13239, 0), isnull(version#13239), coalesce(product#13240, ), isnull(product#13240), coalesce(plant#13241, ), isnull(plant#13241), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#13012, 0.0))), isnull(qty#13012)], 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
593	default	start at FileStorageAdapterImpl.java:171 +details RDD: (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#13010 AS qty#13012, demandChannel#13005, demandStream#13006, cachedKpis#13011 AS kpis#13013] +- (8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#13009L, cachedShardId#13008], 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#13245, null AS demandStream#13246, [] AS kpis#13280, true AS isNewlyCalculated#13248] : +- (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#13237, ), isnull(shardId#13237), coalesce(worklistShardItemId#13238L, 0), isnull(worklistShardItemId#13238L), coalesce(version#13239, 0), isnull(version#13239), coalesce(product#13240, ), isnull(product#13240), coalesce(plant#13241, ), isnull(plant#13241), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#13012, 0.0))), isnull(qty#13012)], 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
592	default	start at FileStorageAdapterImpl.java:171 +details RDD: (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#13010 AS qty#13012, demandChannel#13005, demandStream#13006, cachedKpis#13011 AS kpis#13013] +- (8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#13009L, cachedShardId#13008], 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
591	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
590	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/0
589	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
588	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/0
587	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/0
586	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
585	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: