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

Status: SUCCEEDED
Submitted: 2026/08/31 14:22:41
Duration: 2 s
Associated SQL Query: 13530
Job Group: 21238029-8f83-4dda-9603-e1612427f49b
Completed Stages: 2
Skipped Stages: 3

Enable zooming

digraph G { id="graph_341218"; subgraph graph_stage_341218 { id="graph_stage_341218"; isCluster="true"; label="Stage 341218 (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_341219"; subgraph graph_stage_341219 { id="graph_stage_341219"; isCluster="true"; label="Stage 341219 (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_341220"; subgraph graph_stage_341220 { id="graph_stage_341220"; isCluster="true"; label="Stage 341220 (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_341221"; subgraph graph_stage_341221 { id="graph_stage_341221"; isCluster="true"; label="Stage 341221"; 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_385708 { id="cluster_385708"; isCluster="true"; label="map"; 154236 [id="node_154236" labelType="html" label="MapPartitionsRDD [154236] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385719 { id="cluster_385719"; isCluster="true"; label="WholeStageCodegen (1)"; 154237 [id="node_154237" labelType="html" label="MapPartitionsRDD [154237] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385718 { id="cluster_385718"; isCluster="true"; label="InMemoryTableScan"; 154238 [id="node_154238" labelType="html" label="MapPartitionsRDD [154238] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154239 [id="node_154239" labelType="html" label="*(1) Filter (isnotnull(shardId#3616660) AND (shardId#3616660 = 0_1_10000000532))\n+- *(1) Scan ExistingRDD[shardId#3616660,orderProposalId#3616661L,items#3616662,optimizationGroups#3616663,isOptimal#3616664,lastModified#3616665,optimizationInsights#3616666]\n [154239] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385742 { id="cluster_385742"; isCluster="true"; label="InMemoryTableScan"; 154248 [id="node_154248" labelType="html" label="MapPartitionsRDD [154248] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154249 [id="node_154249" labelType="html" label="MapPartitionsRDD [154249] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154250 [id="node_154250" labelType="html" label="MapPartitionsRDD [154250] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385739 { id="cluster_385739"; isCluster="true"; label="WholeStageCodegen (1)"; 154251 [id="node_154251" labelType="html" label="MapPartitionsRDD [154251] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385738 { id="cluster_385738"; isCluster="true"; label="InMemoryTableScan"; 154252 [id="node_154252" labelType="html" label="MapPartitionsRDD [154252] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154253 [id="node_154253" labelType="html" label="*(1) Filter (isnotnull(shardId#3616660) AND (shardId#3616660 = 0_1_10000000532))\n+- InMemoryTableScan [shardId#3616660, orderProposalId#3616661L, items#3616662, optimizationGroups#3616663, isOptimal#3616664, optimizationInsights#3616666], [isnotnull(shardId#3616660), (shardId#3616660 = 0_1_10000000532)]\n +- InMemoryRelation [shardId#3616660, orderProposalId#3616661L, items#3616662, optimizationGroups#3616663, isOptimal#3616664, lastModified#3616665, optimizationInsights#3616666], StorageLevel(disk, memory, 2 replicas)\n +- *(1) Filter (isnotnull(shardId#3616660) AND (shardId#3616660 = 0_1_10000000532))\n +- *(1) Scan ExistingRDD[shardId#3616660,orderProposalId#3616661L,items#3616662,optimizationGroups#3616663,isOptimal#3616664,lastModified#3616665,optimizationInsights#3616666]\n [154253] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154254 [id="node_154254" labelType="html" label="MapPartitionsRDD [154254] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154255 [id="node_154255" labelType="html" label="MapPartitionsRDD [154255] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154256 [id="node_154256" labelType="html" label="MapPartitionsRDD [154256] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385737 { id="cluster_385737"; isCluster="true"; label="CollectLimit"; 154257 [id="node_154257" labelType="html" label="MapPartitionsRDD [154257] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154258 [id="node_154258" labelType="html" label="MapPartitionsRDD [154258] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 153995->153996; 153996->153997; 153997->154236; 154236->154237; 154237->154238; 154238->154239; 154239->154248; 154248->154249; 154249->154250; 154250->154251; 154251->154252; 154252->154253; 154253->154254; 154254->154255; 154255->154256; 154256->154257; 154257->154258; }

153994,153995

153997

154239

154253

153995

153996

153997

154236

154237

154238

154239

154248

154249

154250

154251

154252

154253

154254

154255

154256

154257

154258

digraph G { id="graph_341222"; subgraph graph_stage_341222 { id="graph_stage_341222"; isCluster="true"; label="Stage 341222"; subgraph cluster_385737 { id="cluster_385737"; isCluster="true"; label="CollectLimit"; 154259 [id="node_154259" labelType="html" label="ShuffledRowRDD [154259] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154260 [id="node_154260" labelType="html" label="MapPartitionsRDD [154260] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385743 { id="cluster_385743"; isCluster="true"; label="mapPartitionsInternal"; 154261 [id="node_154261" labelType="html" label="MapPartitionsRDD [154261] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 154259->154260; 154260->154261; }

154258,154259

154259

154260

154261

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
341222	tenants-pool-506	stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 21238029-8f83-4dda-9603-e1612427f49b batch = 21 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:43	6 ms	1/1
341221	tenants-pool-506	stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 21238029-8f83-4dda-9603-e1612427f49b batch = 21 start at FileStorageAdapterImpl.java:596 +details RDD: (1) Filter (isnotnull(shardId#3616660) AND (shardId#3616660 = 0_1_10000000532)) +- (1) Scan ExistingRDD[shardId#3616660,orderProposalId#3616661L,items#3616662,optimizationGroups#3616663,isOptimal#3616664,lastModified#3616665,optimizationInsights#3616666] 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:41	0.9 s	30/30	630.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

341222

tenants-pool-506

stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 21238029-8f83-4dda-9603-e1612427f49b batch = 21 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:43

6 ms

1/1

341221

tenants-pool-506

stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 21238029-8f83-4dda-9603-e1612427f49b batch = 21 start at FileStorageAdapterImpl.java:596 +details

RDD: *(1) Filter (isnotnull(shardId#3616660) AND (shardId#3616660 = 0_1_10000000532)) +- *(1) Scan ExistingRDD[shardId#3616660,orderProposalId#3616661L,items#3616662,optimizationGroups#3616663,isOptimal#3616664,lastModified#3616665,optimizationInsights#3616666]

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

0.9 s

30/30

630.0 B

Page:

Skipped Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
341220	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
341219	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
341218	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

341220

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

341219

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

341218

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: