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

Status: SUCCEEDED
Submitted: 2026/05/22 09:55:03
Duration: 5 s
Associated SQL Query: 25741
Job Group: 65cb8160-40af-4a1d-9ef7-845fbd048abf
Completed Stages: 10
Skipped Stages: 106

Enable zooming

No DAG visualization information to display for job 42829

Completed Stages (10)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Shuffle Read	Shuffle Write
1333604	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 39 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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/05/22 09:55:08	69 ms	1/1		2.1 KiB
1333603	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 39 start at FileStorageAdapterImpl.java:567 +details RDD: Project [shardId#5838667, named_struct(orderProposalId, _extract_orderProposalId#5841203L, originalReplenishmentRunId, _extract_originalReplenishmentRunId#5841195L, supplierGroup, _extract_supplierGroup#5841196, optimizationGroups, coalesce(optimizationGroups#5840543, []), supplier, _extract_supplier#5841197, supplyingPlant, _extract_supplyingPlant#5841198, orderDateTime, _extract_orderDateTime#5841199, itemGroups, _extract_itemGroups#5841200, previousOrderProposals, _extract_previousOrderProposals#5841201, parentItems, _extract_parentItems#5841202) AS orderProposal#5840645] +- BroadcastHashJoin [coalesce(shardId#5838667, ), isnull(shardId#5838667), coalesce(_extract_orderProposalId#5841203L, 0), isnull(_extract_orderProposalId#5841203L)], [coalesce(shardId#5840546, ), isnull(shardId#5840546), coalesce(orderProposalId#5840547L, 0), isnull(orderProposalId#5840547L)], LeftOuter, BuildRight, false :- Project [shardId#5838667, orderProposal#5840533.orderProposalId AS _extract_orderProposalId#5841194L, order... org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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/05/22 09:55:07	0.8 s	30/30		3.1 KiB	2.1 KiB
1333602	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 39 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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/05/22 09:55:07	0.6 s	30/30		8.3 KiB	3.1 KiB
1333601	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 39 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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/05/22 09:55:05	2 s	30/30		60.6 KiB	8.3 KiB
1333600	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 39 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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/05/22 09:55:03	0.3 s	30/30	27.1 KiB		4.9 KiB
1333599	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 39 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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/05/22 09:55:03	0.6 s	30/30	27.1 KiB		2.6 KiB
1333598	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 39 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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/05/22 09:55:03	0.6 s	30/30	27.1 KiB		45.5 KiB
1333597	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 39 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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/05/22 09:55:04	0.7 s	30/30		8.0 KiB	7.6 KiB
1333596	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 39 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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/05/22 09:55:03	0.6 s	8/8			7.4 KiB
1333595	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 39 start at FileStorageAdapterImpl.java:567 +details RDD: (1) Filter (isnotnull(shardId#5838667) AND (shardId#5838667 = 0_1_10000000246)) +- (1) Scan ExistingRDD[shardId#5838667,orderProposalId#5838668L,items#5838669,optimizationGroups#5838670,isOptimal#5838671,lastModified#5838672,optimizationInsights#5838673] org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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/05/22 09:55:03	0.3 s	30/30	977.0 B		670.0 B

Page:

Skipped Stages (106)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total
1333594	Unknown +details Unknown	Unknown	Unknown	0/0
1333593	Unknown +details Unknown	Unknown	Unknown	0/0
1333592	Unknown +details Unknown	Unknown	Unknown	0/0
1333591	Unknown +details Unknown	Unknown	Unknown	0/0
1333590	Unknown +details Unknown	Unknown	Unknown	0/0
1333589	Unknown +details Unknown	Unknown	Unknown	0/0
1333588	Unknown +details Unknown	Unknown	Unknown	0/0
1333587	Unknown +details Unknown	Unknown	Unknown	0/0
1333586	Unknown +details Unknown	Unknown	Unknown	0/0
1333585	Unknown +details Unknown	Unknown	Unknown	0/0
1333584	Unknown +details Unknown	Unknown	Unknown	0/0
1333583	Unknown +details Unknown	Unknown	Unknown	0/0
1333582	Unknown +details Unknown	Unknown	Unknown	0/0
1333581	Unknown +details Unknown	Unknown	Unknown	0/0
1333580	Unknown +details Unknown	Unknown	Unknown	0/0
1333579	Unknown +details Unknown	Unknown	Unknown	0/0
1333578	Unknown +details Unknown	Unknown	Unknown	0/0
1333577	Unknown +details Unknown	Unknown	Unknown	0/0
1333576	Unknown +details Unknown	Unknown	Unknown	0/0
1333575	Unknown +details Unknown	Unknown	Unknown	0/0
1333574	Unknown +details Unknown	Unknown	Unknown	0/0
1333573	Unknown +details Unknown	Unknown	Unknown	0/0
1333572	Unknown +details Unknown	Unknown	Unknown	0/0
1333571	Unknown +details Unknown	Unknown	Unknown	0/0
1333570	Unknown +details Unknown	Unknown	Unknown	0/0
1333569	Unknown +details Unknown	Unknown	Unknown	0/0
1333568	Unknown +details Unknown	Unknown	Unknown	0/0
1333567	Unknown +details Unknown	Unknown	Unknown	0/0
1333566	Unknown +details Unknown	Unknown	Unknown	0/0
1333565	Unknown +details Unknown	Unknown	Unknown	0/0
1333564	Unknown +details Unknown	Unknown	Unknown	0/0
1333563	Unknown +details Unknown	Unknown	Unknown	0/0
1333562	Unknown +details Unknown	Unknown	Unknown	0/0
1333561	Unknown +details Unknown	Unknown	Unknown	0/0
1333560	Unknown +details Unknown	Unknown	Unknown	0/0
1333559	Unknown +details Unknown	Unknown	Unknown	0/0
1333558	Unknown +details Unknown	Unknown	Unknown	0/0
1333557	Unknown +details Unknown	Unknown	Unknown	0/0
1333556	Unknown +details Unknown	Unknown	Unknown	0/0
1333555	Unknown +details Unknown	Unknown	Unknown	0/0
1333554	Unknown +details Unknown	Unknown	Unknown	0/0
1333553	Unknown +details Unknown	Unknown	Unknown	0/0
1333552	Unknown +details Unknown	Unknown	Unknown	0/0
1333551	Unknown +details Unknown	Unknown	Unknown	0/0
1333550	Unknown +details Unknown	Unknown	Unknown	0/0
1333549	Unknown +details Unknown	Unknown	Unknown	0/0
1333548	Unknown +details Unknown	Unknown	Unknown	0/0
1333547	Unknown +details Unknown	Unknown	Unknown	0/0
1333546	Unknown +details Unknown	Unknown	Unknown	0/0
1333545	Unknown +details Unknown	Unknown	Unknown	0/0
1333544	Unknown +details Unknown	Unknown	Unknown	0/0
1333543	Unknown +details Unknown	Unknown	Unknown	0/0
1333542	Unknown +details Unknown	Unknown	Unknown	0/0
1333541	Unknown +details Unknown	Unknown	Unknown	0/0
1333540	Unknown +details Unknown	Unknown	Unknown	0/0
1333539	Unknown +details Unknown	Unknown	Unknown	0/0
1333538	Unknown +details Unknown	Unknown	Unknown	0/0
1333537	Unknown +details Unknown	Unknown	Unknown	0/0
1333536	Unknown +details Unknown	Unknown	Unknown	0/0
1333535	Unknown +details Unknown	Unknown	Unknown	0/0
1333534	Unknown +details Unknown	Unknown	Unknown	0/0
1333533	Unknown +details Unknown	Unknown	Unknown	0/0
1333532	Unknown +details Unknown	Unknown	Unknown	0/0
1333531	Unknown +details Unknown	Unknown	Unknown	0/0
1333530	Unknown +details Unknown	Unknown	Unknown	0/0
1333529	Unknown +details Unknown	Unknown	Unknown	0/0
1333528	Unknown +details Unknown	Unknown	Unknown	0/0
1333527	Unknown +details Unknown	Unknown	Unknown	0/0
1333526	Unknown +details Unknown	Unknown	Unknown	0/0
1333525	Unknown +details Unknown	Unknown	Unknown	0/0
1333524	Unknown +details Unknown	Unknown	Unknown	0/0
1333523	Unknown +details Unknown	Unknown	Unknown	0/0
1333522	Unknown +details Unknown	Unknown	Unknown	0/0
1333521	Unknown +details Unknown	Unknown	Unknown	0/0
1333520	Unknown +details Unknown	Unknown	Unknown	0/0
1333519	Unknown +details Unknown	Unknown	Unknown	0/0
1333518	Unknown +details Unknown	Unknown	Unknown	0/0
1333517	Unknown +details Unknown	Unknown	Unknown	0/0
1333516	Unknown +details Unknown	Unknown	Unknown	0/0
1333515	Unknown +details Unknown	Unknown	Unknown	0/0
1333514	Unknown +details Unknown	Unknown	Unknown	0/0
1333513	Unknown +details Unknown	Unknown	Unknown	0/0
1333512	Unknown +details Unknown	Unknown	Unknown	0/0
1333511	Unknown +details Unknown	Unknown	Unknown	0/0
1333510	Unknown +details Unknown	Unknown	Unknown	0/0
1333509	Unknown +details Unknown	Unknown	Unknown	0/0
1333508	Unknown +details Unknown	Unknown	Unknown	0/0
1333507	Unknown +details Unknown	Unknown	Unknown	0/0
1333506	Unknown +details Unknown	Unknown	Unknown	0/0
1333505	Unknown +details Unknown	Unknown	Unknown	0/0
1333504	Unknown +details Unknown	Unknown	Unknown	0/0
1333503	Unknown +details Unknown	Unknown	Unknown	0/0
1333502	Unknown +details Unknown	Unknown	Unknown	0/0
1333501	Unknown +details Unknown	Unknown	Unknown	0/0
1333500	Unknown +details Unknown	Unknown	Unknown	0/0
1333499	Unknown +details Unknown	Unknown	Unknown	0/0
1333498	Unknown +details Unknown	Unknown	Unknown	0/0
1333497	Unknown +details Unknown	Unknown	Unknown	0/0
1333496	Unknown +details Unknown	Unknown	Unknown	0/0
1333495	Unknown +details Unknown	Unknown	Unknown	0/0

Page: