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

Status: SUCCEEDED
Submitted: 2026/07/22 02:22:44
Duration: 58 ms
Associated SQL Query: 41363
Job Group: 8fdff9a8-5e79-4dc5-83bf-49d519329d02
Completed Stages: 2
Skipped Stages: 145

Event Timeline

Enable zooming

No DAG visualization information to display for job 56596

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
1577436	tenants-pool-679	stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 50 start at FileStorageAdapterImpl.java:598 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/07/22 02:22:44	39 ms	1/1
1577435	tenants-pool-679	stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 50 start at FileStorageAdapterImpl.java:598 +details RDD: ObjectHashAggregate(keys=[shardId#6608407, resultSeparationId#6612302L], functions=[collect_list(orderProposal#6610550, 0, 0)], output=[shardId#6608407, resultSeparationId#6612302L, orderProposals#6612306]) +- Exchange hashpartitioning(shardId#6608407, resultSeparationId#6612302L, 30), ENSURE_REQUIREMENTS, [plan_id=3474009] +- ObjectHashAggregate(keys=[shardId#6608407, resultSeparationId#6612302L], functions=[partial_collect_list(orderProposal#6610550, 0, 0)], output=[shardId#6608407, resultSeparationId#6612302L, buf#6612342]) +- Project [shardId#6608407, orderProposal#6610550, CASE WHEN (size(orderProposal#6610550.parentItems, true) > 2000) THEN xxhash64(orderProposal#6610550.orderProposalId, 42) ELSE xxhash64(pmod(cast(orderProposal#6610550.orderProposalId as decimal(20,0)), 0), 42) END AS resultSeparationId#6612302L] +- InMemoryTableScan [orderProposal#6610550, shardId#6608407] +- InMemoryRelation [shardId#6608407, orderProposal#6610550], StorageLevel(disk, memory, 2 rep... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/07/22 02:22:44	15 ms	30/30	630.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1577436

tenants-pool-679

stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 50 start at FileStorageAdapterImpl.java:598 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
jdk.internal.reflect.GeneratedMethodAccessor658.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:105)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:332)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246)
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/07/22 02:22:44

39 ms

1/1

1577435

tenants-pool-679

stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 50 start at FileStorageAdapterImpl.java:598 +details

RDD: ObjectHashAggregate(keys=[shardId#6608407, resultSeparationId#6612302L], functions=[collect_list(orderProposal#6610550, 0, 0)], output=[shardId#6608407, resultSeparationId#6612302L, orderProposals#6612306]) +- Exchange hashpartitioning(shardId#6608407, resultSeparationId#6612302L, 30), ENSURE_REQUIREMENTS, [plan_id=3474009] +- ObjectHashAggregate(keys=[shardId#6608407, resultSeparationId#6612302L], functions=[partial_collect_list(orderProposal#6610550, 0, 0)], output=[shardId#6608407, resultSeparationId#6612302L, buf#6612342]) +- Project [shardId#6608407, orderProposal#6610550, CASE WHEN (size(orderProposal#6610550.parentItems, true) > 2000) THEN xxhash64(orderProposal#6610550.orderProposalId, 42) ELSE xxhash64(pmod(cast(orderProposal#6610550.orderProposalId as decimal(20,0)), 0), 42) END AS resultSeparationId#6612302L] +- InMemoryTableScan [orderProposal#6610550, shardId#6608407] +- InMemoryRelation [shardId#6608407, orderProposal#6610550], StorageLevel(disk, memory, 2 rep...

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
jdk.internal.reflect.GeneratedMethodAccessor658.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:105)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:332)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246)
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/07/22 02:22:44

15 ms

30/30

630.0 B

Page:

Skipped Stages (145)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total
1577434	Unknown +details Unknown	Unknown	Unknown	0/0
1577433	Unknown +details Unknown	Unknown	Unknown	0/0
1577432	Unknown +details Unknown	Unknown	Unknown	0/0
1577431	Unknown +details Unknown	Unknown	Unknown	0/0
1577430	Unknown +details Unknown	Unknown	Unknown	0/0
1577429	Unknown +details Unknown	Unknown	Unknown	0/0
1577428	Unknown +details Unknown	Unknown	Unknown	0/0
1577427	Unknown +details Unknown	Unknown	Unknown	0/0
1577426	Unknown +details Unknown	Unknown	Unknown	0/0
1577425	Unknown +details Unknown	Unknown	Unknown	0/0
1577424	Unknown +details Unknown	Unknown	Unknown	0/0
1577423	Unknown +details Unknown	Unknown	Unknown	0/0
1577422	Unknown +details Unknown	Unknown	Unknown	0/0
1577421	Unknown +details Unknown	Unknown	Unknown	0/0
1577420	Unknown +details Unknown	Unknown	Unknown	0/0
1577419	Unknown +details Unknown	Unknown	Unknown	0/0
1577418	Unknown +details Unknown	Unknown	Unknown	0/0
1577417	Unknown +details Unknown	Unknown	Unknown	0/0
1577416	Unknown +details Unknown	Unknown	Unknown	0/0
1577415	Unknown +details Unknown	Unknown	Unknown	0/0
1577414	Unknown +details Unknown	Unknown	Unknown	0/0
1577413	Unknown +details Unknown	Unknown	Unknown	0/0
1577412	Unknown +details Unknown	Unknown	Unknown	0/0
1577411	Unknown +details Unknown	Unknown	Unknown	0/0
1577410	Unknown +details Unknown	Unknown	Unknown	0/0
1577409	Unknown +details Unknown	Unknown	Unknown	0/0
1577408	Unknown +details Unknown	Unknown	Unknown	0/0
1577407	Unknown +details Unknown	Unknown	Unknown	0/0
1577406	Unknown +details Unknown	Unknown	Unknown	0/0
1577405	Unknown +details Unknown	Unknown	Unknown	0/0
1577404	Unknown +details Unknown	Unknown	Unknown	0/0
1577403	Unknown +details Unknown	Unknown	Unknown	0/0
1577402	Unknown +details Unknown	Unknown	Unknown	0/0
1577401	Unknown +details Unknown	Unknown	Unknown	0/0
1577400	Unknown +details Unknown	Unknown	Unknown	0/0
1577399	Unknown +details Unknown	Unknown	Unknown	0/0
1577398	Unknown +details Unknown	Unknown	Unknown	0/0
1577397	Unknown +details Unknown	Unknown	Unknown	0/0
1577396	Unknown +details Unknown	Unknown	Unknown	0/0
1577395	Unknown +details Unknown	Unknown	Unknown	0/0
1577394	Unknown +details Unknown	Unknown	Unknown	0/0
1577393	Unknown +details Unknown	Unknown	Unknown	0/0
1577392	Unknown +details Unknown	Unknown	Unknown	0/0
1577391	Unknown +details Unknown	Unknown	Unknown	0/0
1577390	Unknown +details Unknown	Unknown	Unknown	0/0
1577389	Unknown +details Unknown	Unknown	Unknown	0/0
1577388	Unknown +details Unknown	Unknown	Unknown	0/0
1577387	Unknown +details Unknown	Unknown	Unknown	0/0
1577386	Unknown +details Unknown	Unknown	Unknown	0/0
1577385	Unknown +details Unknown	Unknown	Unknown	0/0
1577384	Unknown +details Unknown	Unknown	Unknown	0/0
1577383	Unknown +details Unknown	Unknown	Unknown	0/0
1577382	Unknown +details Unknown	Unknown	Unknown	0/0
1577381	Unknown +details Unknown	Unknown	Unknown	0/0
1577380	Unknown +details Unknown	Unknown	Unknown	0/0
1577379	Unknown +details Unknown	Unknown	Unknown	0/0
1577378	Unknown +details Unknown	Unknown	Unknown	0/0
1577377	Unknown +details Unknown	Unknown	Unknown	0/0
1577376	Unknown +details Unknown	Unknown	Unknown	0/0
1577375	Unknown +details Unknown	Unknown	Unknown	0/0
1577374	Unknown +details Unknown	Unknown	Unknown	0/0
1577373	Unknown +details Unknown	Unknown	Unknown	0/0
1577372	Unknown +details Unknown	Unknown	Unknown	0/0
1577371	Unknown +details Unknown	Unknown	Unknown	0/0
1577370	Unknown +details Unknown	Unknown	Unknown	0/0
1577369	Unknown +details Unknown	Unknown	Unknown	0/0
1577368	Unknown +details Unknown	Unknown	Unknown	0/0
1577367	Unknown +details Unknown	Unknown	Unknown	0/0
1577366	Unknown +details Unknown	Unknown	Unknown	0/0
1577365	Unknown +details Unknown	Unknown	Unknown	0/0
1577364	Unknown +details Unknown	Unknown	Unknown	0/0
1577363	Unknown +details Unknown	Unknown	Unknown	0/0
1577362	Unknown +details Unknown	Unknown	Unknown	0/0
1577361	Unknown +details Unknown	Unknown	Unknown	0/0
1577360	Unknown +details Unknown	Unknown	Unknown	0/0
1577359	Unknown +details Unknown	Unknown	Unknown	0/0
1577358	Unknown +details Unknown	Unknown	Unknown	0/0
1577357	Unknown +details Unknown	Unknown	Unknown	0/0
1577356	Unknown +details Unknown	Unknown	Unknown	0/0
1577355	Unknown +details Unknown	Unknown	Unknown	0/0
1577354	Unknown +details Unknown	Unknown	Unknown	0/0
1577353	Unknown +details Unknown	Unknown	Unknown	0/0
1577352	Unknown +details Unknown	Unknown	Unknown	0/0
1577351	Unknown +details Unknown	Unknown	Unknown	0/0
1577350	Unknown +details Unknown	Unknown	Unknown	0/0
1577349	Unknown +details Unknown	Unknown	Unknown	0/0
1577348	Unknown +details Unknown	Unknown	Unknown	0/0
1577347	Unknown +details Unknown	Unknown	Unknown	0/0
1577346	Unknown +details Unknown	Unknown	Unknown	0/0
1577345	Unknown +details Unknown	Unknown	Unknown	0/0
1577344	Unknown +details Unknown	Unknown	Unknown	0/0
1577343	Unknown +details Unknown	Unknown	Unknown	0/0
1577342	Unknown +details Unknown	Unknown	Unknown	0/0
1577341	Unknown +details Unknown	Unknown	Unknown	0/0
1577340	Unknown +details Unknown	Unknown	Unknown	0/0
1577339	Unknown +details Unknown	Unknown	Unknown	0/0
1577338	Unknown +details Unknown	Unknown	Unknown	0/0
1577337	Unknown +details Unknown	Unknown	Unknown	0/0
1577336	Unknown +details Unknown	Unknown	Unknown	0/0
1577335	Unknown +details Unknown	Unknown	Unknown	0/0

Page: