crp-order-quantity-kpi-service - Details for Job 6535

Status: SUCCEEDED
Submitted: 2026/03/21 01:20:41
Duration: 0.4 s
Associated SQL Query: 3646
Job Group: 81faa882-918e-4a51-b5e3-3a01a5c048df
Completed Stages: 2
Skipped Stages: 96

Event Timeline

Enable zooming

No DAG visualization information to display for job 6535

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
119722	tenants-pool-780	stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 10 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) jdk.internal.reflect.GeneratedMethodAccessor1635.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:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) 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/03/21 01:20:41	0.2 s	37/37			178.0 B
119721	tenants-pool-780	stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 10 start at FileStorageAdapterImpl.java:171 +details RDD: (7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1161792 AS qty#1161794, demandChannel#1161787, demandStream#1161788, cachedKpis#1161793 AS kpis#1161795] +- (7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1161791L, cachedShardId#1161790], Inner :- (4) Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0 : +- Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1764825] : +- (3) HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[], output=[shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]) : +- Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1...Union :- (5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1162027, null AS demandStream#1162028, [] AS kpis#1162062, true AS isNewlyCalculated#1162030] : +- (5) SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1162019, ), isnull(shardId#1162019), coalesce(worklistShardItemId#1162020L, 0), isnull(worklistShardItemId#1162020L), coalesce(version#1162021, 0), isnull(version#1162021), coalesce(product#1162022, ), isnull(product#1162022), coalesce(plant#1162023, ), isnull(plant#1162023), knownfloatingpointnormalized(normalizenanandzero(coalesce... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) jdk.internal.reflect.GeneratedMethodAccessor1635.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:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) 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/03/21 01:20:41	0.2 s	74/74	1897.0 B			178.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

119722

tenants-pool-780

stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 10 start at FileStorageAdapterImpl.java:171 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63)
jdk.internal.reflect.GeneratedMethodAccessor1635.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:294)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76)
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/03/21 01:20:41

0.2 s

37/37

178.0 B

119721

tenants-pool-780

stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 10 start at FileStorageAdapterImpl.java:171 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63)
jdk.internal.reflect.GeneratedMethodAccessor1635.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:294)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76)
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/03/21 01:20:41

0.2 s

74/74

1897.0 B

178.0 B

Page:

Skipped Stages (96)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total
119720	Unknown +details Unknown	Unknown	Unknown	0/0
119719	Unknown +details Unknown	Unknown	Unknown	0/0
119718	Unknown +details Unknown	Unknown	Unknown	0/0
119717	Unknown +details Unknown	Unknown	Unknown	0/0
119716	Unknown +details Unknown	Unknown	Unknown	0/0
119715	Unknown +details Unknown	Unknown	Unknown	0/0
119714	Unknown +details Unknown	Unknown	Unknown	0/0
119713	Unknown +details Unknown	Unknown	Unknown	0/0
119712	Unknown +details Unknown	Unknown	Unknown	0/0
119711	Unknown +details Unknown	Unknown	Unknown	0/0
119710	Unknown +details Unknown	Unknown	Unknown	0/0
119709	Unknown +details Unknown	Unknown	Unknown	0/0
119708	Unknown +details Unknown	Unknown	Unknown	0/0
119707	Unknown +details Unknown	Unknown	Unknown	0/0
119706	Unknown +details Unknown	Unknown	Unknown	0/0
119705	Unknown +details Unknown	Unknown	Unknown	0/0
119704	Unknown +details Unknown	Unknown	Unknown	0/0
119703	Unknown +details Unknown	Unknown	Unknown	0/0
119702	Unknown +details Unknown	Unknown	Unknown	0/0
119701	Unknown +details Unknown	Unknown	Unknown	0/0
119700	Unknown +details Unknown	Unknown	Unknown	0/0
119699	Unknown +details Unknown	Unknown	Unknown	0/0
119698	Unknown +details Unknown	Unknown	Unknown	0/0
119697	Unknown +details Unknown	Unknown	Unknown	0/0
119696	Unknown +details Unknown	Unknown	Unknown	0/0
119695	Unknown +details Unknown	Unknown	Unknown	0/0
119694	Unknown +details Unknown	Unknown	Unknown	0/0
119693	Unknown +details Unknown	Unknown	Unknown	0/0
119692	Unknown +details Unknown	Unknown	Unknown	0/0
119691	Unknown +details Unknown	Unknown	Unknown	0/0
119690	Unknown +details Unknown	Unknown	Unknown	0/0
119689	Unknown +details Unknown	Unknown	Unknown	0/0
119688	Unknown +details Unknown	Unknown	Unknown	0/0
119687	Unknown +details Unknown	Unknown	Unknown	0/0
119686	Unknown +details Unknown	Unknown	Unknown	0/0
119685	Unknown +details Unknown	Unknown	Unknown	0/0
119684	Unknown +details Unknown	Unknown	Unknown	0/0
119683	Unknown +details Unknown	Unknown	Unknown	0/0
119682	Unknown +details Unknown	Unknown	Unknown	0/0
119681	Unknown +details Unknown	Unknown	Unknown	0/0
119680	Unknown +details Unknown	Unknown	Unknown	0/0
119679	Unknown +details Unknown	Unknown	Unknown	0/0
119678	Unknown +details Unknown	Unknown	Unknown	0/0
119677	Unknown +details Unknown	Unknown	Unknown	0/0
119676	Unknown +details Unknown	Unknown	Unknown	0/0
119675	Unknown +details Unknown	Unknown	Unknown	0/0
119674	Unknown +details Unknown	Unknown	Unknown	0/0
119673	Unknown +details Unknown	Unknown	Unknown	0/0
119672	Unknown +details Unknown	Unknown	Unknown	0/0
119671	Unknown +details Unknown	Unknown	Unknown	0/0
119670	Unknown +details Unknown	Unknown	Unknown	0/0
119669	Unknown +details Unknown	Unknown	Unknown	0/0
119668	Unknown +details Unknown	Unknown	Unknown	0/0
119667	Unknown +details Unknown	Unknown	Unknown	0/0
119666	Unknown +details Unknown	Unknown	Unknown	0/0
119665	Unknown +details Unknown	Unknown	Unknown	0/0
119664	Unknown +details Unknown	Unknown	Unknown	0/0
119663	Unknown +details Unknown	Unknown	Unknown	0/0
119662	Unknown +details Unknown	Unknown	Unknown	0/0
119661	Unknown +details Unknown	Unknown	Unknown	0/0
119660	Unknown +details Unknown	Unknown	Unknown	0/0
119659	Unknown +details Unknown	Unknown	Unknown	0/0
119658	Unknown +details Unknown	Unknown	Unknown	0/0
119657	Unknown +details Unknown	Unknown	Unknown	0/0
119656	Unknown +details Unknown	Unknown	Unknown	0/0
119655	Unknown +details Unknown	Unknown	Unknown	0/0
119654	Unknown +details Unknown	Unknown	Unknown	0/0
119653	Unknown +details Unknown	Unknown	Unknown	0/0
119652	Unknown +details Unknown	Unknown	Unknown	0/0
119651	Unknown +details Unknown	Unknown	Unknown	0/0
119650	Unknown +details Unknown	Unknown	Unknown	0/0
119649	Unknown +details Unknown	Unknown	Unknown	0/0
119648	Unknown +details Unknown	Unknown	Unknown	0/0
119647	Unknown +details Unknown	Unknown	Unknown	0/0
119646	Unknown +details Unknown	Unknown	Unknown	0/0
119645	Unknown +details Unknown	Unknown	Unknown	0/0
119644	Unknown +details Unknown	Unknown	Unknown	0/0
119643	Unknown +details Unknown	Unknown	Unknown	0/0
119642	Unknown +details Unknown	Unknown	Unknown	0/0
119641	Unknown +details Unknown	Unknown	Unknown	0/0
119640	Unknown +details Unknown	Unknown	Unknown	0/0
119639	Unknown +details Unknown	Unknown	Unknown	0/0
119638	Unknown +details Unknown	Unknown	Unknown	0/0
119637	Unknown +details Unknown	Unknown	Unknown	0/0
119636	Unknown +details Unknown	Unknown	Unknown	0/0
119635	Unknown +details Unknown	Unknown	Unknown	0/0
119634	Unknown +details Unknown	Unknown	Unknown	0/0
119633	Unknown +details Unknown	Unknown	Unknown	0/0
119632	Unknown +details Unknown	Unknown	Unknown	0/0
119631	Unknown +details Unknown	Unknown	Unknown	0/0
119630	Unknown +details Unknown	Unknown	Unknown	0/0
119629	Unknown +details Unknown	Unknown	Unknown	0/0
119628	Unknown +details Unknown	Unknown	Unknown	0/0
119627	Unknown +details Unknown	Unknown	Unknown	0/0
119626	Unknown +details Unknown	Unknown	Unknown	0/0
119625	Unknown +details Unknown	Unknown	Unknown	0/0

Page: