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

Status: SUCCEEDED
Submitted: 2026/04/20 06:42:43
Duration: 0.2 s
Associated SQL Query: 97
Job Group: c871ced2-19a8-473b-bfe1-6d8b64ffe1bc
Completed Stages: 2
Skipped Stages: 40

Enable zooming

digraph G { id="graph_792"; subgraph graph_stage_792 { id="graph_stage_792"; isCluster="true"; label="Stage 792 (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_793"; subgraph graph_stage_793 { id="graph_stage_793"; isCluster="true"; label="Stage 793 (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_794"; subgraph graph_stage_794 { id="graph_stage_794"; isCluster="true"; label="Stage 794 (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_795"; subgraph graph_stage_795 { id="graph_stage_795"; isCluster="true"; label="Stage 795 (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_796"; subgraph graph_stage_796 { id="graph_stage_796"; isCluster="true"; label="Stage 796 (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_797"; subgraph graph_stage_797 { id="graph_stage_797"; isCluster="true"; label="Stage 797 (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_798"; subgraph graph_stage_798 { id="graph_stage_798"; isCluster="true"; label="Stage 798 (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_799"; subgraph graph_stage_799 { id="graph_stage_799"; isCluster="true"; label="Stage 799 (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_800"; subgraph graph_stage_800 { id="graph_stage_800"; isCluster="true"; label="Stage 800 (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_801"; subgraph graph_stage_801 { id="graph_stage_801"; isCluster="true"; label="Stage 801 (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_802"; subgraph graph_stage_802 { id="graph_stage_802"; isCluster="true"; label="Stage 802 (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_803"; subgraph graph_stage_803 { id="graph_stage_803"; isCluster="true"; label="Stage 803 (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_804"; subgraph graph_stage_804 { id="graph_stage_804"; isCluster="true"; label="Stage 804 (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_805"; subgraph graph_stage_805 { id="graph_stage_805"; isCluster="true"; label="Stage 805 (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_806"; subgraph graph_stage_806 { id="graph_stage_806"; isCluster="true"; label="Stage 806 (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_807"; subgraph graph_stage_807 { id="graph_stage_807"; isCluster="true"; label="Stage 807 (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_808"; subgraph graph_stage_808 { id="graph_stage_808"; isCluster="true"; label="Stage 808 (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_809"; subgraph graph_stage_809 { id="graph_stage_809"; isCluster="true"; label="Stage 809 (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_810"; subgraph graph_stage_810 { id="graph_stage_810"; isCluster="true"; label="Stage 810 (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_811"; subgraph graph_stage_811 { id="graph_stage_811"; isCluster="true"; label="Stage 811 (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_812"; subgraph graph_stage_812 { id="graph_stage_812"; isCluster="true"; label="Stage 812 (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_813"; subgraph graph_stage_813 { id="graph_stage_813"; isCluster="true"; label="Stage 813 (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_814"; subgraph graph_stage_814 { id="graph_stage_814"; isCluster="true"; label="Stage 814 (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_815"; subgraph graph_stage_815 { id="graph_stage_815"; isCluster="true"; label="Stage 815 (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_816"; subgraph graph_stage_816 { id="graph_stage_816"; isCluster="true"; label="Stage 816 (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_817"; subgraph graph_stage_817 { id="graph_stage_817"; isCluster="true"; label="Stage 817 (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_818"; subgraph graph_stage_818 { id="graph_stage_818"; isCluster="true"; label="Stage 818 (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_819"; subgraph graph_stage_819 { id="graph_stage_819"; isCluster="true"; label="Stage 819 (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_820"; subgraph graph_stage_820 { id="graph_stage_820"; isCluster="true"; label="Stage 820 (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_821"; subgraph graph_stage_821 { id="graph_stage_821"; isCluster="true"; label="Stage 821 (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_822"; subgraph graph_stage_822 { id="graph_stage_822"; isCluster="true"; label="Stage 822 (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_823"; subgraph graph_stage_823 { id="graph_stage_823"; isCluster="true"; label="Stage 823 (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_824"; subgraph graph_stage_824 { id="graph_stage_824"; isCluster="true"; label="Stage 824 (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_825"; subgraph graph_stage_825 { id="graph_stage_825"; isCluster="true"; label="Stage 825 (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_826"; subgraph graph_stage_826 { id="graph_stage_826"; isCluster="true"; label="Stage 826 (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_827"; subgraph graph_stage_827 { id="graph_stage_827"; isCluster="true"; label="Stage 827 (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_828"; subgraph graph_stage_828 { id="graph_stage_828"; isCluster="true"; label="Stage 828 (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_829"; subgraph graph_stage_829 { id="graph_stage_829"; isCluster="true"; label="Stage 829 (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_830"; subgraph graph_stage_830 { id="graph_stage_830"; isCluster="true"; label="Stage 830 (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_831"; subgraph graph_stage_831 { id="graph_stage_831"; isCluster="true"; label="Stage 831 (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_832"; subgraph graph_stage_832 { id="graph_stage_832"; isCluster="true"; label="Stage 832"; 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_3664 { id="cluster_3664"; isCluster="true"; label="InMemoryTableScan"; 1373 [id="node_1373" labelType="html" label="MapPartitionsRDD [1373] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1374 [id="node_1374" labelType="html" label="MapPartitionsRDD [1374] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 1375 [id="node_1375" labelType="html" label="MapPartitionsRDD [1375] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3661 { id="cluster_3661"; isCluster="true"; label="WholeStageCodegen (1)"; 1376 [id="node_1376" labelType="html" label="MapPartitionsRDD [1376] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3660 { id="cluster_3660"; isCluster="true"; label="Exchange"; 1377 [id="node_1377" labelType="html" label="MapPartitionsRDD [1377] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1356->1357; 1357->1358; 1358->1359; 1359->1360; 1360->1373; 1373->1374; 1374->1375; 1375->1376; 1376->1377; }

1355,1356

1360

1356

1357

1358

1359

1360

1373

1374

1375

1376

1377

digraph G { id="graph_833"; subgraph graph_stage_833 { id="graph_stage_833"; isCluster="true"; label="Stage 833"; subgraph cluster_3660 { id="cluster_3660"; isCluster="true"; label="Exchange"; 1378 [id="node_1378" labelType="html" label="ShuffledRowRDD [1378] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3657 { id="cluster_3657"; isCluster="true"; label="WholeStageCodegen (2)"; 1379 [id="node_1379" labelType="html" label="MapPartitionsRDD [1379] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3665 { id="cluster_3665"; isCluster="true"; label="mapPartitionsInternal"; 1380 [id="node_1380" labelType="html" label="MapPartitionsRDD [1380] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 1378->1379; 1379->1380; }

1377,1378

1378

1379

1380

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
833	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:44	59 ms	37/37
832	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:43	0.1 s	37/37	777.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

833

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

59 ms

37/37

832

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

0.1 s

37/37

777.0 B

Page:

Skipped Stages (40)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
831	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
830	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
829	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
828	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
827	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
826	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
825	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
824	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
823	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
822	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
821	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
820	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
819	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
818	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
817	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
816	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
815	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
814	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
813	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
812	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
811	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
810	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
809	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
808	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
807	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
806	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
805	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
804	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
803	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
802	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
801	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
800	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
799	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
798	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
797	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
796	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
795	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
794	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
793	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
792	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: