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

Status: SUCCEEDED
Submitted: 2026/04/20 06:17:27
Duration: 7 s
Associated SQL Query: 76
Job Group: c871ced2-19a8-473b-bfe1-6d8b64ffe1bc
Completed Stages: 6
Skipped Stages: 4

Enable zooming

digraph G { id="graph_492"; subgraph graph_stage_492 { id="graph_stage_492"; isCluster="true"; label="Stage 492 (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_493"; subgraph graph_stage_493 { id="graph_stage_493"; isCluster="true"; label="Stage 493"; 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_494"; subgraph graph_stage_494 { id="graph_stage_494"; isCluster="true"; label="Stage 494 (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_495"; subgraph graph_stage_495 { id="graph_stage_495"; isCluster="true"; label="Stage 495"; 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_496"; subgraph graph_stage_496 { id="graph_stage_496"; isCluster="true"; label="Stage 496 (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_497"; subgraph graph_stage_497 { id="graph_stage_497"; isCluster="true"; label="Stage 497 (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_498"; subgraph graph_stage_498 { id="graph_stage_498"; isCluster="true"; label="Stage 498"; 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_499"; subgraph graph_stage_499 { id="graph_stage_499"; isCluster="true"; label="Stage 499"; 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_500"; subgraph graph_stage_500 { id="graph_stage_500"; isCluster="true"; label="Stage 500"; 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}"]; 950 [id="node_950" labelType="html" label="MapPartitionsRDD [950] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 951 [id="node_951" labelType="html" label="MapPartitionsRDD [951] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 952 [id="node_952" labelType="html" label="MapPartitionsRDD [952] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2501 { id="cluster_2501"; isCluster="true"; label="WholeStageCodegen (14)"; 953 [id="node_953" labelType="html" label="MapPartitionsRDD [953] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2500 { id="cluster_2500"; isCluster="true"; label="Exchange"; 954 [id="node_954" labelType="html" label="MapPartitionsRDD [954] [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->950; 950->951; 951->952; 952->953; 953->954; }

888,889

904,905

908,909

914,915

938,939

920

949

digraph G { id="graph_501"; subgraph graph_stage_501 { id="graph_stage_501"; isCluster="true"; label="Stage 501"; subgraph cluster_2500 { id="cluster_2500"; isCluster="true"; label="Exchange"; 955 [id="node_955" labelType="html" label="ShuffledRowRDD [955] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2495 { id="cluster_2495"; isCluster="true"; label="WholeStageCodegen (15)"; 956 [id="node_956" labelType="html" label="MapPartitionsRDD [956] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2486 { id="cluster_2486"; isCluster="true"; label="MapPartitions"; 957 [id="node_957" labelType="html" label="MapPartitionsRDD [957] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 955->956; 956->957; }

954,955

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Shuffle Read	Shuffle Write
501	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:33	0.7 s	37/37		2.7 KiB
500	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:32	1 s	74/74	777.0 B	886.8 KiB	2.7 KiB
499	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]... 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:31	1 s	74/74		1771.5 KiB
498	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:27	1 s	37/37	355.3 KiB		886.8 KiB
495	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:27	1 s	37/37	355.3 KiB		885.8 KiB
493	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:27	3 s	37/37	355.3 KiB		885.8 KiB

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
497	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
496	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
494	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
492	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: