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

Status: SUCCEEDED
Submitted: 2026/04/20 06:42:44
Duration: 47 s
Associated SQL Query: 88
Job Group: c871ced2-19a8-473b-bfe1-6d8b64ffe1bc
Completed Stages: 3
Skipped Stages: 40

Enable zooming

digraph G { id="graph_834"; subgraph graph_stage_834 { id="graph_stage_834"; isCluster="true"; label="Stage 834 (skipped)"; 1165 [id="node_1165" labelType="html" label="SQLExecutionRDD [1165] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_3163 { id="cluster_3163"; isCluster="true"; label="Scan parquet "; 1162 [id="node_1162" labelType="html" label="FileScanRDD [1162] start at FileStorageAdapterImpl.java:171}"]; 1163 [id="node_1163" labelType="html" label="MapPartitionsRDD [1163] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3160 { id="cluster_3160"; isCluster="true"; label="WholeStageCodegen (1)"; 1164 [id="node_1164" labelType="html" label="MapPartitionsRDD [1164] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3167 { id="cluster_3167"; isCluster="true"; label="WholeStageCodegen (1)"; 1166 [id="node_1166" labelType="html" label="MapPartitionsRDD [1166] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3166 { id="cluster_3166"; isCluster="true"; label="Exchange"; 1167 [id="node_1167" labelType="html" label="MapPartitionsRDD [1167] start at FileStorageAdapterImpl.java:171}"]; } } 1162->1163; 1163->1164; 1164->1165; 1165->1166; 1166->1167; }

digraph G { id="graph_835"; subgraph graph_stage_835 { id="graph_stage_835"; isCluster="true"; label="Stage 835 (skipped)"; subgraph cluster_3166 { id="cluster_3166"; isCluster="true"; label="Exchange"; 1168 [id="node_1168" labelType="html" label="ShuffledRowRDD [1168] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3165 { id="cluster_3165"; isCluster="true"; label="InMemoryTableScan"; 1169 [id="node_1169" labelType="html" label="MapPartitionsRDD [1169] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1170 [id="node_1170" labelType="html" label="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=115930]\n+- *(1) Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]\n [1170] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3451 { id="cluster_3451"; isCluster="true"; label="InMemoryTableScan"; 1269 [id="node_1269" labelType="html" label="MapPartitionsRDD [1269] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1270 [id="node_1270" labelType="html" label="MapPartitionsRDD [1270] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1271 [id="node_1271" labelType="html" label="MapPartitionsRDD [1271] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3441 { id="cluster_3441"; isCluster="true"; label="WholeStageCodegen (3)"; 1272 [id="node_1272" labelType="html" label="MapPartitionsRDD [1272] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3440 { id="cluster_3440"; isCluster="true"; label="Exchange"; 1273 [id="node_1273" labelType="html" label="MapPartitionsRDD [1273] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1168->1169; 1169->1170; 1170->1269; 1269->1270; 1270->1271; 1271->1272; 1272->1273; }

1167,1168

1170

digraph G { id="graph_836"; subgraph graph_stage_836 { id="graph_stage_836"; isCluster="true"; label="Stage 836 (skipped)"; subgraph cluster_3166 { id="cluster_3166"; isCluster="true"; label="Exchange"; 1168 [id="node_1168" labelType="html" label="ShuffledRowRDD [1168] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3165 { id="cluster_3165"; isCluster="true"; label="InMemoryTableScan"; 1169 [id="node_1169" labelType="html" label="MapPartitionsRDD [1169] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1170 [id="node_1170" labelType="html" label="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=115930]\n+- *(1) Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]\n [1170] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3470 { id="cluster_3470"; isCluster="true"; label="InMemoryTableScan"; 1276 [id="node_1276" labelType="html" label="MapPartitionsRDD [1276] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1277 [id="node_1277" labelType="html" label="MapPartitionsRDD [1277] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1278 [id="node_1278" labelType="html" label="MapPartitionsRDD [1278] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3457 { id="cluster_3457"; isCluster="true"; label="WholeStageCodegen (6)"; 1279 [id="node_1279" labelType="html" label="MapPartitionsRDD [1279] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3456 { id="cluster_3456"; isCluster="true"; label="Exchange"; 1280 [id="node_1280" labelType="html" label="MapPartitionsRDD [1280] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1168->1169; 1169->1170; 1170->1276; 1276->1277; 1277->1278; 1278->1279; 1279->1280; }

1167,1168

1170

digraph G { id="graph_837"; subgraph graph_stage_837 { id="graph_stage_837"; isCluster="true"; label="Stage 837 (skipped)"; subgraph cluster_3440 { id="cluster_3440"; isCluster="true"; label="Exchange"; 1274 [id="node_1274" labelType="html" label="ShuffledRowRDD [1274] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3437 { id="cluster_3437"; isCluster="true"; label="WholeStageCodegen (4)"; 1275 [id="node_1275" labelType="html" label="MapPartitionsRDD [1275] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3456 { id="cluster_3456"; isCluster="true"; label="Exchange"; 1281 [id="node_1281" labelType="html" label="ShuffledRowRDD [1281] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3453 { id="cluster_3453"; isCluster="true"; label="WholeStageCodegen (7)"; 1282 [id="node_1282" labelType="html" label="MapPartitionsRDD [1282] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3433 { id="cluster_3433"; isCluster="true"; label="WholeStageCodegen (8)"; 1283 [id="node_1283" labelType="html" label="ZippedPartitionsRDD2 [1283] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1284 [id="node_1284" labelType="html" label="MapPartitionsRDD [1284] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3432 { id="cluster_3432"; isCluster="true"; label="ObjectHashAggregate"; 1285 [id="node_1285" labelType="html" label="MapPartitionsRDD [1285] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3431 { id="cluster_3431"; isCluster="true"; label="Exchange"; 1286 [id="node_1286" labelType="html" label="MapPartitionsRDD [1286] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1274->1275; 1281->1282; 1275->1283; 1282->1283; 1283->1284; 1284->1285; 1285->1286; }

1273,1274

1280,1281

digraph G { id="graph_838"; subgraph graph_stage_838 { id="graph_stage_838"; isCluster="true"; label="Stage 838 (skipped)"; subgraph cluster_3166 { id="cluster_3166"; isCluster="true"; label="Exchange"; 1168 [id="node_1168" labelType="html" label="ShuffledRowRDD [1168] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3165 { id="cluster_3165"; isCluster="true"; label="InMemoryTableScan"; 1169 [id="node_1169" labelType="html" label="MapPartitionsRDD [1169] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1170 [id="node_1170" labelType="html" label="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=115930]\n+- *(1) Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]\n [1170] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3278 { id="cluster_3278"; isCluster="true"; label="InMemoryTableScan"; 1196 [id="node_1196" labelType="html" label="MapPartitionsRDD [1196] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1197 [id="node_1197" labelType="html" label="MapPartitionsRDD [1197] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1198 [id="node_1198" labelType="html" label="MapPartitionsRDD [1198] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3275 { id="cluster_3275"; isCluster="true"; label="WholeStageCodegen (1)"; 1199 [id="node_1199" labelType="html" label="MapPartitionsRDD [1199] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3274 { id="cluster_3274"; isCluster="true"; label="Exchange"; 1200 [id="node_1200" labelType="html" label="MapPartitionsRDD [1200] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1168->1169; 1169->1170; 1170->1196; 1196->1197; 1197->1198; 1198->1199; 1199->1200; }

1167,1168

1170

digraph G { id="graph_839"; subgraph graph_stage_839 { id="graph_stage_839"; isCluster="true"; label="Stage 839 (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_840"; subgraph graph_stage_840 { id="graph_stage_840"; isCluster="true"; label="Stage 840 (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] [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

digraph G { id="graph_841"; subgraph graph_stage_841 { id="graph_stage_841"; isCluster="true"; label="Stage 841 (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_842"; subgraph graph_stage_842 { id="graph_stage_842"; isCluster="true"; label="Stage 842 (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_843"; subgraph graph_stage_843 { id="graph_stage_843"; isCluster="true"; label="Stage 843 (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] [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

digraph G { id="graph_844"; subgraph graph_stage_844 { id="graph_stage_844"; isCluster="true"; label="Stage 844 (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_845"; subgraph graph_stage_845 { id="graph_stage_845"; isCluster="true"; label="Stage 845 (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] [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

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

888,889

904,905

908,909

914,915

938,939

920

949

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

888,889

904,905

908,909

914,915

938,939

920

949

digraph G { id="graph_849"; subgraph graph_stage_849 { id="graph_stage_849"; isCluster="true"; label="Stage 849 (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] [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

digraph G { id="graph_850"; subgraph graph_stage_850 { id="graph_stage_850"; isCluster="true"; label="Stage 850 (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] [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

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

975,976

982,983

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

988,989

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

888,889

904,905

908,909

914,915

938,939

1000,1001

920

949

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

992,993

1008,1009

digraph G { id="graph_855"; subgraph graph_stage_855 { id="graph_stage_855"; isCluster="true"; label="Stage 855 (skipped)"; 1020 [id="node_1020" labelType="html" label="SQLExecutionRDD [1020] [Unordered] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_2710 { id="cluster_2710"; isCluster="true"; label="Exchange"; 1015 [id="node_1015" labelType="html" label="ShuffledRowRDD [1015] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2709 { id="cluster_2709"; isCluster="true"; label="ObjectHashAggregate"; 1016 [id="node_1016" labelType="html" label="MapPartitionsRDD [1016] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2599 { id="cluster_2599"; isCluster="true"; label="WholeStageCodegen (16)"; 1017 [id="node_1017" labelType="html" label="MapPartitionsRDD [1017] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2494 { id="cluster_2494"; isCluster="true"; label="DeserializeToObject"; 1018 [id="node_1018" labelType="html" label="MapPartitionsRDD [1018] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2486 { id="cluster_2486"; isCluster="true"; label="MapPartitions"; 1019 [id="node_1019" labelType="html" label="MapPartitionsRDD [1019] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2781 { id="cluster_2781"; isCluster="true"; label="mapPartitions"; 1021 [id="node_1021" labelType="html" label="MapPartitionsRDD [1021] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2909 { id="cluster_2909"; isCluster="true"; label="Scan"; 1038 [id="node_1038" labelType="html" label="MapPartitionsRDD [1038] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2903 { id="cluster_2903"; isCluster="true"; label="WholeStageCodegen (1)"; 1039 [id="node_1039" labelType="html" label="MapPartitionsRDD [1039] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2902 { id="cluster_2902"; isCluster="true"; label="InMemoryTableScan"; 1040 [id="node_1040" labelType="html" label="MapPartitionsRDD [1040] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1041 [id="node_1041" labelType="html" label="*(1) Generate explode(prodPlantResults#15956), false, [prodPlantResults#15963]\n+- *(1) Project [prodPlantResults#15956]\n +- *(1) Filter ((size(prodPlantResults#15956, true) > 0) AND isnotnull(prodPlantResults#15956))\n +- *(1) SerializeFromObject [mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement)))) null else named_struct(measuredUnit, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true)... [1041] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1042 [id="node_1042" labelType="html" label="MapPartitionsRDD [1042] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1043 [id="node_1043" labelType="html" label="MapPartitionsRDD [1043] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1044 [id="node_1044" labelType="html" label="MapPartitionsRDD [1044] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2901 { id="cluster_2901"; isCluster="true"; label="Project"; 1045 [id="node_1045" labelType="html" label="MapPartitionsRDD [1045] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2916 { id="cluster_2916"; isCluster="true"; label="InMemoryTableScan"; 1046 [id="node_1046" labelType="html" label="MapPartitionsRDD [1046] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1047 [id="node_1047" labelType="html" label="MapPartitionsRDD [1047] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1048 [id="node_1048" labelType="html" label="MapPartitionsRDD [1048] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2911 { id="cluster_2911"; isCluster="true"; label="WholeStageCodegen (1)"; 1049 [id="node_1049" labelType="html" label="MapPartitionsRDD [1049] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2910 { id="cluster_2910"; isCluster="true"; label="Project"; 1050 [id="node_1050" labelType="html" label="MapPartitionsRDD [1050] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2923 { id="cluster_2923"; isCluster="true"; label="InMemoryTableScan"; 1051 [id="node_1051" labelType="html" label="MapPartitionsRDD [1051] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1052 [id="node_1052" labelType="html" label="MapPartitionsRDD [1052] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1053 [id="node_1053" labelType="html" label="MapPartitionsRDD [1053] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2918 { id="cluster_2918"; isCluster="true"; label="WholeStageCodegen (2)"; 1054 [id="node_1054" labelType="html" label="MapPartitionsRDD [1054] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2917 { id="cluster_2917"; isCluster="true"; label="Project"; 1055 [id="node_1055" labelType="html" label="MapPartitionsRDD [1055] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2900 { id="cluster_2900"; isCluster="true"; label="Union"; 1056 [id="node_1056" labelType="html" label="UnionRDD [1056] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2899 { id="cluster_2899"; isCluster="true"; label="Exchange"; 1057 [id="node_1057" labelType="html" label="MapPartitionsRDD [1057] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1015->1016; 1016->1017; 1017->1018; 1018->1019; 1019->1020; 1020->1021; 1021->1038; 1038->1039; 1039->1040; 1040->1041; 1041->1042; 1042->1043; 1043->1044; 1044->1045; 1041->1046; 1046->1047; 1047->1048; 1048->1049; 1049->1050; 1041->1051; 1051->1052; 1052->1053; 1053->1054; 1054->1055; 1045->1056; 1050->1056; 1055->1056; 1056->1057; }

1014,1015

1021

1041

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

1064,1065

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

1057,1058

1067,1068

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

1073,1074

1078

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

1101,1102

1104

digraph G { id="graph_860"; subgraph graph_stage_860 { id="graph_stage_860"; isCluster="true"; label="Stage 860 (skipped)"; subgraph cluster_3016 { id="cluster_3016"; isCluster="true"; label="repartition"; 1105 [id="node_1105" labelType="html" label="ShuffledRDD [1105] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1106 [id="node_1106" labelType="html" label="CoalescedRDD [1106] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1107 [id="node_1107" labelType="html" label="MapPartitionsRDD [1107] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3206 { id="cluster_3206"; isCluster="true"; label="map"; 1187 [id="node_1187" labelType="html" label="MapPartitionsRDD [1187] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3293 { id="cluster_3293"; isCluster="true"; label="WholeStageCodegen (6)"; 1216 [id="node_1216" labelType="html" label="MapPartitionsRDD [1216] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3292 { id="cluster_3292"; isCluster="true"; label="Exchange"; 1217 [id="node_1217" labelType="html" label="MapPartitionsRDD [1217] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1105->1106; 1106->1107; 1107->1187; 1187->1216; 1216->1217; }

1104,1105

1107

1105

1106

1107

1187

1216

1217

digraph G { id="graph_861"; subgraph graph_stage_861 { id="graph_stage_861"; isCluster="true"; label="Stage 861 (skipped)"; subgraph cluster_3016 { id="cluster_3016"; isCluster="true"; label="repartition"; 1105 [id="node_1105" labelType="html" label="ShuffledRDD [1105] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1106 [id="node_1106" labelType="html" label="CoalescedRDD [1106] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1107 [id="node_1107" labelType="html" label="MapPartitionsRDD [1107] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3206 { id="cluster_3206"; isCluster="true"; label="map"; 1187 [id="node_1187" labelType="html" label="MapPartitionsRDD [1187] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3284 { id="cluster_3284"; isCluster="true"; label="WholeStageCodegen (3)"; 1203 [id="node_1203" labelType="html" label="MapPartitionsRDD [1203] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3283 { id="cluster_3283"; isCluster="true"; label="Exchange"; 1204 [id="node_1204" labelType="html" label="MapPartitionsRDD [1204] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1105->1106; 1106->1107; 1107->1187; 1187->1203; 1203->1204; }

1104,1105

1107

1105

1106

1107

1187

1203

1204

digraph G { id="graph_862"; subgraph graph_stage_862 { id="graph_stage_862"; isCluster="true"; label="Stage 862 (skipped)"; subgraph cluster_3016 { id="cluster_3016"; isCluster="true"; label="repartition"; 1105 [id="node_1105" labelType="html" label="ShuffledRDD [1105] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1106 [id="node_1106" labelType="html" label="CoalescedRDD [1106] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1107 [id="node_1107" labelType="html" label="MapPartitionsRDD [1107] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3206 { id="cluster_3206"; isCluster="true"; label="map"; 1187 [id="node_1187" labelType="html" label="MapPartitionsRDD [1187] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3318 { id="cluster_3318"; isCluster="true"; label="WholeStageCodegen (4)"; 1234 [id="node_1234" labelType="html" label="MapPartitionsRDD [1234] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3317 { id="cluster_3317"; isCluster="true"; label="Exchange"; 1235 [id="node_1235" labelType="html" label="MapPartitionsRDD [1235] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1105->1106; 1106->1107; 1107->1187; 1187->1234; 1234->1235; }

1104,1105

1107

1105

1106

1107

1187

1234

1235

digraph G { id="graph_863"; subgraph graph_stage_863 { id="graph_stage_863"; isCluster="true"; label="Stage 863 (skipped)"; subgraph cluster_3166 { id="cluster_3166"; isCluster="true"; label="Exchange"; 1168 [id="node_1168" labelType="html" label="ShuffledRowRDD [1168] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3165 { id="cluster_3165"; isCluster="true"; label="InMemoryTableScan"; 1169 [id="node_1169" labelType="html" label="MapPartitionsRDD [1169] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1170 [id="node_1170" labelType="html" label="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=115930]\n+- *(1) Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]\n [1170] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3312 { id="cluster_3312"; isCluster="true"; label="InMemoryTableScan"; 1227 [id="node_1227" labelType="html" label="MapPartitionsRDD [1227] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1228 [id="node_1228" labelType="html" label="MapPartitionsRDD [1228] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1229 [id="node_1229" labelType="html" label="MapPartitionsRDD [1229] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3309 { id="cluster_3309"; isCluster="true"; label="WholeStageCodegen (2)"; 1230 [id="node_1230" labelType="html" label="MapPartitionsRDD [1230] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3308 { id="cluster_3308"; isCluster="true"; label="Exchange"; 1231 [id="node_1231" labelType="html" label="MapPartitionsRDD [1231] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1168->1169; 1169->1170; 1170->1227; 1227->1228; 1228->1229; 1229->1230; 1230->1231; }

1167,1168

1170

digraph G { id="graph_864"; subgraph graph_stage_864 { id="graph_stage_864"; isCluster="true"; label="Stage 864 (skipped)"; subgraph cluster_3274 { id="cluster_3274"; isCluster="true"; label="Exchange"; 1201 [id="node_1201" labelType="html" label="ShuffledRowRDD [1201] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3271 { id="cluster_3271"; isCluster="true"; label="WholeStageCodegen (2)"; 1202 [id="node_1202" labelType="html" label="MapPartitionsRDD [1202] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3283 { id="cluster_3283"; isCluster="true"; label="Exchange"; 1205 [id="node_1205" labelType="html" label="ShuffledRowRDD [1205] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3280 { id="cluster_3280"; isCluster="true"; label="WholeStageCodegen (4)"; 1208 [id="node_1208" labelType="html" label="MapPartitionsRDD [1208] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3262 { id="cluster_3262"; isCluster="true"; label="WholeStageCodegen (5)"; 1212 [id="node_1212" labelType="html" label="ZippedPartitionsRDD2 [1212] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1215 [id="node_1215" labelType="html" label="MapPartitionsRDD [1215] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3292 { id="cluster_3292"; isCluster="true"; label="Exchange"; 1218 [id="node_1218" labelType="html" label="ShuffledRowRDD [1218] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3289 { id="cluster_3289"; isCluster="true"; label="WholeStageCodegen (7)"; 1219 [id="node_1219" labelType="html" label="MapPartitionsRDD [1219] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3258 { id="cluster_3258"; isCluster="true"; label="WholeStageCodegen (8)"; 1220 [id="node_1220" labelType="html" label="ZippedPartitionsRDD2 [1220] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1221 [id="node_1221" labelType="html" label="MapPartitionsRDD [1221] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3257 { id="cluster_3257"; isCluster="true"; label="InMemoryTableScan"; 1222 [id="node_1222" labelType="html" label="MapPartitionsRDD [1222] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1223 [id="node_1223" labelType="html" label="*(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#18776 AS qty#18778, demandChannel#18771, demandStream#18772, cachedKpis#18777 AS kpis#18779]\n+- *(8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#18775L, cachedShardId#18774], 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]... [1223] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1224 [id="node_1224" labelType="html" label="MapPartitionsRDD [1224] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1225 [id="node_1225" labelType="html" label="MapPartitionsRDD [1225] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1226 [id="node_1226" labelType="html" label="MapPartitionsRDD [1226] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3308 { id="cluster_3308"; isCluster="true"; label="Exchange"; 1232 [id="node_1232" labelType="html" label="ShuffledRowRDD [1232] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3305 { id="cluster_3305"; isCluster="true"; label="WholeStageCodegen (3)"; 1233 [id="node_1233" labelType="html" label="MapPartitionsRDD [1233] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3317 { id="cluster_3317"; isCluster="true"; label="Exchange"; 1236 [id="node_1236" labelType="html" label="ShuffledRowRDD [1236] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3314 { id="cluster_3314"; isCluster="true"; label="WholeStageCodegen (5)"; 1237 [id="node_1237" labelType="html" label="MapPartitionsRDD [1237] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3297 { id="cluster_3297"; isCluster="true"; label="WholeStageCodegen (6)"; 1238 [id="node_1238" labelType="html" label="ZippedPartitionsRDD2 [1238] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1239 [id="node_1239" labelType="html" label="MapPartitionsRDD [1239] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3256 { id="cluster_3256"; isCluster="true"; label="Union"; 1240 [id="node_1240" labelType="html" label="UnionRDD [1240] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3255 { id="cluster_3255"; isCluster="true"; label="Exchange"; 1241 [id="node_1241" labelType="html" label="MapPartitionsRDD [1241] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1201->1202; 1205->1208; 1202->1212; 1208->1212; 1212->1215; 1218->1219; 1215->1220; 1219->1220; 1220->1221; 1221->1222; 1222->1223; 1223->1224; 1224->1225; 1225->1226; 1232->1233; 1236->1237; 1233->1238; 1237->1238; 1238->1239; 1226->1240; 1239->1240; 1240->1241; }

1200,1201

1204,1205

1217,1218

1231,1232

1235,1236

1223

1205

1208

1212

1215

1218

1219

1220

1221

1222

1223

1224

1225

1226

1236

1237

1238

1239

1240

1241

digraph G { id="graph_865"; subgraph graph_stage_865 { id="graph_stage_865"; isCluster="true"; label="Stage 865 (skipped)"; subgraph cluster_3166 { id="cluster_3166"; isCluster="true"; label="Exchange"; 1168 [id="node_1168" labelType="html" label="ShuffledRowRDD [1168] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3165 { id="cluster_3165"; isCluster="true"; label="InMemoryTableScan"; 1169 [id="node_1169" labelType="html" label="MapPartitionsRDD [1169] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1170 [id="node_1170" labelType="html" label="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=115930]\n+- *(1) Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]\n [1170] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3250 { id="cluster_3250"; isCluster="true"; label="InMemoryTableScan"; 1190 [id="node_1190" labelType="html" label="MapPartitionsRDD [1190] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1191 [id="node_1191" labelType="html" label="MapPartitionsRDD [1191] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 1192 [id="node_1192" labelType="html" label="MapPartitionsRDD [1192] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3249 { id="cluster_3249"; isCluster="true"; label="Exchange"; 1193 [id="node_1193" labelType="html" label="MapPartitionsRDD [1193] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1168->1169; 1169->1170; 1170->1190; 1190->1191; 1191->1192; 1192->1193; }

1167,1168

1170

digraph G { id="graph_866"; subgraph graph_stage_866 { id="graph_stage_866"; isCluster="true"; label="Stage 866 (skipped)"; subgraph cluster_3249 { id="cluster_3249"; isCluster="true"; label="Exchange"; 1194 [id="node_1194" labelType="html" label="ShuffledRowRDD [1194] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3246 { id="cluster_3246"; isCluster="true"; label="WholeStageCodegen (1)"; 1195 [id="node_1195" labelType="html" label="MapPartitionsRDD [1195] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3274 { id="cluster_3274"; isCluster="true"; label="Exchange"; 1201 [id="node_1201" labelType="html" label="ShuffledRowRDD [1201] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3271 { id="cluster_3271"; isCluster="true"; label="WholeStageCodegen (2)"; 1202 [id="node_1202" labelType="html" label="MapPartitionsRDD [1202] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3283 { id="cluster_3283"; isCluster="true"; label="Exchange"; 1205 [id="node_1205" labelType="html" label="ShuffledRowRDD [1205] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3280 { id="cluster_3280"; isCluster="true"; label="WholeStageCodegen (4)"; 1208 [id="node_1208" labelType="html" label="MapPartitionsRDD [1208] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3262 { id="cluster_3262"; isCluster="true"; label="WholeStageCodegen (5)"; 1212 [id="node_1212" labelType="html" label="ZippedPartitionsRDD2 [1212] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1215 [id="node_1215" labelType="html" label="MapPartitionsRDD [1215] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3292 { id="cluster_3292"; isCluster="true"; label="Exchange"; 1218 [id="node_1218" labelType="html" label="ShuffledRowRDD [1218] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3289 { id="cluster_3289"; isCluster="true"; label="WholeStageCodegen (7)"; 1219 [id="node_1219" labelType="html" label="MapPartitionsRDD [1219] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3258 { id="cluster_3258"; isCluster="true"; label="WholeStageCodegen (8)"; 1220 [id="node_1220" labelType="html" label="ZippedPartitionsRDD2 [1220] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1221 [id="node_1221" labelType="html" label="MapPartitionsRDD [1221] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3257 { id="cluster_3257"; isCluster="true"; label="InMemoryTableScan"; 1222 [id="node_1222" labelType="html" label="MapPartitionsRDD [1222] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1223 [id="node_1223" labelType="html" label="*(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#18776 AS qty#18778, demandChannel#18771, demandStream#18772, cachedKpis#18777 AS kpis#18779]\n+- *(8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#18775L, cachedShardId#18774], 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]... [1223] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3255 { id="cluster_3255"; isCluster="true"; label="Exchange"; 1242 [id="node_1242" labelType="html" label="ShuffledRowRDD [1242] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3252 { id="cluster_3252"; isCluster="true"; label="WholeStageCodegen (7)"; 1245 [id="node_1245" labelType="html" label="MapPartitionsRDD [1245] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3238 { id="cluster_3238"; isCluster="true"; label="WholeStageCodegen (8)"; 1246 [id="node_1246" labelType="html" label="ZippedPartitionsRDD2 [1246] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1247 [id="node_1247" labelType="html" label="MapPartitionsRDD [1247] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3325 { id="cluster_3325"; isCluster="true"; label="InMemoryTableScan"; 1248 [id="node_1248" labelType="html" label="MapPartitionsRDD [1248] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1249 [id="node_1249" labelType="html" label="MapPartitionsRDD [1249] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1250 [id="node_1250" labelType="html" label="MapPartitionsRDD [1250] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3322 { id="cluster_3322"; isCluster="true"; label="WholeStageCodegen (9)"; 1251 [id="node_1251" labelType="html" label="MapPartitionsRDD [1251] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3237 { id="cluster_3237"; isCluster="true"; label="Union"; 1252 [id="node_1252" labelType="html" label="UnionRDD [1252] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3236 { id="cluster_3236"; isCluster="true"; label="InMemoryTableScan"; 1253 [id="node_1253" labelType="html" label="MapPartitionsRDD [1253] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1254 [id="node_1254" labelType="html" label="Union\n:- *(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#19011, null AS demandStream#19012, [] AS kpis#19046, true AS isNewlyCalculated#19014]\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#19003, ), isnull(shardId#19003), coalesce(worklistShardItemId#19004L, 0), isnull(worklistShardItemId#19004L), coalesce(version#19005, 0), isnull(version#19005), coalesce(product#19006, ), isnull(product#19006), coalesce(plant#19007, ), isnull(plant#19007), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#18778, 0.0))), isnull(qty#18778)], LeftAnti\n: :- *(1) Sort [coalesce(shardId#445, ) ASC NUL... [1254] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3484 { id="cluster_3484"; isCluster="true"; label="InMemoryTableScan"; 1293 [id="node_1293" labelType="html" label="MapPartitionsRDD [1293] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1294 [id="node_1294" labelType="html" label="MapPartitionsRDD [1294] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1295 [id="node_1295" labelType="html" label="MapPartitionsRDD [1295] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3480 { id="cluster_3480"; isCluster="true"; label="WholeStageCodegen (10)"; 1296 [id="node_1296" labelType="html" label="MapPartitionsRDD [1296] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3479 { id="cluster_3479"; isCluster="true"; label="ObjectHashAggregate"; 1297 [id="node_1297" labelType="html" label="MapPartitionsRDD [1297] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3478 { id="cluster_3478"; isCluster="true"; label="Exchange"; 1298 [id="node_1298" labelType="html" label="MapPartitionsRDD [1298] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1194->1195; 1201->1202; 1205->1208; 1202->1212; 1208->1212; 1212->1215; 1218->1219; 1215->1220; 1219->1220; 1220->1221; 1221->1222; 1222->1223; 1242->1245; 1195->1246; 1245->1246; 1246->1247; 1223->1248; 1248->1249; 1249->1250; 1250->1251; 1247->1252; 1251->1252; 1252->1253; 1253->1254; 1254->1293; 1293->1294; 1294->1295; 1295->1296; 1296->1297; 1297->1298; }

1193,1194

1200,1201

1204,1205

1217,1218

1241,1242

1223

1254

1205

1208

1212

1215

1218

1219

1220

1221

1222

1223

1242

1245

1246

1247

1248

1249

1250

1251

1252

1253

1254

1293

1294

1295

1296

1297

1298

digraph G { id="graph_867"; subgraph graph_stage_867 { id="graph_stage_867"; isCluster="true"; label="Stage 867 (skipped)"; subgraph cluster_3249 { id="cluster_3249"; isCluster="true"; label="Exchange"; 1194 [id="node_1194" labelType="html" label="ShuffledRowRDD [1194] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3246 { id="cluster_3246"; isCluster="true"; label="WholeStageCodegen (1)"; 1195 [id="node_1195" labelType="html" label="MapPartitionsRDD [1195] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3274 { id="cluster_3274"; isCluster="true"; label="Exchange"; 1201 [id="node_1201" labelType="html" label="ShuffledRowRDD [1201] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3271 { id="cluster_3271"; isCluster="true"; label="WholeStageCodegen (2)"; 1202 [id="node_1202" labelType="html" label="MapPartitionsRDD [1202] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3283 { id="cluster_3283"; isCluster="true"; label="Exchange"; 1205 [id="node_1205" labelType="html" label="ShuffledRowRDD [1205] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3280 { id="cluster_3280"; isCluster="true"; label="WholeStageCodegen (4)"; 1208 [id="node_1208" labelType="html" label="MapPartitionsRDD [1208] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3262 { id="cluster_3262"; isCluster="true"; label="WholeStageCodegen (5)"; 1212 [id="node_1212" labelType="html" label="ZippedPartitionsRDD2 [1212] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1215 [id="node_1215" labelType="html" label="MapPartitionsRDD [1215] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3292 { id="cluster_3292"; isCluster="true"; label="Exchange"; 1218 [id="node_1218" labelType="html" label="ShuffledRowRDD [1218] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3289 { id="cluster_3289"; isCluster="true"; label="WholeStageCodegen (7)"; 1219 [id="node_1219" labelType="html" label="MapPartitionsRDD [1219] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3258 { id="cluster_3258"; isCluster="true"; label="WholeStageCodegen (8)"; 1220 [id="node_1220" labelType="html" label="ZippedPartitionsRDD2 [1220] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1221 [id="node_1221" labelType="html" label="MapPartitionsRDD [1221] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3257 { id="cluster_3257"; isCluster="true"; label="InMemoryTableScan"; 1222 [id="node_1222" labelType="html" label="MapPartitionsRDD [1222] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1223 [id="node_1223" labelType="html" label="*(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#18776 AS qty#18778, demandChannel#18771, demandStream#18772, cachedKpis#18777 AS kpis#18779]\n+- *(8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#18775L, cachedShardId#18774], 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]... [1223] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3255 { id="cluster_3255"; isCluster="true"; label="Exchange"; 1242 [id="node_1242" labelType="html" label="ShuffledRowRDD [1242] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3252 { id="cluster_3252"; isCluster="true"; label="WholeStageCodegen (7)"; 1245 [id="node_1245" labelType="html" label="MapPartitionsRDD [1245] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3238 { id="cluster_3238"; isCluster="true"; label="WholeStageCodegen (8)"; 1246 [id="node_1246" labelType="html" label="ZippedPartitionsRDD2 [1246] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1247 [id="node_1247" labelType="html" label="MapPartitionsRDD [1247] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3325 { id="cluster_3325"; isCluster="true"; label="InMemoryTableScan"; 1248 [id="node_1248" labelType="html" label="MapPartitionsRDD [1248] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1249 [id="node_1249" labelType="html" label="MapPartitionsRDD [1249] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1250 [id="node_1250" labelType="html" label="MapPartitionsRDD [1250] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3322 { id="cluster_3322"; isCluster="true"; label="WholeStageCodegen (9)"; 1251 [id="node_1251" labelType="html" label="MapPartitionsRDD [1251] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3237 { id="cluster_3237"; isCluster="true"; label="Union"; 1252 [id="node_1252" labelType="html" label="UnionRDD [1252] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3236 { id="cluster_3236"; isCluster="true"; label="InMemoryTableScan"; 1253 [id="node_1253" labelType="html" label="MapPartitionsRDD [1253] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1254 [id="node_1254" labelType="html" label="Union\n:- *(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#19011, null AS demandStream#19012, [] AS kpis#19046, true AS isNewlyCalculated#19014]\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#19003, ), isnull(shardId#19003), coalesce(worklistShardItemId#19004L, 0), isnull(worklistShardItemId#19004L), coalesce(version#19005, 0), isnull(version#19005), coalesce(product#19006, ), isnull(product#19006), coalesce(plant#19007, ), isnull(plant#19007), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#18778, 0.0))), isnull(qty#18778)], LeftAnti\n: :- *(1) Sort [coalesce(shardId#445, ) ASC NUL... [1254] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3478 { id="cluster_3478"; isCluster="true"; label="Exchange"; 1299 [id="node_1299" labelType="html" label="ShuffledRowRDD [1299] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3477 { id="cluster_3477"; isCluster="true"; label="ObjectHashAggregate"; 1300 [id="node_1300" labelType="html" label="MapPartitionsRDD [1300] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3489 { id="cluster_3489"; isCluster="true"; label="InMemoryTableScan"; 1301 [id="node_1301" labelType="html" label="MapPartitionsRDD [1301] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1302 [id="node_1302" labelType="html" label="MapPartitionsRDD [1302] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1303 [id="node_1303" labelType="html" label="MapPartitionsRDD [1303] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3485 { id="cluster_3485"; isCluster="true"; label="WholeStageCodegen (11)"; 1304 [id="node_1304" labelType="html" label="MapPartitionsRDD [1304] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3476 { id="cluster_3476"; isCluster="true"; label="Union"; 1305 [id="node_1305" labelType="html" label="UnionRDD [1305] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3475 { id="cluster_3475"; isCluster="true"; label="Exchange"; 1306 [id="node_1306" labelType="html" label="MapPartitionsRDD [1306] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1194->1195; 1201->1202; 1205->1208; 1202->1212; 1208->1212; 1212->1215; 1218->1219; 1215->1220; 1219->1220; 1220->1221; 1221->1222; 1222->1223; 1242->1245; 1195->1246; 1245->1246; 1246->1247; 1223->1248; 1248->1249; 1249->1250; 1250->1251; 1247->1252; 1251->1252; 1252->1253; 1253->1254; 1299->1300; 1254->1301; 1301->1302; 1302->1303; 1303->1304; 1300->1305; 1304->1305; 1305->1306; }

1193,1194

1200,1201

1204,1205

1217,1218

1241,1242

1298,1299

1223

1254

1205

1208

1212

1215

1218

1219

1220

1221

1222

1223

1242

1245

1246

1247

1248

1249

1250

1251

1252

1253

1254

1299

1300

1301

1302

1303

1304

1305

1306

digraph G { id="graph_868"; subgraph graph_stage_868 { id="graph_stage_868"; isCluster="true"; label="Stage 868 (skipped)"; subgraph cluster_3431 { id="cluster_3431"; isCluster="true"; label="Exchange"; 1287 [id="node_1287" labelType="html" label="ShuffledRowRDD [1287] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3430 { id="cluster_3430"; isCluster="true"; label="ObjectHashAggregate"; 1288 [id="node_1288" labelType="html" label="MapPartitionsRDD [1288] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3429 { id="cluster_3429"; isCluster="true"; label="Project"; 1289 [id="node_1289" labelType="html" label="MapPartitionsRDD [1289] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3428 { id="cluster_3428"; isCluster="true"; label="Exchange"; 1290 [id="node_1290" labelType="html" label="MapPartitionsRDD [1290] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 1287->1288; 1288->1289; 1289->1290; }

1286,1287

digraph G { id="graph_869"; subgraph graph_stage_869 { id="graph_stage_869"; isCluster="true"; label="Stage 869 (skipped)"; subgraph cluster_3428 { id="cluster_3428"; isCluster="true"; label="Exchange"; 1291 [id="node_1291" labelType="html" label="ShuffledRowRDD [1291] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3425 { id="cluster_3425"; isCluster="true"; label="WholeStageCodegen (9)"; 1292 [id="node_1292" labelType="html" label="MapPartitionsRDD [1292] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3475 { id="cluster_3475"; isCluster="true"; label="Exchange"; 1307 [id="node_1307" labelType="html" label="ShuffledRowRDD [1307] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3472 { id="cluster_3472"; isCluster="true"; label="WholeStageCodegen (12)"; 1308 [id="node_1308" labelType="html" label="MapPartitionsRDD [1308] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3421 { id="cluster_3421"; isCluster="true"; label="WholeStageCodegen (13)"; 1309 [id="node_1309" labelType="html" label="ZippedPartitionsRDD2 [1309] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1310 [id="node_1310" labelType="html" label="MapPartitionsRDD [1310] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3420 { id="cluster_3420"; isCluster="true"; label="ObjectHashAggregate"; 1311 [id="node_1311" labelType="html" label="MapPartitionsRDD [1311] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3419 { id="cluster_3419"; isCluster="true"; label="Exchange"; 1312 [id="node_1312" labelType="html" label="MapPartitionsRDD [1312] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1291->1292; 1307->1308; 1292->1309; 1308->1309; 1309->1310; 1310->1311; 1311->1312; }

1290,1291

1306,1307

1307

1308

1309

1310

1311

1312

digraph G { id="graph_870"; subgraph graph_stage_870 { id="graph_stage_870"; isCluster="true"; label="Stage 870 (skipped)"; subgraph cluster_3249 { id="cluster_3249"; isCluster="true"; label="Exchange"; 1194 [id="node_1194" labelType="html" label="ShuffledRowRDD [1194] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3246 { id="cluster_3246"; isCluster="true"; label="WholeStageCodegen (1)"; 1195 [id="node_1195" labelType="html" label="MapPartitionsRDD [1195] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3274 { id="cluster_3274"; isCluster="true"; label="Exchange"; 1201 [id="node_1201" labelType="html" label="ShuffledRowRDD [1201] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3271 { id="cluster_3271"; isCluster="true"; label="WholeStageCodegen (2)"; 1202 [id="node_1202" labelType="html" label="MapPartitionsRDD [1202] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3283 { id="cluster_3283"; isCluster="true"; label="Exchange"; 1205 [id="node_1205" labelType="html" label="ShuffledRowRDD [1205] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3280 { id="cluster_3280"; isCluster="true"; label="WholeStageCodegen (4)"; 1208 [id="node_1208" labelType="html" label="MapPartitionsRDD [1208] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3262 { id="cluster_3262"; isCluster="true"; label="WholeStageCodegen (5)"; 1212 [id="node_1212" labelType="html" label="ZippedPartitionsRDD2 [1212] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1215 [id="node_1215" labelType="html" label="MapPartitionsRDD [1215] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3292 { id="cluster_3292"; isCluster="true"; label="Exchange"; 1218 [id="node_1218" labelType="html" label="ShuffledRowRDD [1218] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3289 { id="cluster_3289"; isCluster="true"; label="WholeStageCodegen (7)"; 1219 [id="node_1219" labelType="html" label="MapPartitionsRDD [1219] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3258 { id="cluster_3258"; isCluster="true"; label="WholeStageCodegen (8)"; 1220 [id="node_1220" labelType="html" label="ZippedPartitionsRDD2 [1220] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1221 [id="node_1221" labelType="html" label="MapPartitionsRDD [1221] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3257 { id="cluster_3257"; isCluster="true"; label="InMemoryTableScan"; 1222 [id="node_1222" labelType="html" label="MapPartitionsRDD [1222] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1223 [id="node_1223" labelType="html" label="*(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#18776 AS qty#18778, demandChannel#18771, demandStream#18772, cachedKpis#18777 AS kpis#18779]\n+- *(8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#18775L, cachedShardId#18774], 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]... [1223] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3255 { id="cluster_3255"; isCluster="true"; label="Exchange"; 1242 [id="node_1242" labelType="html" label="ShuffledRowRDD [1242] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3252 { id="cluster_3252"; isCluster="true"; label="WholeStageCodegen (7)"; 1245 [id="node_1245" labelType="html" label="MapPartitionsRDD [1245] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3238 { id="cluster_3238"; isCluster="true"; label="WholeStageCodegen (8)"; 1246 [id="node_1246" labelType="html" label="ZippedPartitionsRDD2 [1246] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1247 [id="node_1247" labelType="html" label="MapPartitionsRDD [1247] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3325 { id="cluster_3325"; isCluster="true"; label="InMemoryTableScan"; 1248 [id="node_1248" labelType="html" label="MapPartitionsRDD [1248] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1249 [id="node_1249" labelType="html" label="MapPartitionsRDD [1249] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1250 [id="node_1250" labelType="html" label="MapPartitionsRDD [1250] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3322 { id="cluster_3322"; isCluster="true"; label="WholeStageCodegen (9)"; 1251 [id="node_1251" labelType="html" label="MapPartitionsRDD [1251] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3237 { id="cluster_3237"; isCluster="true"; label="Union"; 1252 [id="node_1252" labelType="html" label="UnionRDD [1252] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3236 { id="cluster_3236"; isCluster="true"; label="InMemoryTableScan"; 1253 [id="node_1253" labelType="html" label="MapPartitionsRDD [1253] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1254 [id="node_1254" labelType="html" label="Union\n:- *(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#19011, null AS demandStream#19012, [] AS kpis#19046, true AS isNewlyCalculated#19014]\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#19003, ), isnull(shardId#19003), coalesce(worklistShardItemId#19004L, 0), isnull(worklistShardItemId#19004L), coalesce(version#19005, 0), isnull(version#19005), coalesce(product#19006, ), isnull(product#19006), coalesce(plant#19007, ), isnull(plant#19007), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#18778, 0.0))), isnull(qty#18778)], LeftAnti\n: :- *(1) Sort [coalesce(shardId#445, ) ASC NUL... [1254] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3601 { id="cluster_3601"; isCluster="true"; label="InMemoryTableScan"; 1342 [id="node_1342" labelType="html" label="MapPartitionsRDD [1342] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1343 [id="node_1343" labelType="html" label="MapPartitionsRDD [1343] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1344 [id="node_1344" labelType="html" label="MapPartitionsRDD [1344] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3596 { id="cluster_3596"; isCluster="true"; label="WholeStageCodegen (4)"; 1345 [id="node_1345" labelType="html" label="MapPartitionsRDD [1345] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3595 { id="cluster_3595"; isCluster="true"; label="Exchange"; 1346 [id="node_1346" labelType="html" label="MapPartitionsRDD [1346] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1194->1195; 1201->1202; 1205->1208; 1202->1212; 1208->1212; 1212->1215; 1218->1219; 1215->1220; 1219->1220; 1220->1221; 1221->1222; 1222->1223; 1242->1245; 1195->1246; 1245->1246; 1246->1247; 1223->1248; 1248->1249; 1249->1250; 1250->1251; 1247->1252; 1251->1252; 1252->1253; 1253->1254; 1254->1342; 1342->1343; 1343->1344; 1344->1345; 1345->1346; }

1193,1194

1200,1201

1204,1205

1217,1218

1241,1242

1223

1254

1205

1208

1212

1215

1218

1219

1220

1221

1222

1223

1242

1245

1246

1247

1248

1249

1250

1251

1252

1253

1254

1342

1343

1344

1345

1346

digraph G { id="graph_871"; subgraph graph_stage_871 { id="graph_stage_871"; isCluster="true"; label="Stage 871 (skipped)"; subgraph cluster_3595 { id="cluster_3595"; isCluster="true"; label="Exchange"; 1347 [id="node_1347" labelType="html" label="ShuffledRowRDD [1347] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3592 { id="cluster_3592"; isCluster="true"; label="WholeStageCodegen (5)"; 1348 [id="node_1348" labelType="html" label="MapPartitionsRDD [1348] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3591 { id="cluster_3591"; isCluster="true"; label="Exchange"; 1349 [id="node_1349" labelType="html" label="MapPartitionsRDD [1349] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1347->1348; 1348->1349; }

1346,1347

1347

1348

1349

digraph G { id="graph_872"; subgraph graph_stage_872 { id="graph_stage_872"; isCluster="true"; label="Stage 872 (skipped)"; 1318 [id="node_1318" labelType="html" label="SQLExecutionRDD [1318] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_3419 { id="cluster_3419"; isCluster="true"; label="Exchange"; 1313 [id="node_1313" labelType="html" label="ShuffledRowRDD [1313] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3418 { id="cluster_3418"; isCluster="true"; label="ObjectHashAggregate"; 1314 [id="node_1314" labelType="html" label="MapPartitionsRDD [1314] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3329 { id="cluster_3329"; isCluster="true"; label="WholeStageCodegen (16)"; 1315 [id="node_1315" labelType="html" label="MapPartitionsRDD [1315] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3224 { id="cluster_3224"; isCluster="true"; label="DeserializeToObject"; 1316 [id="node_1316" labelType="html" label="MapPartitionsRDD [1316] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3216 { id="cluster_3216"; isCluster="true"; label="MapPartitions"; 1317 [id="node_1317" labelType="html" label="MapPartitionsRDD [1317] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3490 { id="cluster_3490"; isCluster="true"; label="mapPartitions"; 1319 [id="node_1319" labelType="html" label="MapPartitionsRDD [1319] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3572 { id="cluster_3572"; isCluster="true"; label="Scan"; 1320 [id="node_1320" labelType="html" label="MapPartitionsRDD [1320] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3566 { id="cluster_3566"; isCluster="true"; label="WholeStageCodegen (1)"; 1321 [id="node_1321" labelType="html" label="MapPartitionsRDD [1321] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3565 { id="cluster_3565"; isCluster="true"; label="InMemoryTableScan"; 1322 [id="node_1322" labelType="html" label="MapPartitionsRDD [1322] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1323 [id="node_1323" labelType="html" label="*(1) Generate explode(prodPlantResults#21554), false, [prodPlantResults#21561]\n+- *(1) Project [prodPlantResults#21554]\n +- *(1) Filter ((size(prodPlantResults#21554, true) > 0) AND isnotnull(prodPlantResults#21554))\n +- *(1) SerializeFromObject [mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement)))) null else named_struct(measuredUnit, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true)... [1323] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1324 [id="node_1324" labelType="html" label="MapPartitionsRDD [1324] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1325 [id="node_1325" labelType="html" label="MapPartitionsRDD [1325] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1326 [id="node_1326" labelType="html" label="MapPartitionsRDD [1326] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3564 { id="cluster_3564"; isCluster="true"; label="Project"; 1327 [id="node_1327" labelType="html" label="MapPartitionsRDD [1327] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3579 { id="cluster_3579"; isCluster="true"; label="InMemoryTableScan"; 1328 [id="node_1328" labelType="html" label="MapPartitionsRDD [1328] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1329 [id="node_1329" labelType="html" label="MapPartitionsRDD [1329] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1330 [id="node_1330" labelType="html" label="MapPartitionsRDD [1330] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3574 { id="cluster_3574"; isCluster="true"; label="WholeStageCodegen (1)"; 1331 [id="node_1331" labelType="html" label="MapPartitionsRDD [1331] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3573 { id="cluster_3573"; isCluster="true"; label="Project"; 1332 [id="node_1332" labelType="html" label="MapPartitionsRDD [1332] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3586 { id="cluster_3586"; isCluster="true"; label="InMemoryTableScan"; 1333 [id="node_1333" labelType="html" label="MapPartitionsRDD [1333] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1334 [id="node_1334" labelType="html" label="MapPartitionsRDD [1334] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1335 [id="node_1335" labelType="html" label="MapPartitionsRDD [1335] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3581 { id="cluster_3581"; isCluster="true"; label="WholeStageCodegen (2)"; 1336 [id="node_1336" labelType="html" label="MapPartitionsRDD [1336] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3580 { id="cluster_3580"; isCluster="true"; label="Project"; 1337 [id="node_1337" labelType="html" label="MapPartitionsRDD [1337] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3563 { id="cluster_3563"; isCluster="true"; label="Union"; 1338 [id="node_1338" labelType="html" label="UnionRDD [1338] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3562 { id="cluster_3562"; isCluster="true"; label="Exchange"; 1339 [id="node_1339" labelType="html" label="MapPartitionsRDD [1339] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1313->1314; 1314->1315; 1315->1316; 1316->1317; 1317->1318; 1318->1319; 1319->1320; 1320->1321; 1321->1322; 1322->1323; 1323->1324; 1324->1325; 1325->1326; 1326->1327; 1323->1328; 1328->1329; 1329->1330; 1330->1331; 1331->1332; 1323->1333; 1333->1334; 1334->1335; 1335->1336; 1336->1337; 1327->1338; 1332->1338; 1337->1338; 1338->1339; }

1312,1313

1319

1323

1318

1313

1314

1315

1316

1317

1319

1320

1321

1322

1323

1324

1325

1326

1327

1328

1329

1330

1331

1332

1333

1334

1335

1336

1337

1338

1339

digraph G { id="graph_873"; subgraph graph_stage_873 { id="graph_stage_873"; isCluster="true"; label="Stage 873 (skipped)"; subgraph cluster_3562 { id="cluster_3562"; isCluster="true"; label="Exchange"; 1340 [id="node_1340" labelType="html" label="ShuffledRowRDD [1340] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3559 { id="cluster_3559"; isCluster="true"; label="WholeStageCodegen (3)"; 1341 [id="node_1341" labelType="html" label="MapPartitionsRDD [1341] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3591 { id="cluster_3591"; isCluster="true"; label="Exchange"; 1350 [id="node_1350" labelType="html" label="ShuffledRowRDD [1350] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3588 { id="cluster_3588"; isCluster="true"; label="WholeStageCodegen (6)"; 1351 [id="node_1351" labelType="html" label="MapPartitionsRDD [1351] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3554 { id="cluster_3554"; isCluster="true"; label="WholeStageCodegen (7)"; 1352 [id="node_1352" labelType="html" label="ZippedPartitionsRDD2 [1352] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1353 [id="node_1353" labelType="html" label="MapPartitionsRDD [1353] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3553 { id="cluster_3553"; isCluster="true"; label="SortAggregate"; 1354 [id="node_1354" labelType="html" label="MapPartitionsRDD [1354] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3552 { id="cluster_3552"; isCluster="true"; label="Exchange"; 1355 [id="node_1355" labelType="html" label="MapPartitionsRDD [1355] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1340->1341; 1350->1351; 1341->1352; 1351->1352; 1352->1353; 1353->1354; 1354->1355; }

1339,1340

1349,1350

1340

1341

1350

1351

1352

1353

1354

1355

digraph G { id="graph_874"; subgraph graph_stage_874 { id="graph_stage_874"; isCluster="true"; label="Stage 874"; 1371 [id="node_1371" labelType="html" label="SQLExecutionRDD [1371] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_3016 { id="cluster_3016"; isCluster="true"; label="repartition"; 1105 [id="node_1105" labelType="html" label="ShuffledRDD [1105] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1106 [id="node_1106" labelType="html" label="CoalescedRDD [1106] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1107 [id="node_1107" labelType="html" label="MapPartitionsRDD [1107] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3552 { id="cluster_3552"; isCluster="true"; label="Exchange"; 1356 [id="node_1356" labelType="html" label="ShuffledRowRDD [1356] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3549 { id="cluster_3549"; isCluster="true"; label="WholeStageCodegen (8)"; 1357 [id="node_1357" labelType="html" label="MapPartitionsRDD [1357] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3548 { id="cluster_3548"; isCluster="true"; label="SortAggregate"; 1358 [id="node_1358" labelType="html" label="MapPartitionsRDD [1358] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3547 { id="cluster_3547"; isCluster="true"; label="InMemoryTableScan"; 1359 [id="node_1359" labelType="html" label="MapPartitionsRDD [1359] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1360 [id="node_1360" labelType="html" label="SortAggregate(key=[demandChannel#21587, shardId#445, qty#21607, worklistShardItemId#446L, demandStream#21588], functions=[first(kpis#21616, false)], output=[shardId#445, worklistShardItemId#446L, qty#21607, demandChannel#21587, demandStream#21588, kpis#21749])\n+- *(8) Sort [demandChannel#21587 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, qty#21607 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#21588 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#21587, shardId#445, qty#21607, worklistShardItemId#446L, demandStream#21588, 37), ENSURE_REQUIREMENTS, [plan_id=116966]\n +- SortAggregate(key=[demandChannel#21587, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#21607)) AS qty#21607, worklistShardItemId#446L, demandStream#21588], functions=[partial_first(kpis#21616, false)], output=[demandChannel#21587, shardId#445, qty#21607, worklistShardItemId#446L, demandStream#21588, first#21825, valueSet#21826])\n +- *(7) Sort [demandChannel#215... [1360] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3655 { id="cluster_3655"; isCluster="true"; label="InMemoryTableScan"; 1367 [id="node_1367" labelType="html" label="MapPartitionsRDD [1367] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1368 [id="node_1368" labelType="html" label="MapPartitionsRDD [1368] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1369 [id="node_1369" labelType="html" label="MapPartitionsRDD [1369] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3654 { id="cluster_3654"; isCluster="true"; label="DeserializeToObject"; 1370 [id="node_1370" labelType="html" label="MapPartitionsRDD [1370] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3656 { id="cluster_3656"; isCluster="true"; label="mapPartitions"; 1372 [id="node_1372" labelType="html" label="MapPartitionsRDD [1372] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3676 { id="cluster_3676"; isCluster="true"; label="union"; 1381 [id="node_1381" labelType="html" label="UnionRDD [1381] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3677 { id="cluster_3677"; isCluster="true"; label="filter"; 1382 [id="node_1382" labelType="html" label="MapPartitionsRDD [1382] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3678 { id="cluster_3678"; isCluster="true"; label="distinct"; 1383 [id="node_1383" labelType="html" label="MapPartitionsRDD [1383] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1105->1106; 1106->1107; 1356->1357; 1357->1358; 1358->1359; 1359->1360; 1360->1367; 1367->1368; 1368->1369; 1369->1370; 1370->1371; 1371->1372; 1107->1381; 1372->1381; 1381->1382; 1382->1383; }

1104,1105

1355,1356

1107

1360

1371

1105

1106

1107

1356

1357

1358

1359

1360

1367

1368

1369

1370

1372

1381

1382

1383

digraph G { id="graph_875"; subgraph graph_stage_875 { id="graph_stage_875"; isCluster="true"; label="Stage 875"; subgraph cluster_3678 { id="cluster_3678"; isCluster="true"; label="distinct"; 1384 [id="node_1384" labelType="html" label="ShuffledRDD [1384] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1385 [id="node_1385" labelType="html" label="MapPartitionsRDD [1385] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3679 { id="cluster_3679"; isCluster="true"; label="repartition"; 1386 [id="node_1386" labelType="html" label="MapPartitionsRDD [1386] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1384->1385; 1385->1386; }

1383,1384

1384

1385

1386

digraph G { id="graph_876"; subgraph graph_stage_876 { id="graph_stage_876"; isCluster="true"; label="Stage 876"; subgraph cluster_3679 { id="cluster_3679"; isCluster="true"; label="repartition"; 1387 [id="node_1387" labelType="html" label="ShuffledRDD [1387] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1388 [id="node_1388" labelType="html" label="CoalescedRDD [1388] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1389 [id="node_1389" labelType="html" label="MapPartitionsRDD [1389] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1387->1388; 1388->1389; }

1386,1387

1389

1387

1388

1389

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Shuffle Read	Shuffle Write
876	tenants-pool-506	stream-10000000004-1 id = 0ca74851-d945-4eb8-90f7-ea42a7110a4d runId = c871ced2-19a8-473b-bfe1-6d8b64ffe1bc batch = 2 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:43:30	0.8 s	37/37		2.9 MiB
875	tenants-pool-506	stream-10000000004-1 id = 0ca74851-d945-4eb8-90f7-ea42a7110a4d runId = c871ced2-19a8-473b-bfe1-6d8b64ffe1bc batch = 2 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:42:45	45 s	74/74		2.7 MiB	2.9 MiB
874	tenants-pool-506	stream-10000000004-1 id = 0ca74851-d945-4eb8-90f7-ea42a7110a4d runId = c871ced2-19a8-473b-bfe1-6d8b64ffe1bc batch = 2 start at FileStorageAdapterImpl.java:171 +details RDD: SortAggregate(key=[demandChannel#21587, shardId#445, qty#21607, worklistShardItemId#446L, demandStream#21588], functions=[first(kpis#21616, false)], output=[shardId#445, worklistShardItemId#446L, qty#21607, demandChannel#21587, demandStream#21588, kpis#21749]) +- (8) Sort [demandChannel#21587 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, qty#21607 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#21588 ASC NULLS FIRST], false, 0 +- Exchange hashpartitioning(demandChannel#21587, shardId#445, qty#21607, worklistShardItemId#446L, demandStream#21588, 37), ENSURE_REQUIREMENTS, [plan_id=116966] +- SortAggregate(key=[demandChannel#21587, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#21607)) AS qty#21607, worklistShardItemId#446L, demandStream#21588], functions=[partial_first(kpis#21616, false)], output=[demandChannel#21587, shardId#445, qty#21607, worklistShardItemId#446L, demandStream#21588, first#21825, valueSet#21826]) +- (7) Sort [demandChannel#215... 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:42:44	1 s	74/74	1325.6 KiB		2.7 MiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

876

tenants-pool-506

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

0.8 s

37/37

2.9 MiB

875

tenants-pool-506

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

45 s

74/74

2.7 MiB

2.9 MiB

874

tenants-pool-506

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

RDD: SortAggregate(key=[demandChannel#21587, shardId#445, qty#21607, worklistShardItemId#446L, demandStream#21588], functions=[first(kpis#21616, false)], output=[shardId#445, worklistShardItemId#446L, qty#21607, demandChannel#21587, demandStream#21588, kpis#21749]) +- *(8) Sort [demandChannel#21587 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, qty#21607 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#21588 ASC NULLS FIRST], false, 0 +- Exchange hashpartitioning(demandChannel#21587, shardId#445, qty#21607, worklistShardItemId#446L, demandStream#21588, 37), ENSURE_REQUIREMENTS, [plan_id=116966] +- SortAggregate(key=[demandChannel#21587, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#21607)) AS qty#21607, worklistShardItemId#446L, demandStream#21588], functions=[partial_first(kpis#21616, false)], output=[demandChannel#21587, shardId#445, qty#21607, worklistShardItemId#446L, demandStream#21588, first#21825, valueSet#21826]) +- *(7) Sort [demandChannel#215...

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:42:44

1 s

74/74

1325.6 KiB

2.7 MiB

Page:

Skipped Stages (40)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
873	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
872	default	start at FileStorageAdapterImpl.java:171 +details RDD: MapPartitionsRDD (1) Generate explode(prodPlantResults#21554), false, [prodPlantResults#21561] +- (1) Project [prodPlantResults#21554] +- (1) Filter ((size(prodPlantResults#21554, true) > 0) AND isnotnull(prodPlantResults#21554)) +- (1) SerializeFromObject [mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement)))) null else named_struct(measuredUnit, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true)... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/111
871	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
870	default	start at FileStorageAdapterImpl.java:171 +details RDD: (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#18776 AS qty#18778, demandChannel#18771, demandStream#18772, cachedKpis#18777 AS kpis#18779] +- (8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#18775L, cachedShardId#18774], 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#19011, null AS demandStream#19012, [] AS kpis#19046, true AS isNewlyCalculated#19014] : +- (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#19003, ), isnull(shardId#19003), coalesce(worklistShardItemId#19004L, 0), isnull(worklistShardItemId#19004L), coalesce(version#19005, 0), isnull(version#19005), coalesce(product#19006, ), isnull(product#19006), coalesce(plant#19007, ), isnull(plant#19007), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#18778, 0.0))), isnull(qty#18778)], LeftAnti : :- (1) Sort [coalesce(shardId#445, ) ASC NUL... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/74
869	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
868	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
867	default	start at FileStorageAdapterImpl.java:171 +details RDD: (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#18776 AS qty#18778, demandChannel#18771, demandStream#18772, cachedKpis#18777 AS kpis#18779] +- (8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#18775L, cachedShardId#18774], 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#19011, null AS demandStream#19012, [] AS kpis#19046, true AS isNewlyCalculated#19014] : +- (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#19003, ), isnull(shardId#19003), coalesce(worklistShardItemId#19004L, 0), isnull(worklistShardItemId#19004L), coalesce(version#19005, 0), isnull(version#19005), coalesce(product#19006, ), isnull(product#19006), coalesce(plant#19007, ), isnull(plant#19007), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#18778, 0.0))), isnull(qty#18778)], LeftAnti : :- (1) Sort [coalesce(shardId#445, ) ASC NUL... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/111
866	default	start at FileStorageAdapterImpl.java:171 +details RDD: (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#18776 AS qty#18778, demandChannel#18771, demandStream#18772, cachedKpis#18777 AS kpis#18779] +- (8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#18775L, cachedShardId#18774], 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#19011, null AS demandStream#19012, [] AS kpis#19046, true AS isNewlyCalculated#19014] : +- (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#19003, ), isnull(shardId#19003), coalesce(worklistShardItemId#19004L, 0), isnull(worklistShardItemId#19004L), coalesce(version#19005, 0), isnull(version#19005), coalesce(product#19006, ), isnull(product#19006), coalesce(plant#19007, ), isnull(plant#19007), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#18778, 0.0))), isnull(qty#18778)], LeftAnti : :- (1) Sort [coalesce(shardId#445, ) ASC NUL... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/74
865	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
864	default	start at FileStorageAdapterImpl.java:171 +details RDD: (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#18776 AS qty#18778, demandChannel#18771, demandStream#18772, cachedKpis#18777 AS kpis#18779] +- (8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#18775L, cachedShardId#18774], 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
863	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
862	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
861	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
860	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
859	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
858	default	start at FileStorageAdapterImpl.java:171 +details RDD: SortAggregate(key=[demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990], functions=[first(kpis#16018, false)], output=[shardId#445, worklistShardItemId#446L, qty#16009, demandChannel#15989, demandStream#15990, kpis#16151]) +- (8) Sort [demandChannel#15989 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, qty#16009 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#15990 ASC NULLS FIRST], false, 0 +- Exchange hashpartitioning(demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990, 37), ENSURE_REQUIREMENTS, [plan_id=115377] +- SortAggregate(key=[demandChannel#15989, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#16009)) AS qty#16009, worklistShardItemId#446L, demandStream#15990], functions=[partial_first(kpis#16018, false)], output=[demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990, first#16227, valueSet#16228]) +- (7) Sort [demandChannel#159... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
857	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
856	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
855	default	start at FileStorageAdapterImpl.java:171 +details RDD: MapPartitionsRDD (1) Generate explode(prodPlantResults#15956), false, [prodPlantResults#15963] +- (1) Project [prodPlantResults#15956] +- (1) Filter ((size(prodPlantResults#15956, true) > 0) AND isnotnull(prodPlantResults#15956)) +- (1) SerializeFromObject [mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement)))) null else named_struct(measuredUnit, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true)... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/111
854	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
853	default	start at FileStorageAdapterImpl.java:171 +details RDD: (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#13010 AS qty#13012, demandChannel#13005, demandStream#13006, cachedKpis#13011 AS kpis#13013] +- (8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#13009L, cachedShardId#13008], Inner :- (5) Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0 : +- (5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]) : +- (5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448]) : +- (5) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449] : +- (5) SortMergeJoin [worklistShardItemId#446L, shardId#445]...Union :- (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#13245, null AS demandStream#13246, [] AS kpis#13280, true AS isNewlyCalculated#13248] : +- (8) SortMergeJoin [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)], [coalesce(shardId#13237, ), isnull(shardId#13237), coalesce(worklistShardItemId#13238L, 0), isnull(worklistShardItemId#13238L), coalesce(version#13239, 0), isnull(version#13239), coalesce(product#13240, ), isnull(product#13240), coalesce(plant#13241, ), isnull(plant#13241), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#13012, 0.0))), isnull(qty#13012)], LeftAnti : :- (1) Sort [coalesce(shardId#445, ) ASC NUL... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/111
852	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
851	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
850	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
849	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
848	default	start at FileStorageAdapterImpl.java:171 +details RDD: (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#13010 AS qty#13012, demandChannel#13005, demandStream#13006, cachedKpis#13011 AS kpis#13013] +- (8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#13009L, cachedShardId#13008], Inner :- (5) Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0 : +- (5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]) : +- (5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448]) : +- (5) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449] : +- (5) SortMergeJoin [worklistShardItemId#446L, shardId#445]...Union :- (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#13245, null AS demandStream#13246, [] AS kpis#13280, true AS isNewlyCalculated#13248] : +- (8) SortMergeJoin [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)], [coalesce(shardId#13237, ), isnull(shardId#13237), coalesce(worklistShardItemId#13238L, 0), isnull(worklistShardItemId#13238L), coalesce(version#13239, 0), isnull(version#13239), coalesce(product#13240, ), isnull(product#13240), coalesce(plant#13241, ), isnull(plant#13241), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#13012, 0.0))), isnull(qty#13012)], LeftAnti : :- (1) Sort [coalesce(shardId#445, ) ASC NUL... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/74
847	default	start at FileStorageAdapterImpl.java:171 +details RDD: (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#13010 AS qty#13012, demandChannel#13005, demandStream#13006, cachedKpis#13011 AS kpis#13013] +- (8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#13009L, cachedShardId#13008], Inner :- (5) Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0 : +- (5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]) : +- (5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448]) : +- (5) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449] : +- (5) SortMergeJoin [worklistShardItemId#446L, shardId#445]...Union :- (8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#13245, null AS demandStream#13246, [] AS kpis#13280, true AS isNewlyCalculated#13248] : +- (8) SortMergeJoin [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)], [coalesce(shardId#13237, ), isnull(shardId#13237), coalesce(worklistShardItemId#13238L, 0), isnull(worklistShardItemId#13238L), coalesce(version#13239, 0), isnull(version#13239), coalesce(product#13240, ), isnull(product#13240), coalesce(plant#13241, ), isnull(plant#13241), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#13012, 0.0))), isnull(qty#13012)], LeftAnti : :- (1) Sort [coalesce(shardId#445, ) ASC NUL... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/74
846	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
845	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
844	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
843	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
842	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
841	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
840	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
839	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
838	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
837	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
836	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
835	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
834	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: