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

Status: SUCCEEDED
Submitted: 2026/03/21 20:15:29
Duration: 2 s
Associated SQL Query: 3894
Job Group: 325a8812-9963-4820-9b32-c1b224f207b8
Completed Stages: 10
Skipped Stages: 78

Enable zooming

No DAG visualization information to display for job 6937

Completed Stages (10)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Shuffle Read	Shuffle Write
128284	tenants-pool-780	stream-10000000351-1 id = 61846efb-bf39-441e-8218-46744ddf0f0f runId = 325a8812-9963-4820-9b32-c1b224f207b8 batch = 13 start at FileStorageAdapterImpl.java:171 +details RDD: MapPartitionsRDD 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 20:15:31	0.4 s	37/37		4.1 KiB
128283	tenants-pool-780	stream-10000000351-1 id = 61846efb-bf39-441e-8218-46744ddf0f0f runId = 325a8812-9963-4820-9b32-c1b224f207b8 batch = 13 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 20:15:30	0.4 s	37/37		4.2 KiB	4.1 KiB
128282	tenants-pool-780	stream-10000000351-1 id = 61846efb-bf39-441e-8218-46744ddf0f0f runId = 325a8812-9963-4820-9b32-c1b224f207b8 batch = 13 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 20:15:30	0.1 s	37/37		7.9 KiB	4.0 KiB
128281	tenants-pool-780	stream-10000000351-1 id = 61846efb-bf39-441e-8218-46744ddf0f0f runId = 325a8812-9963-4820-9b32-c1b224f207b8 batch = 13 start at FileStorageAdapterImpl.java:171 +details RDD: (7) Project [shardId#1167367, worklistShardItemId#1167368L, version#1167369, product#1167370, plant#1167371, cachedQty#1245177 AS qty#1245179, demandChannel#1245172, demandStream#1245173, cachedKpis#1245178 AS kpis#1245180] +- (7) SortMergeJoin [worklistShardItemId#1167368L, shardId#1167367], [cachedWorklistShardItemId#1245176L, cachedShardId#1245175], Inner :- (4) Sort [worklistShardItemId#1167368L ASC NULLS FIRST, shardId#1167367 ASC NULLS FIRST], false, 0 : +- Exchange hashpartitioning(worklistShardItemId#1167368L, shardId#1167367, 37), ENSURE_REQUIREMENTS, [plan_id=1828370] : +- (3) HashAggregate(keys=[plant#1167371, shardId#1167367, version#1167369, worklistShardItemId#1167368L, product#1167370], functions=[], output=[shardId#1167367, worklistShardItemId#1167368L, version#1167369, product#1167370, plant#1167371]) : +- Exchange hashpartitioning(plant#1167371, shardId#1167367, version#1167369, worklistShardItemId#1167368L, product#1167370, 37), ENSURE_REQUIREMENTS, [plan_id=1...Union :- (5) Project [shardId#1167367, worklistShardItemId#1167368L, version#1167369, product#1167370, plant#1167371, qty#1167374, null AS demandChannel#1245412, null AS demandStream#1245413, [] AS kpis#1245447, true AS isNewlyCalculated#1245415] : +- (5) SortMergeJoin [coalesce(shardId#1167367, ), isnull(shardId#1167367), coalesce(worklistShardItemId#1167368L, 0), isnull(worklistShardItemId#1167368L), coalesce(version#1167369, 0), isnull(version#1167369), coalesce(product#1167370, ), isnull(product#1167370), coalesce(plant#1167371, ), isnull(plant#1167371), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1167374, 0.0))), isnull(qty#1167374)], [coalesce(shardId#1245404, ), isnull(shardId#1245404), coalesce(worklistShardItemId#1245405L, 0), isnull(worklistShardItemId#1245405L), coalesce(version#1245406, 0), isnull(version#1245406), coalesce(product#1245407, ), isnull(product#1245407), coalesce(plant#1245408, ), isnull(plant#1245408), 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 20:15:29	0.1 s	111/111	2.2 KiB	344.0 B	162.0 B
128280	tenants-pool-780	stream-10000000351-1 id = 61846efb-bf39-441e-8218-46744ddf0f0f runId = 325a8812-9963-4820-9b32-c1b224f207b8 batch = 13 start at FileStorageAdapterImpl.java:171 +details RDD: (7) Project [shardId#1167367, worklistShardItemId#1167368L, version#1167369, product#1167370, plant#1167371, cachedQty#1245177 AS qty#1245179, demandChannel#1245172, demandStream#1245173, cachedKpis#1245178 AS kpis#1245180] +- (7) SortMergeJoin [worklistShardItemId#1167368L, shardId#1167367], [cachedWorklistShardItemId#1245176L, cachedShardId#1245175], Inner :- (4) Sort [worklistShardItemId#1167368L ASC NULLS FIRST, shardId#1167367 ASC NULLS FIRST], false, 0 : +- Exchange hashpartitioning(worklistShardItemId#1167368L, shardId#1167367, 37), ENSURE_REQUIREMENTS, [plan_id=1828370] : +- (3) HashAggregate(keys=[plant#1167371, shardId#1167367, version#1167369, worklistShardItemId#1167368L, product#1167370], functions=[], output=[shardId#1167367, worklistShardItemId#1167368L, version#1167369, product#1167370, plant#1167371]) : +- Exchange hashpartitioning(plant#1167371, shardId#1167367, version#1167369, worklistShardItemId#1167368L, product#1167370, 37), ENSURE_REQUIREMENTS, [plan_id=1...Union :- (5) Project [shardId#1167367, worklistShardItemId#1167368L, version#1167369, product#1167370, plant#1167371, qty#1167374, null AS demandChannel#1245412, null AS demandStream#1245413, [] AS kpis#1245447, true AS isNewlyCalculated#1245415] : +- (5) SortMergeJoin [coalesce(shardId#1167367, ), isnull(shardId#1167367), coalesce(worklistShardItemId#1167368L, 0), isnull(worklistShardItemId#1167368L), coalesce(version#1167369, 0), isnull(version#1167369), coalesce(product#1167370, ), isnull(product#1167370), coalesce(plant#1167371, ), isnull(plant#1167371), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1167374, 0.0))), isnull(qty#1167374)], [coalesce(shardId#1245404, ), isnull(shardId#1245404), coalesce(worklistShardItemId#1245405L, 0), isnull(worklistShardItemId#1245405L), coalesce(version#1245406, 0), isnull(version#1245406), coalesce(product#1245407, ), isnull(product#1245407), coalesce(plant#1245408, ), isnull(plant#1245408), 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 20:15:29	0.2 s	74/74	2.2 KiB		344.0 B
128201	tenants-pool-780	stream-10000000351-1 id = 61846efb-bf39-441e-8218-46744ddf0f0f runId = 325a8812-9963-4820-9b32-c1b224f207b8 batch = 13 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 20:15:29	0.6 s	37/37		8.3 KiB	7.9 KiB
128200	tenants-pool-780	stream-10000000351-1 id = 61846efb-bf39-441e-8218-46744ddf0f0f runId = 325a8812-9963-4820-9b32-c1b224f207b8 batch = 13 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 20:15:29	0.5 s	37/37		7.9 KiB	392.0 B
128199	tenants-pool-780	stream-10000000351-1 id = 61846efb-bf39-441e-8218-46744ddf0f0f runId = 325a8812-9963-4820-9b32-c1b224f207b8 batch = 13 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 20:15:29	0.2 s	37/37		75.4 KiB	8.0 KiB
128198	tenants-pool-780	stream-10000000351-1 id = 61846efb-bf39-441e-8218-46744ddf0f0f runId = 325a8812-9963-4820-9b32-c1b224f207b8 batch = 13 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 20:15:29	0.2 s	1/1			75.4 KiB
128197	tenants-pool-780	stream-10000000351-1 id = 61846efb-bf39-441e-8218-46744ddf0f0f runId = 325a8812-9963-4820-9b32-c1b224f207b8 batch = 13 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 20:15:29	0.3 s	1/1			7.9 KiB

Page:

Skipped Stages (78)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total
128279	Unknown +details Unknown	Unknown	Unknown	0/0
128278	Unknown +details Unknown	Unknown	Unknown	0/0
128277	Unknown +details Unknown	Unknown	Unknown	0/0
128276	Unknown +details Unknown	Unknown	Unknown	0/0
128275	Unknown +details Unknown	Unknown	Unknown	0/0
128274	Unknown +details Unknown	Unknown	Unknown	0/0
128273	Unknown +details Unknown	Unknown	Unknown	0/0
128272	Unknown +details Unknown	Unknown	Unknown	0/0
128271	Unknown +details Unknown	Unknown	Unknown	0/0
128270	Unknown +details Unknown	Unknown	Unknown	0/0
128269	Unknown +details Unknown	Unknown	Unknown	0/0
128268	Unknown +details Unknown	Unknown	Unknown	0/0
128267	Unknown +details Unknown	Unknown	Unknown	0/0
128266	Unknown +details Unknown	Unknown	Unknown	0/0
128265	Unknown +details Unknown	Unknown	Unknown	0/0
128264	Unknown +details Unknown	Unknown	Unknown	0/0
128263	Unknown +details Unknown	Unknown	Unknown	0/0
128262	Unknown +details Unknown	Unknown	Unknown	0/0
128261	Unknown +details Unknown	Unknown	Unknown	0/0
128260	Unknown +details Unknown	Unknown	Unknown	0/0
128259	Unknown +details Unknown	Unknown	Unknown	0/0
128258	Unknown +details Unknown	Unknown	Unknown	0/0
128257	Unknown +details Unknown	Unknown	Unknown	0/0
128256	Unknown +details Unknown	Unknown	Unknown	0/0
128255	Unknown +details Unknown	Unknown	Unknown	0/0
128254	Unknown +details Unknown	Unknown	Unknown	0/0
128253	Unknown +details Unknown	Unknown	Unknown	0/0
128252	Unknown +details Unknown	Unknown	Unknown	0/0
128251	Unknown +details Unknown	Unknown	Unknown	0/0
128250	Unknown +details Unknown	Unknown	Unknown	0/0
128249	Unknown +details Unknown	Unknown	Unknown	0/0
128248	Unknown +details Unknown	Unknown	Unknown	0/0
128247	Unknown +details Unknown	Unknown	Unknown	0/0
128246	Unknown +details Unknown	Unknown	Unknown	0/0
128245	Unknown +details Unknown	Unknown	Unknown	0/0
128244	Unknown +details Unknown	Unknown	Unknown	0/0
128243	Unknown +details Unknown	Unknown	Unknown	0/0
128242	Unknown +details Unknown	Unknown	Unknown	0/0
128241	Unknown +details Unknown	Unknown	Unknown	0/0
128240	Unknown +details Unknown	Unknown	Unknown	0/0
128239	Unknown +details Unknown	Unknown	Unknown	0/0
128238	Unknown +details Unknown	Unknown	Unknown	0/0
128237	Unknown +details Unknown	Unknown	Unknown	0/0
128236	Unknown +details Unknown	Unknown	Unknown	0/0
128235	Unknown +details Unknown	Unknown	Unknown	0/0
128234	Unknown +details Unknown	Unknown	Unknown	0/0
128233	Unknown +details Unknown	Unknown	Unknown	0/0
128232	Unknown +details Unknown	Unknown	Unknown	0/0
128231	Unknown +details Unknown	Unknown	Unknown	0/0
128230	Unknown +details Unknown	Unknown	Unknown	0/0
128229	Unknown +details Unknown	Unknown	Unknown	0/0
128228	Unknown +details Unknown	Unknown	Unknown	0/0
128227	Unknown +details Unknown	Unknown	Unknown	0/0
128226	Unknown +details Unknown	Unknown	Unknown	0/0
128225	Unknown +details Unknown	Unknown	Unknown	0/0
128224	Unknown +details Unknown	Unknown	Unknown	0/0
128223	Unknown +details Unknown	Unknown	Unknown	0/0
128222	Unknown +details Unknown	Unknown	Unknown	0/0
128221	Unknown +details Unknown	Unknown	Unknown	0/0
128220	Unknown +details Unknown	Unknown	Unknown	0/0
128219	Unknown +details Unknown	Unknown	Unknown	0/0
128218	Unknown +details Unknown	Unknown	Unknown	0/0
128217	Unknown +details Unknown	Unknown	Unknown	0/0
128216	Unknown +details Unknown	Unknown	Unknown	0/0
128215	Unknown +details Unknown	Unknown	Unknown	0/0
128214	Unknown +details Unknown	Unknown	Unknown	0/0
128213	Unknown +details Unknown	Unknown	Unknown	0/0
128212	Unknown +details Unknown	Unknown	Unknown	0/0
128211	Unknown +details Unknown	Unknown	Unknown	0/0
128210	Unknown +details Unknown	Unknown	Unknown	0/0
128209	Unknown +details Unknown	Unknown	Unknown	0/0
128208	Unknown +details Unknown	Unknown	Unknown	0/0
128207	Unknown +details Unknown	Unknown	Unknown	0/0
128206	Unknown +details Unknown	Unknown	Unknown	0/0
128205	Unknown +details Unknown	Unknown	Unknown	0/0
128204	Unknown +details Unknown	Unknown	Unknown	0/0
128203	Unknown +details Unknown	Unknown	Unknown	0/0
128202	Unknown +details Unknown	Unknown	Unknown	0/0

Page: