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

Status: SUCCEEDED
Submitted: 2026/03/21 01:20:42
Duration: 0.2 s
Associated SQL Query: 3648
Job Group: 81faa882-918e-4a51-b5e3-3a01a5c048df
Completed Stages: 2
Skipped Stages: 106

Event Timeline

Enable zooming

No DAG visualization information to display for job 6537

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
119937	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:43	60 ms	37/37			92.0 B
119936	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: SortAggregate(key=[demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L, demandStream#1164564], functions=[first(kpis#1164592, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1164583, demandChannel#1164563, demandStream#1164564, kpis#1164725]) +- *(6) Sort [demandChannel#1164563 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1164583 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1164564 ASC NULLS FIRST], false, 0 +- Exchange hashpartitioning(demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L, demandStream#1164564, 37), ENSURE_REQUIREMENTS, [plan_id=1765755] +- SortAggregate(key=[demandChannel#1164563, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1164583)) AS qty#1164583, worklistShardItemId#1100458L, demandStream#1164564], functions=[partial_first(kpis#1164592, false)], output=[demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L,... 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:42	0.1 s	37/37	1272.0 B			92.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

119937

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

60 ms

37/37

92.0 B

119936

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: SortAggregate(key=[demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L, demandStream#1164564], functions=[first(kpis#1164592, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1164583, demandChannel#1164563, demandStream#1164564, kpis#1164725]) +- *(6) Sort [demandChannel#1164563 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1164583 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1164564 ASC NULLS FIRST], false, 0 +- Exchange hashpartitioning(demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L, demandStream#1164564, 37), ENSURE_REQUIREMENTS, [plan_id=1765755] +- SortAggregate(key=[demandChannel#1164563, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1164583)) AS qty#1164583, worklistShardItemId#1100458L, demandStream#1164564], functions=[partial_first(kpis#1164592, false)], output=[demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L,...

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

0.1 s

37/37

1272.0 B

92.0 B

Page:

Skipped Stages (106)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total
119935	Unknown +details Unknown	Unknown	Unknown	0/0
119934	Unknown +details Unknown	Unknown	Unknown	0/0
119933	Unknown +details Unknown	Unknown	Unknown	0/0
119932	Unknown +details Unknown	Unknown	Unknown	0/0
119931	Unknown +details Unknown	Unknown	Unknown	0/0
119930	Unknown +details Unknown	Unknown	Unknown	0/0
119929	Unknown +details Unknown	Unknown	Unknown	0/0
119928	Unknown +details Unknown	Unknown	Unknown	0/0
119927	Unknown +details Unknown	Unknown	Unknown	0/0
119926	Unknown +details Unknown	Unknown	Unknown	0/0
119925	Unknown +details Unknown	Unknown	Unknown	0/0
119924	Unknown +details Unknown	Unknown	Unknown	0/0
119923	Unknown +details Unknown	Unknown	Unknown	0/0
119922	Unknown +details Unknown	Unknown	Unknown	0/0
119921	Unknown +details Unknown	Unknown	Unknown	0/0
119920	Unknown +details Unknown	Unknown	Unknown	0/0
119919	Unknown +details Unknown	Unknown	Unknown	0/0
119918	Unknown +details Unknown	Unknown	Unknown	0/0
119917	Unknown +details Unknown	Unknown	Unknown	0/0
119916	Unknown +details Unknown	Unknown	Unknown	0/0
119915	Unknown +details Unknown	Unknown	Unknown	0/0
119914	Unknown +details Unknown	Unknown	Unknown	0/0
119913	Unknown +details Unknown	Unknown	Unknown	0/0
119912	Unknown +details Unknown	Unknown	Unknown	0/0
119911	Unknown +details Unknown	Unknown	Unknown	0/0
119910	Unknown +details Unknown	Unknown	Unknown	0/0
119909	Unknown +details Unknown	Unknown	Unknown	0/0
119908	Unknown +details Unknown	Unknown	Unknown	0/0
119907	Unknown +details Unknown	Unknown	Unknown	0/0
119906	Unknown +details Unknown	Unknown	Unknown	0/0
119905	Unknown +details Unknown	Unknown	Unknown	0/0
119904	Unknown +details Unknown	Unknown	Unknown	0/0
119903	Unknown +details Unknown	Unknown	Unknown	0/0
119902	Unknown +details Unknown	Unknown	Unknown	0/0
119901	Unknown +details Unknown	Unknown	Unknown	0/0
119900	Unknown +details Unknown	Unknown	Unknown	0/0
119899	Unknown +details Unknown	Unknown	Unknown	0/0
119898	Unknown +details Unknown	Unknown	Unknown	0/0
119897	Unknown +details Unknown	Unknown	Unknown	0/0
119896	Unknown +details Unknown	Unknown	Unknown	0/0
119895	Unknown +details Unknown	Unknown	Unknown	0/0
119894	Unknown +details Unknown	Unknown	Unknown	0/0
119893	Unknown +details Unknown	Unknown	Unknown	0/0
119892	Unknown +details Unknown	Unknown	Unknown	0/0
119891	Unknown +details Unknown	Unknown	Unknown	0/0
119890	Unknown +details Unknown	Unknown	Unknown	0/0
119889	Unknown +details Unknown	Unknown	Unknown	0/0
119888	Unknown +details Unknown	Unknown	Unknown	0/0
119887	Unknown +details Unknown	Unknown	Unknown	0/0
119886	Unknown +details Unknown	Unknown	Unknown	0/0
119885	Unknown +details Unknown	Unknown	Unknown	0/0
119884	Unknown +details Unknown	Unknown	Unknown	0/0
119883	Unknown +details Unknown	Unknown	Unknown	0/0
119882	Unknown +details Unknown	Unknown	Unknown	0/0
119881	Unknown +details Unknown	Unknown	Unknown	0/0
119880	Unknown +details Unknown	Unknown	Unknown	0/0
119879	Unknown +details Unknown	Unknown	Unknown	0/0
119878	Unknown +details Unknown	Unknown	Unknown	0/0
119877	Unknown +details Unknown	Unknown	Unknown	0/0
119876	Unknown +details Unknown	Unknown	Unknown	0/0
119875	Unknown +details Unknown	Unknown	Unknown	0/0
119874	Unknown +details Unknown	Unknown	Unknown	0/0
119873	Unknown +details Unknown	Unknown	Unknown	0/0
119872	Unknown +details Unknown	Unknown	Unknown	0/0
119871	Unknown +details Unknown	Unknown	Unknown	0/0
119870	Unknown +details Unknown	Unknown	Unknown	0/0
119869	Unknown +details Unknown	Unknown	Unknown	0/0
119868	Unknown +details Unknown	Unknown	Unknown	0/0
119867	Unknown +details Unknown	Unknown	Unknown	0/0
119866	Unknown +details Unknown	Unknown	Unknown	0/0
119865	Unknown +details Unknown	Unknown	Unknown	0/0
119864	Unknown +details Unknown	Unknown	Unknown	0/0
119863	Unknown +details Unknown	Unknown	Unknown	0/0
119862	Unknown +details Unknown	Unknown	Unknown	0/0
119861	Unknown +details Unknown	Unknown	Unknown	0/0
119860	Unknown +details Unknown	Unknown	Unknown	0/0
119859	Unknown +details Unknown	Unknown	Unknown	0/0
119858	Unknown +details Unknown	Unknown	Unknown	0/0
119857	Unknown +details Unknown	Unknown	Unknown	0/0
119856	Unknown +details Unknown	Unknown	Unknown	0/0
119855	Unknown +details Unknown	Unknown	Unknown	0/0
119854	Unknown +details Unknown	Unknown	Unknown	0/0
119853	Unknown +details Unknown	Unknown	Unknown	0/0
119852	Unknown +details Unknown	Unknown	Unknown	0/0
119851	Unknown +details Unknown	Unknown	Unknown	0/0
119850	Unknown +details Unknown	Unknown	Unknown	0/0
119849	Unknown +details Unknown	Unknown	Unknown	0/0
119848	Unknown +details Unknown	Unknown	Unknown	0/0
119847	Unknown +details Unknown	Unknown	Unknown	0/0
119846	Unknown +details Unknown	Unknown	Unknown	0/0
119845	Unknown +details Unknown	Unknown	Unknown	0/0
119844	Unknown +details Unknown	Unknown	Unknown	0/0
119843	Unknown +details Unknown	Unknown	Unknown	0/0
119842	Unknown +details Unknown	Unknown	Unknown	0/0
119841	Unknown +details Unknown	Unknown	Unknown	0/0
119840	Unknown +details Unknown	Unknown	Unknown	0/0
119839	Unknown +details Unknown	Unknown	Unknown	0/0
119838	Unknown +details Unknown	Unknown	Unknown	0/0
119837	Unknown +details Unknown	Unknown	Unknown	0/0
119836	Unknown +details Unknown	Unknown	Unknown	0/0

Page: