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

Status: SUCCEEDED
Submitted: 2026/08/31 14:36:21
Duration: 9 s
Job Group: 6813b2ad-7812-35f0-8d67-645c7ed180b0
Completed Stages: 2
Skipped Stages: 15

Enable zooming

digraph G { id="graph_341261"; subgraph graph_stage_341261 { id="graph_stage_341261"; isCluster="true"; label="Stage 341261 (skipped)"; 154082 [id="node_154082" labelType="html" label="SQLExecutionRDD [154082] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_385389 { id="cluster_385389"; isCluster="true"; label="Scan parquet "; 154079 [id="node_154079" labelType="html" label="FileScanRDD [154079] start at FileStorageAdapterImpl.java:596}"]; 154080 [id="node_154080" labelType="html" label="MapPartitionsRDD [154080] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385386 { id="cluster_385386"; isCluster="true"; label="WholeStageCodegen (1)"; 154081 [id="node_154081" labelType="html" label="MapPartitionsRDD [154081] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385404 { id="cluster_385404"; isCluster="true"; label="WholeStageCodegen (1)"; 154083 [id="node_154083" labelType="html" label="MapPartitionsRDD [154083] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385403 { id="cluster_385403"; isCluster="true"; label="HashAggregate"; 154084 [id="node_154084" labelType="html" label="MapPartitionsRDD [154084] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385402 { id="cluster_385402"; isCluster="true"; label="Exchange"; 154085 [id="node_154085" labelType="html" label="MapPartitionsRDD [154085] start at FileStorageAdapterImpl.java:596}"]; } } 154079->154080; 154080->154081; 154081->154082; 154082->154083; 154083->154084; 154084->154085; }

digraph G { id="graph_341262"; subgraph graph_stage_341262 { id="graph_stage_341262"; isCluster="true"; label="Stage 341262 (skipped)"; 153792 [id="node_153792" labelType="html" label="SQLExecutionRDD [153792] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_381879 { id="cluster_381879"; isCluster="true"; label="map"; 152695 [id="node_152695" labelType="html" label="MapPartitionsRDD [152695] [Cached] [Indeterminate] map at PeriodicAsyncRDDCheckpointWriterImpl.java:207}"]; } subgraph cluster_381900 { id="cluster_381900"; isCluster="true"; label="checkpoint"; 152698 [id="node_152698" labelType="html" label="LocalCheckpointRDD [152698] count at KpiCurveCacheImpl.java:255}"]; } subgraph cluster_384774 { id="cluster_384774"; isCluster="true"; label="map"; 153789 [id="node_153789" labelType="html" label="MapPartitionsRDD [153789] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384776 { id="cluster_384776"; isCluster="true"; label="WholeStageCodegen (1)"; 153790 [id="node_153790" labelType="html" label="MapPartitionsRDD [153790] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384775 { id="cluster_384775"; isCluster="true"; label="DeserializeToObject"; 153791 [id="node_153791" labelType="html" label="MapPartitionsRDD [153791] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384779 { id="cluster_384779"; isCluster="true"; label="mapPartitions"; 153793 [id="node_153793" labelType="html" label="MapPartitionsRDD [153793] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384780 { id="cluster_384780"; isCluster="true"; label="repartition"; 153794 [id="node_153794" labelType="html" label="MapPartitionsRDD [153794] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 152698->152695; 152695->153789; 153789->153790; 153790->153791; 153791->153792; 153792->153793; 153793->153794; }

152695

153792

152695

153789

153790

153791

153793

153794

digraph G { id="graph_341263"; subgraph graph_stage_341263 { id="graph_stage_341263"; isCluster="true"; label="Stage 341263 (skipped)"; 153802 [id="node_153802" labelType="html" label="SQLExecutionRDD [153802] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_384780 { id="cluster_384780"; isCluster="true"; label="repartition"; 153795 [id="node_153795" labelType="html" label="ShuffledRDD [153795] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153796 [id="node_153796" labelType="html" label="CoalescedRDD [153796] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153797 [id="node_153797" labelType="html" label="MapPartitionsRDD [153797] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384805 { id="cluster_384805"; isCluster="true"; label="map"; 153798 [id="node_153798" labelType="html" label="MapPartitionsRDD [153798] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384808 { id="cluster_384808"; isCluster="true"; label="WholeStageCodegen (1)"; 153800 [id="node_153800" labelType="html" label="MapPartitionsRDD [153800] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384807 { id="cluster_384807"; isCluster="true"; label="DeserializeToObject"; 153801 [id="node_153801" labelType="html" label="MapPartitionsRDD [153801] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384815 { id="cluster_384815"; isCluster="true"; label="mapPartitions"; 153803 [id="node_153803" labelType="html" label="MapPartitionsRDD [153803] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384816 { id="cluster_384816"; isCluster="true"; label="repartition"; 153804 [id="node_153804" labelType="html" label="MapPartitionsRDD [153804] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 153795->153796; 153796->153797; 153797->153798; 153798->153800; 153800->153801; 153801->153802; 153802->153803; 153803->153804; }

153794,153795

153797

153802

153795

153796

153797

153798

153800

153801

153803

153804

digraph G { id="graph_341264"; subgraph graph_stage_341264 { id="graph_stage_341264"; isCluster="true"; label="Stage 341264 (skipped)"; 154061 [id="node_154061" labelType="html" label="SQLExecutionRDD [154061] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_385367 { id="cluster_385367"; isCluster="true"; label="Scan parquet "; 154058 [id="node_154058" labelType="html" label="FileScanRDD [154058] start at FileStorageAdapterImpl.java:596}"]; 154059 [id="node_154059" labelType="html" label="MapPartitionsRDD [154059] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385364 { id="cluster_385364"; isCluster="true"; label="WholeStageCodegen (1)"; 154060 [id="node_154060" labelType="html" label="MapPartitionsRDD [154060] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385382 { id="cluster_385382"; isCluster="true"; label="WholeStageCodegen (1)"; 154062 [id="node_154062" labelType="html" label="MapPartitionsRDD [154062] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385381 { id="cluster_385381"; isCluster="true"; label="HashAggregate"; 154063 [id="node_154063" labelType="html" label="MapPartitionsRDD [154063] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385380 { id="cluster_385380"; isCluster="true"; label="Exchange"; 154064 [id="node_154064" labelType="html" label="MapPartitionsRDD [154064] start at FileStorageAdapterImpl.java:596}"]; } } 154058->154059; 154059->154060; 154060->154061; 154061->154062; 154062->154063; 154063->154064; }

digraph G { id="graph_341265"; subgraph graph_stage_341265 { id="graph_stage_341265"; isCluster="true"; label="Stage 341265 (skipped)"; subgraph cluster_385380 { id="cluster_385380"; isCluster="true"; label="Exchange"; 154065 [id="node_154065" labelType="html" label="ShuffledRowRDD [154065] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385377 { id="cluster_385377"; isCluster="true"; label="WholeStageCodegen (2)"; 154066 [id="node_154066" labelType="html" label="MapPartitionsRDD [154066] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385376 { id="cluster_385376"; isCluster="true"; label="Exchange"; 154067 [id="node_154067" labelType="html" label="MapPartitionsRDD [154067] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154065->154066; 154066->154067; }

154064,154065

digraph G { id="graph_341266"; subgraph graph_stage_341266 { id="graph_stage_341266"; isCluster="true"; label="Stage 341266 (skipped)"; 153983 [id="node_153983" labelType="html" label="SQLExecutionRDD [153983] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_384816 { id="cluster_384816"; isCluster="true"; label="repartition"; 153805 [id="node_153805" labelType="html" label="ShuffledRDD [153805] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153806 [id="node_153806" labelType="html" label="CoalescedRDD [153806] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153807 [id="node_153807" labelType="html" label="MapPartitionsRDD [153807] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385197 { id="cluster_385197"; isCluster="true"; label="map"; 153980 [id="node_153980" labelType="html" label="MapPartitionsRDD [153980] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385199 { id="cluster_385199"; isCluster="true"; label="WholeStageCodegen (1)"; 153981 [id="node_153981" labelType="html" label="MapPartitionsRDD [153981] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385198 { id="cluster_385198"; isCluster="true"; label="DeserializeToObject"; 153982 [id="node_153982" labelType="html" label="MapPartitionsRDD [153982] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385202 { id="cluster_385202"; isCluster="true"; label="mapPartitions"; 153984 [id="node_153984" labelType="html" label="MapPartitionsRDD [153984] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385203 { id="cluster_385203"; isCluster="true"; label="repartition"; 153985 [id="node_153985" labelType="html" label="MapPartitionsRDD [153985] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 153805->153806; 153806->153807; 153807->153980; 153980->153981; 153981->153982; 153982->153983; 153983->153984; 153984->153985; }

153804,153805

153807

153983

153805

153806

153807

153980

153981

153982

153984

153985

digraph G { id="graph_341267"; subgraph graph_stage_341267 { id="graph_stage_341267"; isCluster="true"; label="Stage 341267 (skipped)"; 154125 [id="node_154125" labelType="html" label="SQLExecutionRDD [154125] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_385203 { id="cluster_385203"; isCluster="true"; label="repartition"; 153986 [id="node_153986" labelType="html" label="ShuffledRDD [153986] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153987 [id="node_153987" labelType="html" label="CoalescedRDD [153987] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153988 [id="node_153988" labelType="html" label="MapPartitionsRDD [153988] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385376 { id="cluster_385376"; isCluster="true"; label="Exchange"; 154068 [id="node_154068" labelType="html" label="ShuffledRowRDD [154068] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385375 { id="cluster_385375"; isCluster="true"; label="InMemoryTableScan"; 154069 [id="node_154069" labelType="html" label="MapPartitionsRDD [154069] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154070 [id="node_154070" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3614482L, 30), REPARTITION_BY_NUM, [plan_id=1034625]\n+- *(2) HashAggregate(keys=[demandChannel#3614485, shardId#3614481, kpis#3614487, version#3614483, qty#3614484, worklistShardItemId#3614482L, demandStream#3614486], functions=[], output=[shardId#3614481, worklistShardItemId#3614482L, version#3614483, qty#3614484, demandChannel#3614485, demandStream#3614486, kpis#3614487])\n +- Exchange hashpartitioning(demandChannel#3614485, shardId#3614481, kpis#3614487, version#3614483, qty#3614484, worklistShardItemId#3614482L, demandStream#3614486, 30), ENSURE_REQUIREMENTS, [plan_id=1034621]\n +- HashAggregate(keys=[demandChannel#3614485, shardId#3614481, knownfloatingpointnormalized(transform(kpis#3614487, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3614581)) null else named_struct(label, lambda arg#3614581.label, dateTime, lambda arg#3614581.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3614581.value)))), lambda ... [154070] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385452 { id="cluster_385452"; isCluster="true"; label="InMemoryTableScan"; 154121 [id="node_154121" labelType="html" label="MapPartitionsRDD [154121] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154122 [id="node_154122" labelType="html" label="MapPartitionsRDD [154122] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154123 [id="node_154123" labelType="html" label="MapPartitionsRDD [154123] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385451 { id="cluster_385451"; isCluster="true"; label="DeserializeToObject"; 154124 [id="node_154124" labelType="html" label="MapPartitionsRDD [154124] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385453 { id="cluster_385453"; isCluster="true"; label="mapPartitions"; 154126 [id="node_154126" labelType="html" label="MapPartitionsRDD [154126] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385454 { id="cluster_385454"; isCluster="true"; label="union"; 154127 [id="node_154127" labelType="html" label="UnionRDD [154127] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385455 { id="cluster_385455"; isCluster="true"; label="keyBy"; 154128 [id="node_154128" labelType="html" label="MapPartitionsRDD [154128] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 153986->153987; 153987->153988; 154068->154069; 154069->154070; 154070->154121; 154121->154122; 154122->154123; 154123->154124; 154124->154125; 154125->154126; 153988->154127; 154126->154127; 154127->154128; }

153985,153986

154067,154068

153988

153986

153987

153988

154127

154128

digraph G { id="graph_341268"; subgraph graph_stage_341268 { id="graph_stage_341268"; isCluster="true"; label="Stage 341268 (skipped)"; 154103 [id="node_154103" labelType="html" label="SQLExecutionRDD [154103] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_385411 { id="cluster_385411"; isCluster="true"; label="Scan parquet "; 154100 [id="node_154100" labelType="html" label="FileScanRDD [154100] start at FileStorageAdapterImpl.java:596}"]; 154101 [id="node_154101" labelType="html" label="MapPartitionsRDD [154101] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385408 { id="cluster_385408"; isCluster="true"; label="WholeStageCodegen (1)"; 154102 [id="node_154102" labelType="html" label="MapPartitionsRDD [154102] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385426 { id="cluster_385426"; isCluster="true"; label="WholeStageCodegen (1)"; 154104 [id="node_154104" labelType="html" label="MapPartitionsRDD [154104] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385425 { id="cluster_385425"; isCluster="true"; label="HashAggregate"; 154105 [id="node_154105" labelType="html" label="MapPartitionsRDD [154105] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385424 { id="cluster_385424"; isCluster="true"; label="Exchange"; 154106 [id="node_154106" labelType="html" label="MapPartitionsRDD [154106] start at FileStorageAdapterImpl.java:596}"]; } } 154100->154101; 154101->154102; 154102->154103; 154103->154104; 154104->154105; 154105->154106; }

digraph G { id="graph_341269"; subgraph graph_stage_341269 { id="graph_stage_341269"; isCluster="true"; label="Stage 341269 (skipped)"; subgraph cluster_385424 { id="cluster_385424"; isCluster="true"; label="Exchange"; 154107 [id="node_154107" labelType="html" label="ShuffledRowRDD [154107] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385421 { id="cluster_385421"; isCluster="true"; label="WholeStageCodegen (2)"; 154108 [id="node_154108" labelType="html" label="MapPartitionsRDD [154108] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385420 { id="cluster_385420"; isCluster="true"; label="Exchange"; 154109 [id="node_154109" labelType="html" label="MapPartitionsRDD [154109] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154107->154108; 154108->154109; }

154106,154107

digraph G { id="graph_341270"; subgraph graph_stage_341270 { id="graph_stage_341270"; isCluster="true"; label="Stage 341270 (skipped)"; subgraph cluster_385456 { id="cluster_385456"; isCluster="true"; label="reduceByKey"; 154129 [id="node_154129" labelType="html" label="ShuffledRDD [154129] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385457 { id="cluster_385457"; isCluster="true"; label="map"; 154130 [id="node_154130" labelType="html" label="MapPartitionsRDD [154130] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385458 { id="cluster_385458"; isCluster="true"; label="repartition"; 154131 [id="node_154131" labelType="html" label="MapPartitionsRDD [154131] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 154129->154130; 154130->154131; }

154128,154129

154129

154130

154131

digraph G { id="graph_341271"; subgraph graph_stage_341271 { id="graph_stage_341271"; isCluster="true"; label="Stage 341271 (skipped)"; 154140 [id="node_154140" labelType="html" label="SQLExecutionRDD [154140] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_385420 { id="cluster_385420"; isCluster="true"; label="Exchange"; 154110 [id="node_154110" labelType="html" label="ShuffledRowRDD [154110] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385419 { id="cluster_385419"; isCluster="true"; label="InMemoryTableScan"; 154111 [id="node_154111" labelType="html" label="MapPartitionsRDD [154111] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154112 [id="node_154112" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3615107L, 30), REPARTITION_BY_NUM, [plan_id=1034785]\n+- *(2) HashAggregate(keys=[demandChannel#3615110, shardId#3615106, kpis#3615112, version#3615108, qty#3615109, worklistShardItemId#3615107L, demandStream#3615111], functions=[], output=[shardId#3615106, worklistShardItemId#3615107L, version#3615108, qty#3615109, demandChannel#3615110, demandStream#3615111, kpis#3615112])\n +- Exchange hashpartitioning(demandChannel#3615110, shardId#3615106, kpis#3615112, version#3615108, qty#3615109, worklistShardItemId#3615107L, demandStream#3615111, 30), ENSURE_REQUIREMENTS, [plan_id=1034781]\n +- HashAggregate(keys=[demandChannel#3615110, shardId#3615106, knownfloatingpointnormalized(transform(kpis#3615112, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3615199)) null else named_struct(label, lambda arg#3615199.label, dateTime, lambda arg#3615199.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3615199.value)))), lambda ... [154112] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385458 { id="cluster_385458"; isCluster="true"; label="repartition"; 154132 [id="node_154132" labelType="html" label="ShuffledRDD [154132] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154133 [id="node_154133" labelType="html" label="CoalescedRDD [154133] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154134 [id="node_154134" labelType="html" label="MapPartitionsRDD [154134] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385519 { id="cluster_385519"; isCluster="true"; label="InMemoryTableScan"; 154136 [id="node_154136" labelType="html" label="MapPartitionsRDD [154136] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154137 [id="node_154137" labelType="html" label="MapPartitionsRDD [154137] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154138 [id="node_154138" labelType="html" label="MapPartitionsRDD [154138] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385518 { id="cluster_385518"; isCluster="true"; label="DeserializeToObject"; 154139 [id="node_154139" labelType="html" label="MapPartitionsRDD [154139] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385520 { id="cluster_385520"; isCluster="true"; label="mapPartitions"; 154141 [id="node_154141" labelType="html" label="MapPartitionsRDD [154141] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385521 { id="cluster_385521"; isCluster="true"; label="union"; 154142 [id="node_154142" labelType="html" label="UnionRDD [154142] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385522 { id="cluster_385522"; isCluster="true"; label="keyBy"; 154143 [id="node_154143" labelType="html" label="MapPartitionsRDD [154143] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 154110->154111; 154111->154112; 154132->154133; 154133->154134; 154112->154136; 154136->154137; 154137->154138; 154138->154139; 154139->154140; 154140->154141; 154134->154142; 154141->154142; 154142->154143; }

154109,154110

154131,154132

154134

154132

154133

154134

154142

154143

digraph G { id="graph_341272"; subgraph graph_stage_341272 { id="graph_stage_341272"; isCluster="true"; label="Stage 341272 (skipped)"; subgraph cluster_385523 { id="cluster_385523"; isCluster="true"; label="reduceByKey"; 154144 [id="node_154144" labelType="html" label="ShuffledRDD [154144] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385532 { id="cluster_385532"; isCluster="true"; label="map"; 154145 [id="node_154145" labelType="html" label="MapPartitionsRDD [154145] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385533 { id="cluster_385533"; isCluster="true"; label="repartition"; 154146 [id="node_154146" labelType="html" label="MapPartitionsRDD [154146] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 154144->154145; 154145->154146; }

154143,154144

154144

154145

154146

digraph G { id="graph_341273"; subgraph graph_stage_341273 { id="graph_stage_341273"; isCluster="true"; label="Stage 341273 (skipped)"; subgraph cluster_385402 { id="cluster_385402"; isCluster="true"; label="Exchange"; 154086 [id="node_154086" labelType="html" label="ShuffledRowRDD [154086] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385399 { id="cluster_385399"; isCluster="true"; label="WholeStageCodegen (2)"; 154087 [id="node_154087" labelType="html" label="MapPartitionsRDD [154087] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385398 { id="cluster_385398"; isCluster="true"; label="Exchange"; 154088 [id="node_154088" labelType="html" label="MapPartitionsRDD [154088] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154086->154087; 154087->154088; }

154085,154086

digraph G { id="graph_341274"; subgraph graph_stage_341274 { id="graph_stage_341274"; isCluster="true"; label="Stage 341274 (skipped)"; 154215 [id="node_154215" labelType="html" label="SQLExecutionRDD [154215] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_385398 { id="cluster_385398"; isCluster="true"; label="Exchange"; 154089 [id="node_154089" labelType="html" label="ShuffledRowRDD [154089] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385397 { id="cluster_385397"; isCluster="true"; label="InMemoryTableScan"; 154090 [id="node_154090" labelType="html" label="MapPartitionsRDD [154090] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154091 [id="node_154091" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3614461L, 30), REPARTITION_BY_NUM, [plan_id=1034705]\n+- *(2) HashAggregate(keys=[demandChannel#3614464, shardId#3614460, kpis#3614466, version#3614462, qty#3614463, worklistShardItemId#3614461L, demandStream#3614465], functions=[], output=[shardId#3614460, worklistShardItemId#3614461L, version#3614462, qty#3614463, demandChannel#3614464, demandStream#3614465, kpis#3614466])\n +- Exchange hashpartitioning(demandChannel#3614464, shardId#3614460, kpis#3614466, version#3614462, qty#3614463, worklistShardItemId#3614461L, demandStream#3614465, 30), ENSURE_REQUIREMENTS, [plan_id=1034701]\n +- HashAggregate(keys=[demandChannel#3614464, shardId#3614460, knownfloatingpointnormalized(transform(kpis#3614466, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3614876)) null else named_struct(label, lambda arg#3614876.label, dateTime, lambda arg#3614876.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3614876.value)))), lambda ... [154091] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385533 { id="cluster_385533"; isCluster="true"; label="repartition"; 154147 [id="node_154147" labelType="html" label="ShuffledRDD [154147] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154148 [id="node_154148" labelType="html" label="CoalescedRDD [154148] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154149 [id="node_154149" labelType="html" label="MapPartitionsRDD [154149] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385679 { id="cluster_385679"; isCluster="true"; label="InMemoryTableScan"; 154211 [id="node_154211" labelType="html" label="MapPartitionsRDD [154211] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154212 [id="node_154212" labelType="html" label="MapPartitionsRDD [154212] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154213 [id="node_154213" labelType="html" label="MapPartitionsRDD [154213] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385678 { id="cluster_385678"; isCluster="true"; label="DeserializeToObject"; 154214 [id="node_154214" labelType="html" label="MapPartitionsRDD [154214] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385680 { id="cluster_385680"; isCluster="true"; label="mapPartitions"; 154216 [id="node_154216" labelType="html" label="MapPartitionsRDD [154216] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385681 { id="cluster_385681"; isCluster="true"; label="union"; 154217 [id="node_154217" labelType="html" label="UnionRDD [154217] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385682 { id="cluster_385682"; isCluster="true"; label="keyBy"; 154218 [id="node_154218" labelType="html" label="MapPartitionsRDD [154218] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 154089->154090; 154090->154091; 154147->154148; 154148->154149; 154091->154211; 154211->154212; 154212->154213; 154213->154214; 154214->154215; 154215->154216; 154149->154217; 154216->154217; 154217->154218; }

154088,154089

154146,154147

154149

154147

154148

154149

154217

154218

digraph G { id="graph_341275"; subgraph graph_stage_341275 { id="graph_stage_341275"; isCluster="true"; label="Stage 341275 (skipped)"; subgraph cluster_385691 { id="cluster_385691"; isCluster="true"; label="reduceByKey"; 154219 [id="node_154219" labelType="html" label="ShuffledRDD [154219] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385692 { id="cluster_385692"; isCluster="true"; label="map"; 154220 [id="node_154220" labelType="html" label="MapPartitionsRDD [154220] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385693 { id="cluster_385693"; isCluster="true"; label="repartition"; 154221 [id="node_154221" labelType="html" label="MapPartitionsRDD [154221] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 154219->154220; 154220->154221; }

154218,154219

154219

154220

154221

digraph G { id="graph_341276"; subgraph graph_stage_341276 { id="graph_stage_341276"; isCluster="true"; label="Stage 341276"; 154353 [id="node_154353" labelType="html" label="SQLExecutionRDD [154353] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; subgraph cluster_385693 { id="cluster_385693"; isCluster="true"; label="repartition"; 154222 [id="node_154222" labelType="html" label="ShuffledRDD [154222] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154223 [id="node_154223" labelType="html" label="CoalescedRDD [154223] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154224 [id="node_154224" labelType="html" label="MapPartitionsRDD [154224] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385982 { id="cluster_385982"; isCluster="true"; label="map"; 154350 [id="node_154350" labelType="html" label="MapPartitionsRDD [154350] [Indeterminate] createDataFrame at KpiCurveCacheImpl.java:230}"]; } subgraph cluster_385984 { id="cluster_385984"; isCluster="true"; label="WholeStageCodegen (1)"; 154351 [id="node_154351" labelType="html" label="MapPartitionsRDD [154351] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_385983 { id="cluster_385983"; isCluster="true"; label="DeserializeToObject"; 154352 [id="node_154352" labelType="html" label="MapPartitionsRDD [154352] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_385987 { id="cluster_385987"; isCluster="true"; label="mapPartitions"; 154354 [id="node_154354" labelType="html" label="MapPartitionsRDD [154354] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_385988 { id="cluster_385988"; isCluster="true"; label="repartition"; 154355 [id="node_154355" labelType="html" label="MapPartitionsRDD [154355] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } } 154222->154223; 154223->154224; 154224->154350; 154350->154351; 154351->154352; 154352->154353; 154353->154354; 154354->154355; }

154221,154222

154224

154353

154222

154223

154224

154350

154351

154352

154354

154355

digraph G { id="graph_341277"; subgraph graph_stage_341277 { id="graph_stage_341277"; isCluster="true"; label="Stage 341277"; subgraph cluster_385988 { id="cluster_385988"; isCluster="true"; label="repartition"; 154356 [id="node_154356" labelType="html" label="ShuffledRDD [154356] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 154357 [id="node_154357" labelType="html" label="CoalescedRDD [154357] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 154358 [id="node_154358" labelType="html" label="MapPartitionsRDD [154358] [Cached] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } } 154356->154357; 154357->154358; }

154355,154356

154358

154356

154357

154358

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
341277	tenants-pool-506	replenishmentRunId = 10000000532 tenantId = 8793759653749352888 activityType = TriggerOptimize activityId = 6813b2ad-7812-35f0-8d67-645c7ed180b0 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 7d5b0d3e-a8b4-3f66-a348-065089418e78 attempt = 1 cornerstoneTenantId = 8445 marketUnit = 10000_OP_PERF scenario = STANDARD 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.removeShardsFromCache(KpiCurveCacheImpl.java:101) 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)	2026/08/31 14:36:25	5 s	37/37			123.9 MiB
341276	tenants-pool-506	replenishmentRunId = 10000000532 tenantId = 8793759653749352888 activityType = TriggerOptimize activityId = 6813b2ad-7812-35f0-8d67-645c7ed180b0 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 7d5b0d3e-a8b4-3f66-a348-065089418e78 attempt = 1 cornerstoneTenantId = 8445 marketUnit = 10000_OP_PERF scenario = STANDARD 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)	2026/08/31 14:36:21	4 s	30/30	149.7 MiB			123.9 MiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

341277

tenants-pool-506

replenishmentRunId = 10000000532 tenantId = 8793759653749352888 activityType = TriggerOptimize activityId = 6813b2ad-7812-35f0-8d67-645c7ed180b0 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 7d5b0d3e-a8b4-3f66-a348-065089418e78 attempt = 1 cornerstoneTenantId = 8445 marketUnit = 10000_OP_PERF scenario = STANDARD 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.removeShardsFromCache(KpiCurveCacheImpl.java:101)
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)

2026/08/31 14:36:25

5 s

37/37

123.9 MiB

341276

tenants-pool-506

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)

2026/08/31 14:36:21

4 s

30/30

149.7 MiB

123.9 MiB

Page:

Skipped Stages (15)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
341275	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
341274	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
341273	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
341272	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
341271	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
341270	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
341269	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
341268	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
341267	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
341266	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
341265	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
341264	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
341263	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
341262	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
341261	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: