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

Status: SUCCEEDED
Submitted: 2026/08/31 14:22:25
Duration: 0.6 s
Associated SQL Query: 13525
Job Group: 688c595e-a841-4933-aa02-353eb721dac8
Completed Stages: 2
Skipped Stages: 3

Enable zooming

digraph G { id="graph_341176"; subgraph graph_stage_341176 { id="graph_stage_341176"; isCluster="true"; label="Stage 341176 (skipped)"; 153810 [id="node_153810" labelType="html" label="SQLExecutionRDD [153810] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_381880 { id="cluster_381880"; isCluster="true"; label="map"; 152696 [id="node_152696" labelType="html" label="MapPartitionsRDD [152696] [Cached] [Indeterminate] map at PeriodicAsyncRDDCheckpointWriterImpl.java:207}"]; } subgraph cluster_381881 { id="cluster_381881"; isCluster="true"; label="checkpoint"; 152697 [id="node_152697" labelType="html" label="LocalCheckpointRDD [152697] count at OptimalQuantitiesCacheImpl.java:251}"]; } subgraph cluster_384806 { id="cluster_384806"; isCluster="true"; label="map"; 153799 [id="node_153799" labelType="html" label="MapPartitionsRDD [153799] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384812 { id="cluster_384812"; isCluster="true"; label="WholeStageCodegen (1)"; 153808 [id="node_153808" labelType="html" label="MapPartitionsRDD [153808] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384811 { id="cluster_384811"; isCluster="true"; label="DeserializeToObject"; 153809 [id="node_153809" labelType="html" label="MapPartitionsRDD [153809] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384817 { id="cluster_384817"; isCluster="true"; label="mapPartitions"; 153811 [id="node_153811" labelType="html" label="MapPartitionsRDD [153811] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384818 { id="cluster_384818"; isCluster="true"; label="repartition"; 153812 [id="node_153812" labelType="html" label="MapPartitionsRDD [153812] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 152697->152696; 152696->153799; 153799->153808; 153808->153809; 153809->153810; 153810->153811; 153811->153812; }

152696

153810

152696

153799

153808

153809

153811

153812

digraph G { id="graph_341177"; subgraph graph_stage_341177 { id="graph_stage_341177"; isCluster="true"; label="Stage 341177 (skipped)"; 153883 [id="node_153883" labelType="html" label="SQLExecutionRDD [153883] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_384818 { id="cluster_384818"; isCluster="true"; label="repartition"; 153813 [id="node_153813" labelType="html" label="ShuffledRDD [153813] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153814 [id="node_153814" labelType="html" label="CoalescedRDD [153814] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153815 [id="node_153815" labelType="html" label="MapPartitionsRDD [153815] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384959 { id="cluster_384959"; isCluster="true"; label="map"; 153877 [id="node_153877" labelType="html" label="MapPartitionsRDD [153877] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384970 { id="cluster_384970"; isCluster="true"; label="WholeStageCodegen (1)"; 153881 [id="node_153881" labelType="html" label="MapPartitionsRDD [153881] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384969 { id="cluster_384969"; isCluster="true"; label="DeserializeToObject"; 153882 [id="node_153882" labelType="html" label="MapPartitionsRDD [153882] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384973 { id="cluster_384973"; isCluster="true"; label="mapPartitions"; 153886 [id="node_153886" labelType="html" label="MapPartitionsRDD [153886] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384976 { id="cluster_384976"; isCluster="true"; label="repartition"; 153887 [id="node_153887" labelType="html" label="MapPartitionsRDD [153887] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 153813->153814; 153814->153815; 153815->153877; 153877->153881; 153881->153882; 153882->153883; 153883->153886; 153886->153887; }

153812,153813

153815

153883

153813

153814

153815

153877

153881

153882

153886

153887

digraph G { id="graph_341178"; subgraph graph_stage_341178 { id="graph_stage_341178"; isCluster="true"; label="Stage 341178 (skipped)"; 153992 [id="node_153992" labelType="html" label="SQLExecutionRDD [153992] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_384976 { id="cluster_384976"; isCluster="true"; label="repartition"; 153888 [id="node_153888" labelType="html" label="ShuffledRDD [153888] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153889 [id="node_153889" labelType="html" label="CoalescedRDD [153889] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153890 [id="node_153890" labelType="html" label="MapPartitionsRDD [153890] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385221 { id="cluster_385221"; isCluster="true"; label="map"; 153989 [id="node_153989" labelType="html" label="MapPartitionsRDD [153989] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385223 { id="cluster_385223"; isCluster="true"; label="WholeStageCodegen (1)"; 153990 [id="node_153990" labelType="html" label="MapPartitionsRDD [153990] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385222 { id="cluster_385222"; isCluster="true"; label="DeserializeToObject"; 153991 [id="node_153991" labelType="html" label="MapPartitionsRDD [153991] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385226 { id="cluster_385226"; isCluster="true"; label="mapPartitions"; 153993 [id="node_153993" labelType="html" label="MapPartitionsRDD [153993] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385227 { id="cluster_385227"; isCluster="true"; label="repartition"; 153994 [id="node_153994" labelType="html" label="MapPartitionsRDD [153994] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 153888->153889; 153889->153890; 153890->153989; 153989->153990; 153990->153991; 153991->153992; 153992->153993; 153993->153994; }

153887,153888

153890

153992

153888

153889

153890

153989

153990

153991

153993

153994

digraph G { id="graph_341179"; subgraph graph_stage_341179 { id="graph_stage_341179"; isCluster="true"; label="Stage 341179"; subgraph cluster_385227 { id="cluster_385227"; isCluster="true"; label="repartition"; 153995 [id="node_153995" labelType="html" label="ShuffledRDD [153995] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153996 [id="node_153996" labelType="html" label="CoalescedRDD [153996] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153997 [id="node_153997" labelType="html" label="MapPartitionsRDD [153997] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385548 { id="cluster_385548"; isCluster="true"; label="map"; 154161 [id="node_154161" labelType="html" label="MapPartitionsRDD [154161] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385559 { id="cluster_385559"; isCluster="true"; label="WholeStageCodegen (1)"; 154162 [id="node_154162" labelType="html" label="MapPartitionsRDD [154162] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385558 { id="cluster_385558"; isCluster="true"; label="InMemoryTableScan"; 154163 [id="node_154163" labelType="html" label="MapPartitionsRDD [154163] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154164 [id="node_154164" labelType="html" label="*(1) Filter (isnotnull(shardId#3615817) AND (shardId#3615817 = 0_7_10000000532))\n+- *(1) Scan ExistingRDD[shardId#3615817,orderProposalId#3615818L,items#3615819,optimizationGroups#3615820,isOptimal#3615821,lastModified#3615822,optimizationInsights#3615823]\n [154164] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385582 { id="cluster_385582"; isCluster="true"; label="InMemoryTableScan"; 154173 [id="node_154173" labelType="html" label="MapPartitionsRDD [154173] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154174 [id="node_154174" labelType="html" label="MapPartitionsRDD [154174] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154175 [id="node_154175" labelType="html" label="MapPartitionsRDD [154175] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385579 { id="cluster_385579"; isCluster="true"; label="WholeStageCodegen (1)"; 154176 [id="node_154176" labelType="html" label="MapPartitionsRDD [154176] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385578 { id="cluster_385578"; isCluster="true"; label="InMemoryTableScan"; 154177 [id="node_154177" labelType="html" label="MapPartitionsRDD [154177] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154178 [id="node_154178" labelType="html" label="*(1) Filter (isnotnull(shardId#3615817) AND (shardId#3615817 = 0_7_10000000532))\n+- InMemoryTableScan [shardId#3615817, orderProposalId#3615818L, items#3615819, optimizationGroups#3615820, isOptimal#3615821, optimizationInsights#3615823], [isnotnull(shardId#3615817), (shardId#3615817 = 0_7_10000000532)]\n +- InMemoryRelation [shardId#3615817, orderProposalId#3615818L, items#3615819, optimizationGroups#3615820, isOptimal#3615821, lastModified#3615822, optimizationInsights#3615823], StorageLevel(disk, memory, 2 replicas)\n +- *(1) Filter (isnotnull(shardId#3615817) AND (shardId#3615817 = 0_7_10000000532))\n +- *(1) Scan ExistingRDD[shardId#3615817,orderProposalId#3615818L,items#3615819,optimizationGroups#3615820,isOptimal#3615821,lastModified#3615822,optimizationInsights#3615823]\n [154178] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154179 [id="node_154179" labelType="html" label="MapPartitionsRDD [154179] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154180 [id="node_154180" labelType="html" label="MapPartitionsRDD [154180] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154181 [id="node_154181" labelType="html" label="MapPartitionsRDD [154181] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385577 { id="cluster_385577"; isCluster="true"; label="CollectLimit"; 154182 [id="node_154182" labelType="html" label="MapPartitionsRDD [154182] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154183 [id="node_154183" labelType="html" label="MapPartitionsRDD [154183] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 153995->153996; 153996->153997; 153997->154161; 154161->154162; 154162->154163; 154163->154164; 154164->154173; 154173->154174; 154174->154175; 154175->154176; 154176->154177; 154177->154178; 154178->154179; 154179->154180; 154180->154181; 154181->154182; 154182->154183; }

153994,153995

153997

154164

154178

153995

153996

153997

154161

154162

154163

154164

154173

154174

154175

154176

154177

154178

154179

154180

154181

154182

154183

digraph G { id="graph_341180"; subgraph graph_stage_341180 { id="graph_stage_341180"; isCluster="true"; label="Stage 341180"; subgraph cluster_385577 { id="cluster_385577"; isCluster="true"; label="CollectLimit"; 154184 [id="node_154184" labelType="html" label="ShuffledRowRDD [154184] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154185 [id="node_154185" labelType="html" label="MapPartitionsRDD [154185] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385583 { id="cluster_385583"; isCluster="true"; label="mapPartitionsInternal"; 154186 [id="node_154186" labelType="html" label="MapPartitionsRDD [154186] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 154184->154185; 154185->154186; }

154183,154184

154184

154185

154186

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
341180	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:25	13 ms	1/1
341179	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 RDD: (1) Filter (isnotnull(shardId#3615817) AND (shardId#3615817 = 0_7_10000000532)) +- (1) Scan ExistingRDD[shardId#3615817,orderProposalId#3615818L,items#3615819,optimizationGroups#3615820,isOptimal#3615821,lastModified#3615822,optimizationInsights#3615823] 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:25	0.4 s	30/30	630.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

341180

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

13 ms

1/1

341179

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

RDD: *(1) Filter (isnotnull(shardId#3615817) AND (shardId#3615817 = 0_7_10000000532)) +- *(1) Scan ExistingRDD[shardId#3615817,orderProposalId#3615818L,items#3615819,optimizationGroups#3615820,isOptimal#3615821,lastModified#3615822,optimizationInsights#3615823]

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

0.4 s

30/30

630.0 B

Page:

Skipped Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
341178	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
341177	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
341176	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

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

341178

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

0/30

341177

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

0/30

341176

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

0/30

Page: