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

Status: SUCCEEDED
Submitted: 2026/04/20 06:17:34
Duration: 1.2 min
Associated SQL Query: 72
Job Group: c871ced2-19a8-473b-bfe1-6d8b64ffe1bc
Completed Stages: 8
Skipped Stages: 8

Enable zooming

digraph G { id="graph_509"; subgraph graph_stage_509 { id="graph_stage_509"; isCluster="true"; label="Stage 509 (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_510"; subgraph graph_stage_510 { id="graph_stage_510"; isCluster="true"; label="Stage 510 (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_511"; subgraph graph_stage_511 { id="graph_stage_511"; isCluster="true"; label="Stage 511 (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_512"; subgraph graph_stage_512 { id="graph_stage_512"; isCluster="true"; label="Stage 512 (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_513"; subgraph graph_stage_513 { id="graph_stage_513"; isCluster="true"; label="Stage 513 (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_514"; subgraph graph_stage_514 { id="graph_stage_514"; isCluster="true"; label="Stage 514 (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_515"; subgraph graph_stage_515 { id="graph_stage_515"; isCluster="true"; label="Stage 515 (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_516"; subgraph graph_stage_516 { id="graph_stage_516"; isCluster="true"; label="Stage 516 (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_517"; subgraph graph_stage_517 { id="graph_stage_517"; isCluster="true"; label="Stage 517"; 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_518"; subgraph graph_stage_518 { id="graph_stage_518"; isCluster="true"; label="Stage 518"; 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_519"; subgraph graph_stage_519 { id="graph_stage_519"; isCluster="true"; label="Stage 519"; 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_520"; subgraph graph_stage_520 { id="graph_stage_520"; isCluster="true"; label="Stage 520"; 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_521"; subgraph graph_stage_521 { id="graph_stage_521"; isCluster="true"; label="Stage 521"; 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_522"; subgraph graph_stage_522 { id="graph_stage_522"; isCluster="true"; label="Stage 522"; 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_523"; subgraph graph_stage_523 { id="graph_stage_523"; isCluster="true"; label="Stage 523"; 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_524"; subgraph graph_stage_524 { id="graph_stage_524"; isCluster="true"; label="Stage 524"; 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}"]; } } 1015->1016; 1016->1017; 1017->1018; 1018->1019; 1019->1020; 1020->1021; }

1014,1015

1021

Completed Stages (8)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Shuffle Read	Shuffle Write
524	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: MapPartitionsRDD 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:18:37	10 s	37/37		1451.3 KiB
523	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:17:41	0.5 s	37/37		2.3 MiB	1451.3 KiB
522	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: (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)	2026/04/20 06:17:35	0.6 s	111/111	315.7 KiB		809.9 KiB
521	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:17:36	1 s	37/37		2.5 MiB	1594.0 KiB
520	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:17:35	1 s	37/37		4.0 MiB	2.5 MiB
519	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:17:34	0.6 s	37/37	355.3 KiB		2.5 MiB
518	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:17:34	0.5 s	37/37	355.3 KiB		1525.0 KiB
517	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: (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)	2026/04/20 06:17:34	0.6 s	74/74	315.7 KiB

Page:

Skipped Stages (8)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
516	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
515	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
514	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
513	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
512	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
511	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
510	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
509	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: