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

Status: SUCCEEDED
Submitted: 2026/08/31 14:22:06
Duration: 15 s
Associated SQL Query: 13512
Job Group: 688c595e-a841-4933-aa02-353eb721dac8
Completed Stages: 3
Skipped Stages: 5

Enable zooming

digraph G { id="graph_341146"; subgraph graph_stage_341146 { id="graph_stage_341146"; isCluster="true"; label="Stage 341146 (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_341147"; subgraph graph_stage_341147 { id="graph_stage_341147"; isCluster="true"; label="Stage 341147 (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_341148"; subgraph graph_stage_341148 { id="graph_stage_341148"; isCluster="true"; label="Stage 341148 (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_341149"; subgraph graph_stage_341149 { id="graph_stage_341149"; isCluster="true"; label="Stage 341149 (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_341150"; subgraph graph_stage_341150 { id="graph_stage_341150"; isCluster="true"; label="Stage 341150 (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_341151"; subgraph graph_stage_341151 { id="graph_stage_341151"; isCluster="true"; label="Stage 341151"; 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] [Cached] [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

154070

153986

153987

153988

154127

154128

digraph G { id="graph_341152"; subgraph graph_stage_341152 { id="graph_stage_341152"; isCluster="true"; label="Stage 341152"; 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_341153"; subgraph graph_stage_341153 { id="graph_stage_341153"; isCluster="true"; label="Stage 341153"; 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}"]; } } 154132->154133; 154133->154134; }

154131,154132

154134

154132

154133

154134

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Shuffle Read	Shuffle Write
341153	tenants-pool-506	stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 688c595e-a841-4933-aa02-353eb721dac8 batch = 20 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)	2026/08/31 14:22:17	4 s	30/30		71.8 MiB
341152	tenants-pool-506	stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 688c595e-a841-4933-aa02-353eb721dac8 batch = 20 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)	2026/08/31 14:22:12	5 s	37/37		82.3 MiB	71.8 MiB
341151	tenants-pool-506	stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 688c595e-a841-4933-aa02-353eb721dac8 batch = 20 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)	2026/08/31 14:22:06	6 s	60/60	57.1 MiB		82.3 MiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

341153

tenants-pool-506

stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 688c595e-a841-4933-aa02-353eb721dac8 batch = 20 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)

2026/08/31 14:22:17

4 s

30/30

71.8 MiB

341152

tenants-pool-506

stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 688c595e-a841-4933-aa02-353eb721dac8 batch = 20 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)

2026/08/31 14:22:12

5 s

37/37

82.3 MiB

71.8 MiB

341151

tenants-pool-506

stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 688c595e-a841-4933-aa02-353eb721dac8 batch = 20 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)

2026/08/31 14:22:06

6 s

60/60

57.1 MiB

82.3 MiB

Page:

Skipped Stages (5)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
341150	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
341149	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
341148	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
341147	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
341146	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: