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

Status: SUCCEEDED
Submitted: 2026/07/21 20:59:45
Duration: 0.2 s
Associated SQL Query: 34838
Job Group: 881110fc-a22e-43dd-9ef6-858dd65243b7
Completed Stages: 2
Skipped Stages: 156

Event Timeline

Enable zooming

No DAG visualization information to display for job 47351

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
1345726	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 102 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/21 20:59:45	43 ms	1/1
1345725	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 102 start at FileStorageAdapterImpl.java:598 +details RDD: ObjectHashAggregate(keys=[shardId#5594062, resultSeparationId#5597941L], functions=[collect_list(orderProposal#5596205, 0, 0)], output=[shardId#5594062, resultSeparationId#5597941L, orderProposals#5597945]) +- Exchange hashpartitioning(shardId#5594062, resultSeparationId#5597941L, 30), ENSURE_REQUIREMENTS, [plan_id=2904443] +- ObjectHashAggregate(keys=[shardId#5594062, resultSeparationId#5597941L], functions=[partial_collect_list(orderProposal#5596205, 0, 0)], output=[shardId#5594062, resultSeparationId#5597941L, buf#5597981]) +- Project [shardId#5594062, orderProposal#5596205, CASE WHEN (size(orderProposal#5596205.parentItems, true) > 2000) THEN xxhash64(orderProposal#5596205.orderProposalId, 42) ELSE xxhash64(pmod(cast(orderProposal#5596205.orderProposalId as decimal(20,0)), 0), 42) END AS resultSeparationId#5597941L] +- InMemoryTableScan [orderProposal#5596205, shardId#5594062] +- InMemoryRelation [shardId#5594062, orderProposal#5596205], 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/21 20:59:45	0.1 s	30/30	630.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1345726

tenants-pool-169

stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 102 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/21 20:59:45

43 ms

1/1

1345725

tenants-pool-169

stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 102 start at FileStorageAdapterImpl.java:598 +details

RDD: ObjectHashAggregate(keys=[shardId#5594062, resultSeparationId#5597941L], functions=[collect_list(orderProposal#5596205, 0, 0)], output=[shardId#5594062, resultSeparationId#5597941L, orderProposals#5597945]) +- Exchange hashpartitioning(shardId#5594062, resultSeparationId#5597941L, 30), ENSURE_REQUIREMENTS, [plan_id=2904443] +- ObjectHashAggregate(keys=[shardId#5594062, resultSeparationId#5597941L], functions=[partial_collect_list(orderProposal#5596205, 0, 0)], output=[shardId#5594062, resultSeparationId#5597941L, buf#5597981]) +- Project [shardId#5594062, orderProposal#5596205, CASE WHEN (size(orderProposal#5596205.parentItems, true) > 2000) THEN xxhash64(orderProposal#5596205.orderProposalId, 42) ELSE xxhash64(pmod(cast(orderProposal#5596205.orderProposalId as decimal(20,0)), 0), 42) END AS resultSeparationId#5597941L] +- InMemoryTableScan [orderProposal#5596205, shardId#5594062] +- InMemoryRelation [shardId#5594062, orderProposal#5596205], 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/21 20:59:45

0.1 s

30/30

630.0 B

Page:

Skipped Stages (156)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total
1345724	Unknown +details Unknown	Unknown	Unknown	0/0
1345723	Unknown +details Unknown	Unknown	Unknown	0/0
1345722	Unknown +details Unknown	Unknown	Unknown	0/0
1345721	Unknown +details Unknown	Unknown	Unknown	0/0
1345720	Unknown +details Unknown	Unknown	Unknown	0/0
1345719	Unknown +details Unknown	Unknown	Unknown	0/0
1345718	Unknown +details Unknown	Unknown	Unknown	0/0
1345717	Unknown +details Unknown	Unknown	Unknown	0/0
1345716	Unknown +details Unknown	Unknown	Unknown	0/0
1345715	Unknown +details Unknown	Unknown	Unknown	0/0
1345714	Unknown +details Unknown	Unknown	Unknown	0/0
1345713	Unknown +details Unknown	Unknown	Unknown	0/0
1345712	Unknown +details Unknown	Unknown	Unknown	0/0
1345711	Unknown +details Unknown	Unknown	Unknown	0/0
1345710	Unknown +details Unknown	Unknown	Unknown	0/0
1345709	Unknown +details Unknown	Unknown	Unknown	0/0
1345708	Unknown +details Unknown	Unknown	Unknown	0/0
1345707	Unknown +details Unknown	Unknown	Unknown	0/0
1345706	Unknown +details Unknown	Unknown	Unknown	0/0
1345705	Unknown +details Unknown	Unknown	Unknown	0/0
1345704	Unknown +details Unknown	Unknown	Unknown	0/0
1345703	Unknown +details Unknown	Unknown	Unknown	0/0
1345702	Unknown +details Unknown	Unknown	Unknown	0/0
1345701	Unknown +details Unknown	Unknown	Unknown	0/0
1345700	Unknown +details Unknown	Unknown	Unknown	0/0
1345699	Unknown +details Unknown	Unknown	Unknown	0/0
1345698	Unknown +details Unknown	Unknown	Unknown	0/0
1345697	Unknown +details Unknown	Unknown	Unknown	0/0
1345696	Unknown +details Unknown	Unknown	Unknown	0/0
1345695	Unknown +details Unknown	Unknown	Unknown	0/0
1345694	Unknown +details Unknown	Unknown	Unknown	0/0
1345693	Unknown +details Unknown	Unknown	Unknown	0/0
1345692	Unknown +details Unknown	Unknown	Unknown	0/0
1345691	Unknown +details Unknown	Unknown	Unknown	0/0
1345690	Unknown +details Unknown	Unknown	Unknown	0/0
1345689	Unknown +details Unknown	Unknown	Unknown	0/0
1345688	Unknown +details Unknown	Unknown	Unknown	0/0
1345687	Unknown +details Unknown	Unknown	Unknown	0/0
1345686	Unknown +details Unknown	Unknown	Unknown	0/0
1345685	Unknown +details Unknown	Unknown	Unknown	0/0
1345684	Unknown +details Unknown	Unknown	Unknown	0/0
1345683	Unknown +details Unknown	Unknown	Unknown	0/0
1345682	Unknown +details Unknown	Unknown	Unknown	0/0
1345681	Unknown +details Unknown	Unknown	Unknown	0/0
1345680	Unknown +details Unknown	Unknown	Unknown	0/0
1345679	Unknown +details Unknown	Unknown	Unknown	0/0
1345678	Unknown +details Unknown	Unknown	Unknown	0/0
1345677	Unknown +details Unknown	Unknown	Unknown	0/0
1345676	Unknown +details Unknown	Unknown	Unknown	0/0
1345675	Unknown +details Unknown	Unknown	Unknown	0/0
1345674	Unknown +details Unknown	Unknown	Unknown	0/0
1345673	Unknown +details Unknown	Unknown	Unknown	0/0
1345672	Unknown +details Unknown	Unknown	Unknown	0/0
1345671	Unknown +details Unknown	Unknown	Unknown	0/0
1345670	Unknown +details Unknown	Unknown	Unknown	0/0
1345669	Unknown +details Unknown	Unknown	Unknown	0/0
1345668	Unknown +details Unknown	Unknown	Unknown	0/0
1345667	Unknown +details Unknown	Unknown	Unknown	0/0
1345666	Unknown +details Unknown	Unknown	Unknown	0/0
1345665	Unknown +details Unknown	Unknown	Unknown	0/0
1345664	Unknown +details Unknown	Unknown	Unknown	0/0
1345663	Unknown +details Unknown	Unknown	Unknown	0/0
1345662	Unknown +details Unknown	Unknown	Unknown	0/0
1345661	Unknown +details Unknown	Unknown	Unknown	0/0
1345660	Unknown +details Unknown	Unknown	Unknown	0/0
1345659	Unknown +details Unknown	Unknown	Unknown	0/0
1345658	Unknown +details Unknown	Unknown	Unknown	0/0
1345657	Unknown +details Unknown	Unknown	Unknown	0/0
1345656	Unknown +details Unknown	Unknown	Unknown	0/0
1345655	Unknown +details Unknown	Unknown	Unknown	0/0
1345654	Unknown +details Unknown	Unknown	Unknown	0/0
1345653	Unknown +details Unknown	Unknown	Unknown	0/0
1345652	Unknown +details Unknown	Unknown	Unknown	0/0
1345651	Unknown +details Unknown	Unknown	Unknown	0/0
1345650	Unknown +details Unknown	Unknown	Unknown	0/0
1345649	Unknown +details Unknown	Unknown	Unknown	0/0
1345648	Unknown +details Unknown	Unknown	Unknown	0/0
1345647	Unknown +details Unknown	Unknown	Unknown	0/0
1345646	Unknown +details Unknown	Unknown	Unknown	0/0
1345645	Unknown +details Unknown	Unknown	Unknown	0/0
1345644	Unknown +details Unknown	Unknown	Unknown	0/0
1345643	Unknown +details Unknown	Unknown	Unknown	0/0
1345642	Unknown +details Unknown	Unknown	Unknown	0/0
1345641	Unknown +details Unknown	Unknown	Unknown	0/0
1345640	Unknown +details Unknown	Unknown	Unknown	0/0
1345639	Unknown +details Unknown	Unknown	Unknown	0/0
1345638	Unknown +details Unknown	Unknown	Unknown	0/0
1345637	Unknown +details Unknown	Unknown	Unknown	0/0
1345636	Unknown +details Unknown	Unknown	Unknown	0/0
1345635	Unknown +details Unknown	Unknown	Unknown	0/0
1345634	Unknown +details Unknown	Unknown	Unknown	0/0
1345633	Unknown +details Unknown	Unknown	Unknown	0/0
1345632	Unknown +details Unknown	Unknown	Unknown	0/0
1345631	Unknown +details Unknown	Unknown	Unknown	0/0
1345630	Unknown +details Unknown	Unknown	Unknown	0/0
1345629	Unknown +details Unknown	Unknown	Unknown	0/0
1345628	Unknown +details Unknown	Unknown	Unknown	0/0
1345627	Unknown +details Unknown	Unknown	Unknown	0/0
1345626	Unknown +details Unknown	Unknown	Unknown	0/0
1345625	Unknown +details Unknown	Unknown	Unknown	0/0

Page: