crp-order-qty-opt-service - Details for Job 81199

Status: SUCCEEDED
Submitted: 2026/09/02 11:08:53
Duration: 43 ms
Completed Stages: 1
Skipped Stages: 26

Enable zooming

digraph G { id="graph_1521333"; subgraph graph_stage_1521333 { id="graph_stage_1521333"; isCluster="true"; label="Stage 1521333 (skipped)"; 667559 [id="node_667559" labelType="html" label="SQLExecutionRDD [667559] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1673971 { id="cluster_1673971"; isCluster="true"; label="Scan parquet "; 667556 [id="node_667556" labelType="html" label="FileScanRDD [667556] start at FileStorageAdapterImpl.java:596}"]; 667557 [id="node_667557" labelType="html" label="MapPartitionsRDD [667557] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673968 { id="cluster_1673968"; isCluster="true"; label="WholeStageCodegen (1)"; 667558 [id="node_667558" labelType="html" label="MapPartitionsRDD [667558] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673986 { id="cluster_1673986"; isCluster="true"; label="WholeStageCodegen (1)"; 667560 [id="node_667560" labelType="html" label="MapPartitionsRDD [667560] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673985 { id="cluster_1673985"; isCluster="true"; label="HashAggregate"; 667561 [id="node_667561" labelType="html" label="MapPartitionsRDD [667561] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673984 { id="cluster_1673984"; isCluster="true"; label="Exchange"; 667562 [id="node_667562" labelType="html" label="MapPartitionsRDD [667562] start at FileStorageAdapterImpl.java:596}"]; } } 667556->667557; 667557->667558; 667558->667559; 667559->667560; 667560->667561; 667561->667562; }

digraph G { id="graph_1521334"; subgraph graph_stage_1521334 { id="graph_stage_1521334"; isCluster="true"; label="Stage 1521334 (skipped)"; 664202 [id="node_664202" labelType="html" label="SQLExecutionRDD [664202] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1665494 { id="cluster_1665494"; isCluster="true"; label="map"; 664178 [id="node_664178" labelType="html" label="MapPartitionsRDD [664178] [Cached] [Indeterminate] map at PeriodicAsyncRDDCheckpointWriterImpl.java:207}"]; } subgraph cluster_1665558 { id="cluster_1665558"; isCluster="true"; label="checkpoint"; 664198 [id="node_664198" labelType="html" label="LocalCheckpointRDD [664198] count at KpiCurveCacheImpl.java:255}"]; } subgraph cluster_1665559 { id="cluster_1665559"; isCluster="true"; label="map"; 664199 [id="node_664199" labelType="html" label="MapPartitionsRDD [664199] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1665561 { id="cluster_1665561"; isCluster="true"; label="WholeStageCodegen (1)"; 664200 [id="node_664200" labelType="html" label="MapPartitionsRDD [664200] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1665560 { id="cluster_1665560"; isCluster="true"; label="DeserializeToObject"; 664201 [id="node_664201" labelType="html" label="MapPartitionsRDD [664201] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1665564 { id="cluster_1665564"; isCluster="true"; label="mapPartitions"; 664203 [id="node_664203" labelType="html" label="MapPartitionsRDD [664203] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1665565 { id="cluster_1665565"; isCluster="true"; label="repartition"; 664204 [id="node_664204" labelType="html" label="MapPartitionsRDD [664204] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 664198->664178; 664178->664199; 664199->664200; 664200->664201; 664201->664202; 664202->664203; 664203->664204; }

664178

664202

664178

664199

664200

664201

664203

664204

digraph G { id="graph_1521335"; subgraph graph_stage_1521335 { id="graph_stage_1521335"; isCluster="true"; label="Stage 1521335 (skipped)"; 664909 [id="node_664909" labelType="html" label="SQLExecutionRDD [664909] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1667360 { id="cluster_1667360"; isCluster="true"; label="Scan parquet "; 664906 [id="node_664906" labelType="html" label="FileScanRDD [664906] start at FileStorageAdapterImpl.java:596}"]; 664907 [id="node_664907" labelType="html" label="MapPartitionsRDD [664907] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1667357 { id="cluster_1667357"; isCluster="true"; label="WholeStageCodegen (1)"; 664908 [id="node_664908" labelType="html" label="MapPartitionsRDD [664908] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1667375 { id="cluster_1667375"; isCluster="true"; label="WholeStageCodegen (1)"; 664910 [id="node_664910" labelType="html" label="MapPartitionsRDD [664910] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1667374 { id="cluster_1667374"; isCluster="true"; label="HashAggregate"; 664911 [id="node_664911" labelType="html" label="MapPartitionsRDD [664911] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1667373 { id="cluster_1667373"; isCluster="true"; label="Exchange"; 664912 [id="node_664912" labelType="html" label="MapPartitionsRDD [664912] start at FileStorageAdapterImpl.java:596}"]; } } 664906->664907; 664907->664908; 664908->664909; 664909->664910; 664910->664911; 664911->664912; }

digraph G { id="graph_1521336"; subgraph graph_stage_1521336 { id="graph_stage_1521336"; isCluster="true"; label="Stage 1521336 (skipped)"; subgraph cluster_1667373 { id="cluster_1667373"; isCluster="true"; label="Exchange"; 664913 [id="node_664913" labelType="html" label="ShuffledRowRDD [664913] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1667370 { id="cluster_1667370"; isCluster="true"; label="WholeStageCodegen (2)"; 664914 [id="node_664914" labelType="html" label="MapPartitionsRDD [664914] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1667369 { id="cluster_1667369"; isCluster="true"; label="Exchange"; 664915 [id="node_664915" labelType="html" label="MapPartitionsRDD [664915] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 664913->664914; 664914->664915; }

664912,664913

digraph G { id="graph_1521337"; subgraph graph_stage_1521337 { id="graph_stage_1521337"; isCluster="true"; label="Stage 1521337 (skipped)"; 664358 [id="node_664358" labelType="html" label="SQLExecutionRDD [664358] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; subgraph cluster_1665565 { id="cluster_1665565"; isCluster="true"; label="repartition"; 664205 [id="node_664205" labelType="html" label="ShuffledRDD [664205] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 664206 [id="node_664206" labelType="html" label="CoalescedRDD [664206] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 664207 [id="node_664207" labelType="html" label="MapPartitionsRDD [664207] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1665903 { id="cluster_1665903"; isCluster="true"; label="map"; 664355 [id="node_664355" labelType="html" label="MapPartitionsRDD [664355] [Indeterminate] createDataFrame at KpiCurveCacheImpl.java:230}"]; } subgraph cluster_1665905 { id="cluster_1665905"; isCluster="true"; label="WholeStageCodegen (1)"; 664356 [id="node_664356" labelType="html" label="MapPartitionsRDD [664356] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1665904 { id="cluster_1665904"; isCluster="true"; label="DeserializeToObject"; 664357 [id="node_664357" labelType="html" label="MapPartitionsRDD [664357] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1665908 { id="cluster_1665908"; isCluster="true"; label="mapPartitions"; 664359 [id="node_664359" labelType="html" label="MapPartitionsRDD [664359] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1665909 { id="cluster_1665909"; isCluster="true"; label="repartition"; 664360 [id="node_664360" labelType="html" label="MapPartitionsRDD [664360] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } } 664205->664206; 664206->664207; 664207->664355; 664355->664356; 664356->664357; 664357->664358; 664358->664359; 664359->664360; }

664204,664205

664207

664358

664205

664206

664207

664355

664356

664357

664359

664360

digraph G { id="graph_1521338"; subgraph graph_stage_1521338 { id="graph_stage_1521338"; isCluster="true"; label="Stage 1521338 (skipped)"; 664939 [id="node_664939" labelType="html" label="SQLExecutionRDD [664939] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1665909 { id="cluster_1665909"; isCluster="true"; label="repartition"; 664361 [id="node_664361" labelType="html" label="ShuffledRDD [664361] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 664362 [id="node_664362" labelType="html" label="CoalescedRDD [664362] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 664363 [id="node_664363" labelType="html" label="MapPartitionsRDD [664363] [Cached] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } subgraph cluster_1667369 { id="cluster_1667369"; isCluster="true"; label="Exchange"; 664916 [id="node_664916" labelType="html" label="ShuffledRowRDD [664916] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1667368 { id="cluster_1667368"; isCluster="true"; label="InMemoryTableScan"; 664917 [id="node_664917" labelType="html" label="MapPartitionsRDD [664917] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 664918 [id="node_664918" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#15242352L, 30), REPARTITION_BY_NUM, [plan_id=4671509]\n+- *(2) HashAggregate(keys=[demandChannel#15242355, shardId#15242351, kpis#15242357, version#15242353, qty#15242354, worklistShardItemId#15242352L, demandStream#15242356], functions=[], output=[shardId#15242351, worklistShardItemId#15242352L, version#15242353, qty#15242354, demandChannel#15242355, demandStream#15242356, kpis#15242357])\n +- Exchange hashpartitioning(demandChannel#15242355, shardId#15242351, kpis#15242357, version#15242353, qty#15242354, worklistShardItemId#15242352L, demandStream#15242356, 30), ENSURE_REQUIREMENTS, [plan_id=4671505]\n +- HashAggregate(keys=[demandChannel#15242355, shardId#15242351, knownfloatingpointnormalized(transform(kpis#15242357, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#15622675)) null else named_struct(label, lambda arg#15622675.label, dateTime, lambda arg#15622675.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda ar... [664918] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1667433 { id="cluster_1667433"; isCluster="true"; label="InMemoryTableScan"; 664935 [id="node_664935" labelType="html" label="MapPartitionsRDD [664935] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 664936 [id="node_664936" labelType="html" label="MapPartitionsRDD [664936] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 664937 [id="node_664937" labelType="html" label="MapPartitionsRDD [664937] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1667432 { id="cluster_1667432"; isCluster="true"; label="DeserializeToObject"; 664938 [id="node_664938" labelType="html" label="MapPartitionsRDD [664938] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1667434 { id="cluster_1667434"; isCluster="true"; label="mapPartitions"; 664940 [id="node_664940" labelType="html" label="MapPartitionsRDD [664940] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1667435 { id="cluster_1667435"; isCluster="true"; label="union"; 664941 [id="node_664941" labelType="html" label="UnionRDD [664941] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1667436 { id="cluster_1667436"; isCluster="true"; label="keyBy"; 664942 [id="node_664942" labelType="html" label="MapPartitionsRDD [664942] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 664361->664362; 664362->664363; 664916->664917; 664917->664918; 664918->664935; 664935->664936; 664936->664937; 664937->664938; 664938->664939; 664939->664940; 664363->664941; 664940->664941; 664941->664942; }

664360,664361

664915,664916

664363

664361

664362

664363

664941

664942

digraph G { id="graph_1521339"; subgraph graph_stage_1521339 { id="graph_stage_1521339"; isCluster="true"; label="Stage 1521339 (skipped)"; subgraph cluster_1667437 { id="cluster_1667437"; isCluster="true"; label="reduceByKey"; 664943 [id="node_664943" labelType="html" label="ShuffledRDD [664943] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1667438 { id="cluster_1667438"; isCluster="true"; label="map"; 664944 [id="node_664944" labelType="html" label="MapPartitionsRDD [664944] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1667439 { id="cluster_1667439"; isCluster="true"; label="repartition"; 664945 [id="node_664945" labelType="html" label="MapPartitionsRDD [664945] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 664943->664944; 664944->664945; }

664942,664943

664943

664944

664945

digraph G { id="graph_1521340"; subgraph graph_stage_1521340 { id="graph_stage_1521340"; isCluster="true"; label="Stage 1521340 (skipped)"; 664993 [id="node_664993" labelType="html" label="SQLExecutionRDD [664993] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1667439 { id="cluster_1667439"; isCluster="true"; label="repartition"; 664946 [id="node_664946" labelType="html" label="ShuffledRDD [664946] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 664947 [id="node_664947" labelType="html" label="CoalescedRDD [664947] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 664948 [id="node_664948" labelType="html" label="MapPartitionsRDD [664948] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1667543 { id="cluster_1667543"; isCluster="true"; label="map"; 664990 [id="node_664990" labelType="html" label="MapPartitionsRDD [664990] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1667545 { id="cluster_1667545"; isCluster="true"; label="WholeStageCodegen (1)"; 664991 [id="node_664991" labelType="html" label="MapPartitionsRDD [664991] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1667544 { id="cluster_1667544"; isCluster="true"; label="DeserializeToObject"; 664992 [id="node_664992" labelType="html" label="MapPartitionsRDD [664992] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1667548 { id="cluster_1667548"; isCluster="true"; label="mapPartitions"; 664994 [id="node_664994" labelType="html" label="MapPartitionsRDD [664994] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1667549 { id="cluster_1667549"; isCluster="true"; label="repartition"; 664995 [id="node_664995" labelType="html" label="MapPartitionsRDD [664995] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 664946->664947; 664947->664948; 664948->664990; 664990->664991; 664991->664992; 664992->664993; 664993->664994; 664994->664995; }

664945,664946

664948

664993

664946

664947

664948

664990

664991

664992

664994

664995

digraph G { id="graph_1521341"; subgraph graph_stage_1521341 { id="graph_stage_1521341"; isCluster="true"; label="Stage 1521341 (skipped)"; 665499 [id="node_665499" labelType="html" label="SQLExecutionRDD [665499] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; subgraph cluster_1667549 { id="cluster_1667549"; isCluster="true"; label="repartition"; 664996 [id="node_664996" labelType="html" label="ShuffledRDD [664996] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 664997 [id="node_664997" labelType="html" label="CoalescedRDD [664997] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 664998 [id="node_664998" labelType="html" label="MapPartitionsRDD [664998] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1668812 { id="cluster_1668812"; isCluster="true"; label="map"; 665496 [id="node_665496" labelType="html" label="MapPartitionsRDD [665496] [Indeterminate] createDataFrame at KpiCurveCacheImpl.java:230}"]; } subgraph cluster_1668814 { id="cluster_1668814"; isCluster="true"; label="WholeStageCodegen (1)"; 665497 [id="node_665497" labelType="html" label="MapPartitionsRDD [665497] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1668813 { id="cluster_1668813"; isCluster="true"; label="DeserializeToObject"; 665498 [id="node_665498" labelType="html" label="MapPartitionsRDD [665498] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1668817 { id="cluster_1668817"; isCluster="true"; label="mapPartitions"; 665500 [id="node_665500" labelType="html" label="MapPartitionsRDD [665500] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1668818 { id="cluster_1668818"; isCluster="true"; label="repartition"; 665501 [id="node_665501" labelType="html" label="MapPartitionsRDD [665501] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } } 664996->664997; 664997->664998; 664998->665496; 665496->665497; 665497->665498; 665498->665499; 665499->665500; 665500->665501; }

664995,664996

664998

665499

664996

664997

664998

665496

665497

665498

665500

665501

digraph G { id="graph_1521342"; subgraph graph_stage_1521342 { id="graph_stage_1521342"; isCluster="true"; label="Stage 1521342 (skipped)"; 665867 [id="node_665867" labelType="html" label="SQLExecutionRDD [665867] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1669741 { id="cluster_1669741"; isCluster="true"; label="Scan parquet "; 665864 [id="node_665864" labelType="html" label="FileScanRDD [665864] start at FileStorageAdapterImpl.java:596}"]; 665865 [id="node_665865" labelType="html" label="MapPartitionsRDD [665865] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1669738 { id="cluster_1669738"; isCluster="true"; label="WholeStageCodegen (1)"; 665866 [id="node_665866" labelType="html" label="MapPartitionsRDD [665866] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1669756 { id="cluster_1669756"; isCluster="true"; label="WholeStageCodegen (1)"; 665868 [id="node_665868" labelType="html" label="MapPartitionsRDD [665868] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1669755 { id="cluster_1669755"; isCluster="true"; label="HashAggregate"; 665869 [id="node_665869" labelType="html" label="MapPartitionsRDD [665869] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1669754 { id="cluster_1669754"; isCluster="true"; label="Exchange"; 665870 [id="node_665870" labelType="html" label="MapPartitionsRDD [665870] start at FileStorageAdapterImpl.java:596}"]; } } 665864->665865; 665865->665866; 665866->665867; 665867->665868; 665868->665869; 665869->665870; }

digraph G { id="graph_1521343"; subgraph graph_stage_1521343 { id="graph_stage_1521343"; isCluster="true"; label="Stage 1521343 (skipped)"; subgraph cluster_1669754 { id="cluster_1669754"; isCluster="true"; label="Exchange"; 665871 [id="node_665871" labelType="html" label="ShuffledRowRDD [665871] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1669751 { id="cluster_1669751"; isCluster="true"; label="WholeStageCodegen (2)"; 665872 [id="node_665872" labelType="html" label="MapPartitionsRDD [665872] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1669750 { id="cluster_1669750"; isCluster="true"; label="Exchange"; 665873 [id="node_665873" labelType="html" label="MapPartitionsRDD [665873] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 665871->665872; 665872->665873; }

665870,665871

digraph G { id="graph_1521344"; subgraph graph_stage_1521344 { id="graph_stage_1521344"; isCluster="true"; label="Stage 1521344 (skipped)"; 665791 [id="node_665791" labelType="html" label="SQLExecutionRDD [665791] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1668818 { id="cluster_1668818"; isCluster="true"; label="repartition"; 665502 [id="node_665502" labelType="html" label="ShuffledRDD [665502] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 665503 [id="node_665503" labelType="html" label="CoalescedRDD [665503] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 665504 [id="node_665504" labelType="html" label="MapPartitionsRDD [665504] [Cached] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } subgraph cluster_1669564 { id="cluster_1669564"; isCluster="true"; label="map"; 665788 [id="node_665788" labelType="html" label="MapPartitionsRDD [665788] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1669566 { id="cluster_1669566"; isCluster="true"; label="WholeStageCodegen (1)"; 665789 [id="node_665789" labelType="html" label="MapPartitionsRDD [665789] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1669565 { id="cluster_1669565"; isCluster="true"; label="DeserializeToObject"; 665790 [id="node_665790" labelType="html" label="MapPartitionsRDD [665790] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1669569 { id="cluster_1669569"; isCluster="true"; label="mapPartitions"; 665792 [id="node_665792" labelType="html" label="MapPartitionsRDD [665792] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1669570 { id="cluster_1669570"; isCluster="true"; label="repartition"; 665793 [id="node_665793" labelType="html" label="MapPartitionsRDD [665793] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 665502->665503; 665503->665504; 665504->665788; 665788->665789; 665789->665790; 665790->665791; 665791->665792; 665792->665793; }

665501,665502

665504

665791

665502

665503

665504

665788

665789

665790

665792

665793

digraph G { id="graph_1521345"; subgraph graph_stage_1521345 { id="graph_stage_1521345"; isCluster="true"; label="Stage 1521345 (skipped)"; 665889 [id="node_665889" labelType="html" label="SQLExecutionRDD [665889] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1669570 { id="cluster_1669570"; isCluster="true"; label="repartition"; 665794 [id="node_665794" labelType="html" label="ShuffledRDD [665794] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 665795 [id="node_665795" labelType="html" label="CoalescedRDD [665795] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 665796 [id="node_665796" labelType="html" label="MapPartitionsRDD [665796] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1669750 { id="cluster_1669750"; isCluster="true"; label="Exchange"; 665874 [id="node_665874" labelType="html" label="ShuffledRowRDD [665874] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1669749 { id="cluster_1669749"; isCluster="true"; label="InMemoryTableScan"; 665875 [id="node_665875" labelType="html" label="MapPartitionsRDD [665875] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 665876 [id="node_665876" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#15242296L, 30), REPARTITION_BY_NUM, [plan_id=4677267]\n+- *(2) HashAggregate(keys=[demandChannel#15242299, shardId#15242295, kpis#15242301, version#15242297, qty#15242298, worklistShardItemId#15242296L, demandStream#15242300], functions=[], output=[shardId#15242295, worklistShardItemId#15242296L, version#15242297, qty#15242298, demandChannel#15242299, demandStream#15242300, kpis#15242301])\n +- Exchange hashpartitioning(demandChannel#15242299, shardId#15242295, kpis#15242301, version#15242297, qty#15242298, worklistShardItemId#15242296L, demandStream#15242300, 30), ENSURE_REQUIREMENTS, [plan_id=4677263]\n +- HashAggregate(keys=[demandChannel#15242299, shardId#15242295, knownfloatingpointnormalized(transform(kpis#15242301, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#15644520)) null else named_struct(label, lambda arg#15644520.label, dateTime, lambda arg#15644520.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda ar... [665876] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1669782 { id="cluster_1669782"; isCluster="true"; label="InMemoryTableScan"; 665885 [id="node_665885" labelType="html" label="MapPartitionsRDD [665885] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 665886 [id="node_665886" labelType="html" label="MapPartitionsRDD [665886] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 665887 [id="node_665887" labelType="html" label="MapPartitionsRDD [665887] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1669781 { id="cluster_1669781"; isCluster="true"; label="DeserializeToObject"; 665888 [id="node_665888" labelType="html" label="MapPartitionsRDD [665888] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1669783 { id="cluster_1669783"; isCluster="true"; label="mapPartitions"; 665890 [id="node_665890" labelType="html" label="MapPartitionsRDD [665890] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1669784 { id="cluster_1669784"; isCluster="true"; label="union"; 665891 [id="node_665891" labelType="html" label="UnionRDD [665891] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1669785 { id="cluster_1669785"; isCluster="true"; label="keyBy"; 665892 [id="node_665892" labelType="html" label="MapPartitionsRDD [665892] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 665794->665795; 665795->665796; 665874->665875; 665875->665876; 665876->665885; 665885->665886; 665886->665887; 665887->665888; 665888->665889; 665889->665890; 665796->665891; 665890->665891; 665891->665892; }

665793,665794

665873,665874

665796

665794

665795

665796

665891

665892

digraph G { id="graph_1521346"; subgraph graph_stage_1521346 { id="graph_stage_1521346"; isCluster="true"; label="Stage 1521346 (skipped)"; subgraph cluster_1669786 { id="cluster_1669786"; isCluster="true"; label="reduceByKey"; 665893 [id="node_665893" labelType="html" label="ShuffledRDD [665893] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1669787 { id="cluster_1669787"; isCluster="true"; label="map"; 665894 [id="node_665894" labelType="html" label="MapPartitionsRDD [665894] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1669788 { id="cluster_1669788"; isCluster="true"; label="repartition"; 665895 [id="node_665895" labelType="html" label="MapPartitionsRDD [665895] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 665893->665894; 665894->665895; }

665892,665893

665893

665894

665895

digraph G { id="graph_1521347"; subgraph graph_stage_1521347 { id="graph_stage_1521347"; isCluster="true"; label="Stage 1521347 (skipped)"; 666489 [id="node_666489" labelType="html" label="SQLExecutionRDD [666489] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1669788 { id="cluster_1669788"; isCluster="true"; label="repartition"; 665896 [id="node_665896" labelType="html" label="ShuffledRDD [665896] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 665897 [id="node_665897" labelType="html" label="CoalescedRDD [665897] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 665898 [id="node_665898" labelType="html" label="MapPartitionsRDD [665898] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1671330 { id="cluster_1671330"; isCluster="true"; label="map"; 666486 [id="node_666486" labelType="html" label="MapPartitionsRDD [666486] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1671332 { id="cluster_1671332"; isCluster="true"; label="WholeStageCodegen (1)"; 666487 [id="node_666487" labelType="html" label="MapPartitionsRDD [666487] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1671331 { id="cluster_1671331"; isCluster="true"; label="DeserializeToObject"; 666488 [id="node_666488" labelType="html" label="MapPartitionsRDD [666488] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1671335 { id="cluster_1671335"; isCluster="true"; label="mapPartitions"; 666490 [id="node_666490" labelType="html" label="MapPartitionsRDD [666490] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1671336 { id="cluster_1671336"; isCluster="true"; label="repartition"; 666491 [id="node_666491" labelType="html" label="MapPartitionsRDD [666491] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 665896->665897; 665897->665898; 665898->666486; 666486->666487; 666487->666488; 666488->666489; 666489->666490; 666490->666491; }

665895,665896

665898

666489

665896

665897

665898

666486

666487

666488

666490

666491

digraph G { id="graph_1521348"; subgraph graph_stage_1521348 { id="graph_stage_1521348"; isCluster="true"; label="Stage 1521348 (skipped)"; 666732 [id="node_666732" labelType="html" label="SQLExecutionRDD [666732] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1671891 { id="cluster_1671891"; isCluster="true"; label="Scan parquet "; 666729 [id="node_666729" labelType="html" label="FileScanRDD [666729] start at FileStorageAdapterImpl.java:596}"]; 666730 [id="node_666730" labelType="html" label="MapPartitionsRDD [666730] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1671888 { id="cluster_1671888"; isCluster="true"; label="WholeStageCodegen (1)"; 666731 [id="node_666731" labelType="html" label="MapPartitionsRDD [666731] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1671906 { id="cluster_1671906"; isCluster="true"; label="WholeStageCodegen (1)"; 666733 [id="node_666733" labelType="html" label="MapPartitionsRDD [666733] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1671905 { id="cluster_1671905"; isCluster="true"; label="HashAggregate"; 666734 [id="node_666734" labelType="html" label="MapPartitionsRDD [666734] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1671904 { id="cluster_1671904"; isCluster="true"; label="Exchange"; 666735 [id="node_666735" labelType="html" label="MapPartitionsRDD [666735] start at FileStorageAdapterImpl.java:596}"]; } } 666729->666730; 666730->666731; 666731->666732; 666732->666733; 666733->666734; 666734->666735; }

digraph G { id="graph_1521349"; subgraph graph_stage_1521349 { id="graph_stage_1521349"; isCluster="true"; label="Stage 1521349 (skipped)"; subgraph cluster_1671904 { id="cluster_1671904"; isCluster="true"; label="Exchange"; 666736 [id="node_666736" labelType="html" label="ShuffledRowRDD [666736] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1671901 { id="cluster_1671901"; isCluster="true"; label="WholeStageCodegen (2)"; 666737 [id="node_666737" labelType="html" label="MapPartitionsRDD [666737] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1671900 { id="cluster_1671900"; isCluster="true"; label="Exchange"; 666738 [id="node_666738" labelType="html" label="MapPartitionsRDD [666738] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 666736->666737; 666737->666738; }

666735,666736

digraph G { id="graph_1521350"; subgraph graph_stage_1521350 { id="graph_stage_1521350"; isCluster="true"; label="Stage 1521350 (skipped)"; 666607 [id="node_666607" labelType="html" label="SQLExecutionRDD [666607] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; subgraph cluster_1671336 { id="cluster_1671336"; isCluster="true"; label="repartition"; 666492 [id="node_666492" labelType="html" label="ShuffledRDD [666492] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 666493 [id="node_666493" labelType="html" label="CoalescedRDD [666493] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 666494 [id="node_666494" labelType="html" label="MapPartitionsRDD [666494] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1671560 { id="cluster_1671560"; isCluster="true"; label="map"; 666604 [id="node_666604" labelType="html" label="MapPartitionsRDD [666604] [Indeterminate] createDataFrame at KpiCurveCacheImpl.java:230}"]; } subgraph cluster_1671562 { id="cluster_1671562"; isCluster="true"; label="WholeStageCodegen (1)"; 666605 [id="node_666605" labelType="html" label="MapPartitionsRDD [666605] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1671561 { id="cluster_1671561"; isCluster="true"; label="DeserializeToObject"; 666606 [id="node_666606" labelType="html" label="MapPartitionsRDD [666606] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1671565 { id="cluster_1671565"; isCluster="true"; label="mapPartitions"; 666608 [id="node_666608" labelType="html" label="MapPartitionsRDD [666608] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1671566 { id="cluster_1671566"; isCluster="true"; label="repartition"; 666609 [id="node_666609" labelType="html" label="MapPartitionsRDD [666609] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } } 666492->666493; 666493->666494; 666494->666604; 666604->666605; 666605->666606; 666606->666607; 666607->666608; 666608->666609; }

666491,666492

666494

666607

666492

666493

666494

666604

666605

666606

666608

666609

digraph G { id="graph_1521351"; subgraph graph_stage_1521351 { id="graph_stage_1521351"; isCluster="true"; label="Stage 1521351 (skipped)"; 666754 [id="node_666754" labelType="html" label="SQLExecutionRDD [666754] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1671566 { id="cluster_1671566"; isCluster="true"; label="repartition"; 666610 [id="node_666610" labelType="html" label="ShuffledRDD [666610] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 666611 [id="node_666611" labelType="html" label="CoalescedRDD [666611] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 666612 [id="node_666612" labelType="html" label="MapPartitionsRDD [666612] [Cached] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } subgraph cluster_1671900 { id="cluster_1671900"; isCluster="true"; label="Exchange"; 666739 [id="node_666739" labelType="html" label="ShuffledRowRDD [666739] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1671899 { id="cluster_1671899"; isCluster="true"; label="InMemoryTableScan"; 666740 [id="node_666740" labelType="html" label="MapPartitionsRDD [666740] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 666741 [id="node_666741" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#15242296L, 30), REPARTITION_BY_NUM, [plan_id=4682454]\n+- *(2) HashAggregate(keys=[demandChannel#15242299, shardId#15242295, kpis#15242301, version#15242297, qty#15242298, worklistShardItemId#15242296L, demandStream#15242300], functions=[], output=[shardId#15242295, worklistShardItemId#15242296L, version#15242297, qty#15242298, demandChannel#15242299, demandStream#15242300, kpis#15242301])\n +- Exchange hashpartitioning(demandChannel#15242299, shardId#15242295, kpis#15242301, version#15242297, qty#15242298, worklistShardItemId#15242296L, demandStream#15242300, 30), ENSURE_REQUIREMENTS, [plan_id=4682450]\n +- HashAggregate(keys=[demandChannel#15242299, shardId#15242295, knownfloatingpointnormalized(transform(kpis#15242301, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#15665578)) null else named_struct(label, lambda arg#15665578.label, dateTime, lambda arg#15665578.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda ar... [666741] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1671932 { id="cluster_1671932"; isCluster="true"; label="InMemoryTableScan"; 666750 [id="node_666750" labelType="html" label="MapPartitionsRDD [666750] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 666751 [id="node_666751" labelType="html" label="MapPartitionsRDD [666751] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 666752 [id="node_666752" labelType="html" label="MapPartitionsRDD [666752] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1671931 { id="cluster_1671931"; isCluster="true"; label="DeserializeToObject"; 666753 [id="node_666753" labelType="html" label="MapPartitionsRDD [666753] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1671933 { id="cluster_1671933"; isCluster="true"; label="mapPartitions"; 666755 [id="node_666755" labelType="html" label="MapPartitionsRDD [666755] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1671934 { id="cluster_1671934"; isCluster="true"; label="union"; 666756 [id="node_666756" labelType="html" label="UnionRDD [666756] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1671935 { id="cluster_1671935"; isCluster="true"; label="keyBy"; 666757 [id="node_666757" labelType="html" label="MapPartitionsRDD [666757] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 666610->666611; 666611->666612; 666739->666740; 666740->666741; 666741->666750; 666750->666751; 666751->666752; 666752->666753; 666753->666754; 666754->666755; 666612->666756; 666755->666756; 666756->666757; }

666609,666610

666738,666739

666612

666610

666611

666612

666756

666757

digraph G { id="graph_1521352"; subgraph graph_stage_1521352 { id="graph_stage_1521352"; isCluster="true"; label="Stage 1521352 (skipped)"; subgraph cluster_1671936 { id="cluster_1671936"; isCluster="true"; label="reduceByKey"; 666758 [id="node_666758" labelType="html" label="ShuffledRDD [666758] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1671937 { id="cluster_1671937"; isCluster="true"; label="map"; 666759 [id="node_666759" labelType="html" label="MapPartitionsRDD [666759] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1671938 { id="cluster_1671938"; isCluster="true"; label="repartition"; 666760 [id="node_666760" labelType="html" label="MapPartitionsRDD [666760] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 666758->666759; 666759->666760; }

666757,666758

666758

666759

666760

digraph G { id="graph_1521353"; subgraph graph_stage_1521353 { id="graph_stage_1521353"; isCluster="true"; label="Stage 1521353 (skipped)"; 667354 [id="node_667354" labelType="html" label="SQLExecutionRDD [667354] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1671938 { id="cluster_1671938"; isCluster="true"; label="repartition"; 666761 [id="node_666761" labelType="html" label="ShuffledRDD [666761] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 666762 [id="node_666762" labelType="html" label="CoalescedRDD [666762] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 666763 [id="node_666763" labelType="html" label="MapPartitionsRDD [666763] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673480 { id="cluster_1673480"; isCluster="true"; label="map"; 667351 [id="node_667351" labelType="html" label="MapPartitionsRDD [667351] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673482 { id="cluster_1673482"; isCluster="true"; label="WholeStageCodegen (1)"; 667352 [id="node_667352" labelType="html" label="MapPartitionsRDD [667352] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673481 { id="cluster_1673481"; isCluster="true"; label="DeserializeToObject"; 667353 [id="node_667353" labelType="html" label="MapPartitionsRDD [667353] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673485 { id="cluster_1673485"; isCluster="true"; label="mapPartitions"; 667355 [id="node_667355" labelType="html" label="MapPartitionsRDD [667355] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673486 { id="cluster_1673486"; isCluster="true"; label="repartition"; 667356 [id="node_667356" labelType="html" label="MapPartitionsRDD [667356] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 666761->666762; 666762->666763; 666763->667351; 667351->667352; 667352->667353; 667353->667354; 667354->667355; 667355->667356; }

666760,666761

666763

667354

666761

666762

666763

667351

667352

667353

667355

667356

digraph G { id="graph_1521354"; subgraph graph_stage_1521354 { id="graph_stage_1521354"; isCluster="true"; label="Stage 1521354 (skipped)"; 667434 [id="node_667434" labelType="html" label="SQLExecutionRDD [667434] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; subgraph cluster_1673486 { id="cluster_1673486"; isCluster="true"; label="repartition"; 667357 [id="node_667357" labelType="html" label="ShuffledRDD [667357] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 667358 [id="node_667358" labelType="html" label="CoalescedRDD [667358] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 667359 [id="node_667359" labelType="html" label="MapPartitionsRDD [667359] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673663 { id="cluster_1673663"; isCluster="true"; label="map"; 667431 [id="node_667431" labelType="html" label="MapPartitionsRDD [667431] [Indeterminate] createDataFrame at KpiCurveCacheImpl.java:230}"]; } subgraph cluster_1673665 { id="cluster_1673665"; isCluster="true"; label="WholeStageCodegen (1)"; 667432 [id="node_667432" labelType="html" label="MapPartitionsRDD [667432] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1673664 { id="cluster_1673664"; isCluster="true"; label="DeserializeToObject"; 667433 [id="node_667433" labelType="html" label="MapPartitionsRDD [667433] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1673668 { id="cluster_1673668"; isCluster="true"; label="mapPartitions"; 667435 [id="node_667435" labelType="html" label="MapPartitionsRDD [667435] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1673669 { id="cluster_1673669"; isCluster="true"; label="repartition"; 667436 [id="node_667436" labelType="html" label="MapPartitionsRDD [667436] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } } 667357->667358; 667358->667359; 667359->667431; 667431->667432; 667432->667433; 667433->667434; 667434->667435; 667435->667436; }

667356,667357

667359

667434

667357

667358

667359

667431

667432

667433

667435

667436

digraph G { id="graph_1521355"; subgraph graph_stage_1521355 { id="graph_stage_1521355"; isCluster="true"; label="Stage 1521355 (skipped)"; subgraph cluster_1673984 { id="cluster_1673984"; isCluster="true"; label="Exchange"; 667563 [id="node_667563" labelType="html" label="ShuffledRowRDD [667563] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673981 { id="cluster_1673981"; isCluster="true"; label="WholeStageCodegen (2)"; 667564 [id="node_667564" labelType="html" label="MapPartitionsRDD [667564] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673980 { id="cluster_1673980"; isCluster="true"; label="Exchange"; 667565 [id="node_667565" labelType="html" label="MapPartitionsRDD [667565] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 667563->667564; 667564->667565; }

667562,667563

digraph G { id="graph_1521356"; subgraph graph_stage_1521356 { id="graph_stage_1521356"; isCluster="true"; label="Stage 1521356 (skipped)"; 667581 [id="node_667581" labelType="html" label="SQLExecutionRDD [667581] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1673669 { id="cluster_1673669"; isCluster="true"; label="repartition"; 667437 [id="node_667437" labelType="html" label="ShuffledRDD [667437] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 667438 [id="node_667438" labelType="html" label="CoalescedRDD [667438] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 667439 [id="node_667439" labelType="html" label="MapPartitionsRDD [667439] [Cached] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } subgraph cluster_1673980 { id="cluster_1673980"; isCluster="true"; label="Exchange"; 667566 [id="node_667566" labelType="html" label="ShuffledRowRDD [667566] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673979 { id="cluster_1673979"; isCluster="true"; label="InMemoryTableScan"; 667567 [id="node_667567" labelType="html" label="MapPartitionsRDD [667567] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 667568 [id="node_667568" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#15242296L, 30), REPARTITION_BY_NUM, [plan_id=4687558]\n+- *(2) HashAggregate(keys=[demandChannel#15242299, shardId#15242295, kpis#15242301, version#15242297, qty#15242298, worklistShardItemId#15242296L, demandStream#15242300], functions=[], output=[shardId#15242295, worklistShardItemId#15242296L, version#15242297, qty#15242298, demandChannel#15242299, demandStream#15242300, kpis#15242301])\n +- Exchange hashpartitioning(demandChannel#15242299, shardId#15242295, kpis#15242301, version#15242297, qty#15242298, worklistShardItemId#15242296L, demandStream#15242300, 30), ENSURE_REQUIREMENTS, [plan_id=4687554]\n +- HashAggregate(keys=[demandChannel#15242299, shardId#15242295, knownfloatingpointnormalized(transform(kpis#15242301, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#15686449)) null else named_struct(label, lambda arg#15686449.label, dateTime, lambda arg#15686449.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda ar... [667568] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1674012 { id="cluster_1674012"; isCluster="true"; label="InMemoryTableScan"; 667577 [id="node_667577" labelType="html" label="MapPartitionsRDD [667577] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 667578 [id="node_667578" labelType="html" label="MapPartitionsRDD [667578] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 667579 [id="node_667579" labelType="html" label="MapPartitionsRDD [667579] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1674011 { id="cluster_1674011"; isCluster="true"; label="DeserializeToObject"; 667580 [id="node_667580" labelType="html" label="MapPartitionsRDD [667580] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1674013 { id="cluster_1674013"; isCluster="true"; label="mapPartitions"; 667582 [id="node_667582" labelType="html" label="MapPartitionsRDD [667582] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1674014 { id="cluster_1674014"; isCluster="true"; label="union"; 667583 [id="node_667583" labelType="html" label="UnionRDD [667583] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1674015 { id="cluster_1674015"; isCluster="true"; label="keyBy"; 667584 [id="node_667584" labelType="html" label="MapPartitionsRDD [667584] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 667437->667438; 667438->667439; 667566->667567; 667567->667568; 667568->667577; 667577->667578; 667578->667579; 667579->667580; 667580->667581; 667581->667582; 667439->667583; 667582->667583; 667583->667584; }

667436,667437

667565,667566

667439

667437

667438

667439

667583

667584

digraph G { id="graph_1521357"; subgraph graph_stage_1521357 { id="graph_stage_1521357"; isCluster="true"; label="Stage 1521357 (skipped)"; subgraph cluster_1674016 { id="cluster_1674016"; isCluster="true"; label="reduceByKey"; 667585 [id="node_667585" labelType="html" label="ShuffledRDD [667585] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1674017 { id="cluster_1674017"; isCluster="true"; label="map"; 667586 [id="node_667586" labelType="html" label="MapPartitionsRDD [667586] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1674018 { id="cluster_1674018"; isCluster="true"; label="repartition"; 667587 [id="node_667587" labelType="html" label="MapPartitionsRDD [667587] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 667585->667586; 667586->667587; }

667584,667585

667585

667586

667587

digraph G { id="graph_1521358"; subgraph graph_stage_1521358 { id="graph_stage_1521358"; isCluster="true"; label="Stage 1521358 (skipped)"; 668163 [id="node_668163" labelType="html" label="SQLExecutionRDD [668163] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1674018 { id="cluster_1674018"; isCluster="true"; label="repartition"; 667588 [id="node_667588" labelType="html" label="ShuffledRDD [667588] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 667589 [id="node_667589" labelType="html" label="CoalescedRDD [667589] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 667590 [id="node_667590" labelType="html" label="MapPartitionsRDD [667590] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1675510 { id="cluster_1675510"; isCluster="true"; label="map"; 668160 [id="node_668160" labelType="html" label="MapPartitionsRDD [668160] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1675512 { id="cluster_1675512"; isCluster="true"; label="WholeStageCodegen (1)"; 668161 [id="node_668161" labelType="html" label="MapPartitionsRDD [668161] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1675511 { id="cluster_1675511"; isCluster="true"; label="DeserializeToObject"; 668162 [id="node_668162" labelType="html" label="MapPartitionsRDD [668162] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1675515 { id="cluster_1675515"; isCluster="true"; label="mapPartitions"; 668164 [id="node_668164" labelType="html" label="MapPartitionsRDD [668164] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1675516 { id="cluster_1675516"; isCluster="true"; label="repartition"; 668165 [id="node_668165" labelType="html" label="MapPartitionsRDD [668165] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 667588->667589; 667589->667590; 667590->668160; 668160->668161; 668161->668162; 668162->668163; 668163->668164; 668164->668165; }

667587,667588

667590

668163

667588

667589

667590

668160

668161

668162

668164

668165

digraph G { id="graph_1521359"; subgraph graph_stage_1521359 { id="graph_stage_1521359"; isCluster="true"; label="Stage 1521359"; subgraph cluster_1675516 { id="cluster_1675516"; isCluster="true"; label="repartition"; 668166 [id="node_668166" labelType="html" label="ShuffledRDD [668166] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 668167 [id="node_668167" labelType="html" label="CoalescedRDD [668167] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 668168 [id="node_668168" labelType="html" label="MapPartitionsRDD [668168] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1675684 { id="cluster_1675684"; isCluster="true"; label="map"; 668236 [id="node_668236" labelType="html" label="MapPartitionsRDD [668236] [Cached] [Indeterminate] map at PeriodicAsyncRDDCheckpointWriterImpl.java:207}"]; } } 668166->668167; 668167->668168; 668168->668236; }

668165,668166

668168

668236

668166

668167

668168

668236

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
1521359	default	count at KpiCurveCacheImpl.java:255 +details org.apache.spark.api.java.AbstractJavaRDDLike.count(JavaRDDLike.scala:46) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.logRDDCountDebug(KpiCurveCacheImpl.java:255) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.triggerCheckpointing(KpiCurveCacheImpl.java:214) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.cachelifecycle.PeriodicAsyncRDDCheckpointWriterImpl.lambda$createCheckpointsConcurrently$0(PeriodicAsyncRDDCheckpointWriterImpl.java:119) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/09/02 11:08:53	23 ms	30/30	630.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1521359

default

count at KpiCurveCacheImpl.java:255 +details

org.apache.spark.api.java.AbstractJavaRDDLike.count(JavaRDDLike.scala:46)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.logRDDCountDebug(KpiCurveCacheImpl.java:255)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.triggerCheckpointing(KpiCurveCacheImpl.java:214)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.cachelifecycle.PeriodicAsyncRDDCheckpointWriterImpl.lambda$createCheckpointsConcurrently$0(PeriodicAsyncRDDCheckpointWriterImpl.java:119)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
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/09/02 11:08:53

23 ms

30/30

630.0 B

Page:

Skipped Stages (26)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
1521358	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/30
1521357	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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
1521356	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/67
1521355	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/30
1521354	default	repartition at KpiCurveCacheImpl.java:98 +details org.apache.spark.api.java.JavaRDD.repartition(JavaRDD.scala:118) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.removeShardsFromCache(KpiCurveCacheImpl.java:98) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:141) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:49) jdk.internal.reflect.GeneratedMethodAccessor620.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/30
1521353	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/30
1521352	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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
1521351	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/67
1521350	default	repartition at KpiCurveCacheImpl.java:98 +details org.apache.spark.api.java.JavaRDD.repartition(JavaRDD.scala:118) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.removeShardsFromCache(KpiCurveCacheImpl.java:98) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:141) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:49) jdk.internal.reflect.GeneratedMethodAccessor620.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/30
1521349	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/30
1521348	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/30
1521347	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/30
1521346	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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
1521345	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/60
1521344	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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
1521343	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/30
1521342	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/30
1521341	default	repartition at KpiCurveCacheImpl.java:98 +details org.apache.spark.api.java.JavaRDD.repartition(JavaRDD.scala:118) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.removeShardsFromCache(KpiCurveCacheImpl.java:98) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:141) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:49) jdk.internal.reflect.GeneratedMethodAccessor620.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/30
1521340	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/30
1521339	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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
1521338	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/67
1521337	default	repartition at KpiCurveCacheImpl.java:98 +details org.apache.spark.api.java.JavaRDD.repartition(JavaRDD.scala:118) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.removeShardsFromCache(KpiCurveCacheImpl.java:98) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:141) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:49) jdk.internal.reflect.GeneratedMethodAccessor620.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/30
1521336	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/30
1521335	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/30
1521334	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/30
1521333	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/30

Page: