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

Status: SUCCEEDED
Submitted: 2026/08/31 14:22:58
Duration: 0.8 s
Associated SQL Query: 13533
Job Group: 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d
Completed Stages: 2
Skipped Stages: 3

Enable zooming

digraph G { id="graph_341239"; subgraph graph_stage_341239 { id="graph_stage_341239"; isCluster="true"; label="Stage 341239 (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_341240"; subgraph graph_stage_341240 { id="graph_stage_341240"; isCluster="true"; label="Stage 341240 (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_341241"; subgraph graph_stage_341241 { id="graph_stage_341241"; isCluster="true"; label="Stage 341241 (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_341242"; subgraph graph_stage_341242 { id="graph_stage_341242"; isCluster="true"; label="Stage 341242"; 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_385860 { id="cluster_385860"; isCluster="true"; label="map"; 154297 [id="node_154297" labelType="html" label="MapPartitionsRDD [154297] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385871 { id="cluster_385871"; isCluster="true"; label="WholeStageCodegen (1)"; 154298 [id="node_154298" labelType="html" label="MapPartitionsRDD [154298] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385870 { id="cluster_385870"; isCluster="true"; label="InMemoryTableScan"; 154299 [id="node_154299" labelType="html" label="MapPartitionsRDD [154299] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154300 [id="node_154300" labelType="html" label="*(1) Filter (isnotnull(shardId#3617344) AND (shardId#3617344 = 0_3_10000000532))\n+- *(1) Scan ExistingRDD[shardId#3617344,orderProposalId#3617345L,items#3617346,optimizationGroups#3617347,isOptimal#3617348,lastModified#3617349,optimizationInsights#3617350]\n [154300] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154301 [id="node_154301" labelType="html" label="MapPartitionsRDD [154301] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154302 [id="node_154302" labelType="html" label="MapPartitionsRDD [154302] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154303 [id="node_154303" labelType="html" label="MapPartitionsRDD [154303] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385865 { id="cluster_385865"; isCluster="true"; label="WholeStageCodegen (1)"; 154304 [id="node_154304" labelType="html" label="MapPartitionsRDD [154304] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385864 { id="cluster_385864"; isCluster="true"; label="Exchange"; 154305 [id="node_154305" labelType="html" label="MapPartitionsRDD [154305] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 153995->153996; 153996->153997; 153997->154297; 154297->154298; 154298->154299; 154299->154300; 154300->154301; 154301->154302; 154302->154303; 154303->154304; 154304->154305; }

153994,153995

153997

154300

153995

153996

153997

154297

154298

154299

154300

154301

154302

154303

154304

154305

digraph G { id="graph_341243"; subgraph graph_stage_341243 { id="graph_stage_341243"; isCluster="true"; label="Stage 341243"; subgraph cluster_385864 { id="cluster_385864"; isCluster="true"; label="Exchange"; 154306 [id="node_154306" labelType="html" label="ShuffledRowRDD [154306] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385861 { id="cluster_385861"; isCluster="true"; label="WholeStageCodegen (2)"; 154307 [id="node_154307" labelType="html" label="MapPartitionsRDD [154307] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385874 { id="cluster_385874"; isCluster="true"; label="mapPartitionsInternal"; 154308 [id="node_154308" labelType="html" label="MapPartitionsRDD [154308] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 154306->154307; 154307->154308; }

154305,154306

154306

154307

154308

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
341243	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d batch = 17 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:59	0.2 s	30/30
341242	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d batch = 17 start at FileStorageAdapterImpl.java:596 +details RDD: (1) Filter (isnotnull(shardId#3617344) AND (shardId#3617344 = 0_3_10000000532)) +- (1) Scan ExistingRDD[shardId#3617344,orderProposalId#3617345L,items#3617346,optimizationGroups#3617347,isOptimal#3617348,lastModified#3617349,optimizationInsights#3617350] 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:58	0.6 s	30/30	630.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

341243

tenants-pool-506

stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d batch = 17 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:59

0.2 s

30/30

341242

tenants-pool-506

stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d batch = 17 start at FileStorageAdapterImpl.java:596 +details

RDD: *(1) Filter (isnotnull(shardId#3617344) AND (shardId#3617344 = 0_3_10000000532)) +- *(1) Scan ExistingRDD[shardId#3617344,orderProposalId#3617345L,items#3617346,optimizationGroups#3617347,isOptimal#3617348,lastModified#3617349,optimizationInsights#3617350]

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

0.6 s

30/30

630.0 B

Page:

Skipped Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
341241	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
341240	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
341239	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

341241

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

341240

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

341239

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: