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

Status: SUCCEEDED
Submitted: 2026/02/06 10:33:52
Duration: 0.2 s
Associated SQL Query: 117
Job Group: 4a9fac36-cbda-4d33-921d-3feccc1086b2
Completed Stages: 3
Skipped Stages: 1

Enable zooming

digraph G { subgraph clusterstage_458 { label="Stage 458 (skipped)"; 1213 [labelType="html" label="SQLExecutionRDD [1213] start at FileStorageAdapterImpl.java:529"]; subgraph cluster3183 { label="Scan parquet "; 1210 [labelType="html" label="FileScanRDD [1210] start at FileStorageAdapterImpl.java:529"]; 1211 [labelType="html" label="MapPartitionsRDD [1211] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3180 { label="WholeStageCodegen (1)"; 1212 [labelType="html" label="MapPartitionsRDD [1212] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3198 { label="WholeStageCodegen (1)"; 1214 [labelType="html" label="MapPartitionsRDD [1214] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3197 { label="HashAggregate"; 1215 [labelType="html" label="MapPartitionsRDD [1215] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3196 { label="Exchange"; 1216 [labelType="html" label="MapPartitionsRDD [1216] start at FileStorageAdapterImpl.java:529"]; } } 1210->1211; 1211->1212; 1212->1213; 1213->1214; 1214->1215; 1215->1216; }

digraph G { subgraph clusterstage_459 { label="Stage 459"; subgraph cluster3196 { label="Exchange"; 1217 [labelType="html" label="ShuffledRowRDD [1217] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3193 { label="WholeStageCodegen (2)"; 1218 [labelType="html" label="MapPartitionsRDD [1218] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3192 { label="Exchange"; 1219 [labelType="html" label="MapPartitionsRDD [1219] [Unordered] start at FileStorageAdapterImpl.java:529"]; } } 1217->1218; 1218->1219; }

1216,1217

digraph G { subgraph clusterstage_460 { label="Stage 460"; subgraph cluster3192 { label="Exchange"; 1220 [labelType="html" label="ShuffledRowRDD [1220] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3191 { label="InMemoryTableScan"; 1221 [labelType="html" label="MapPartitionsRDD [1221] [Unordered] start at FileStorageAdapterImpl.java:529"]; 1222 [labelType="html" label="Exchange hashpartitioning(worklistShardItemId#40837L, 25), REPARTITION_BY_NUM, [plan_id=12351]\n+- *(2) HashAggregate(keys=[demandChannel#40840, shardId#40836, kpis#40842, version#40838, qty#40839, worklistShardItemId#40837L, demandStream#40841], functions=[], output=[shardId#40836, worklistShardItemId#40837L, version#40838, qty#40839, demandChannel#40840, demandStream#40841, kpis#40842])\n +- Exchange hashpartitioning(demandChannel#40840, shardId#40836, kpis#40842, version#40838, qty#40839, worklistShardItemId#40837L, demandStream#40841, 25), ENSURE_REQUIREMENTS, [plan_id=12347]\n +- HashAggregate(keys=[demandChannel#40840, shardId#40836, knownfloatingpointnormalized(transform(kpis#40842, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#41483)) null else named_struct(label, lambda arg#41483.label, dateTime, lambda arg#41483.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#41483.value)))), lambda arg#41483, false))) AS kpis#40842, version#40838, knownfloatin... [1222] [Cached] [Unordered] start at FileStorageAdapterImpl.java:529"]; 1223 [labelType="html" label="MapPartitionsRDD [1223] [Unordered] start at FileStorageAdapterImpl.java:529"]; 1224 [labelType="html" label="MapPartitionsRDD [1224] [Unordered] start at FileStorageAdapterImpl.java:529"]; 1225 [labelType="html" label="MapPartitionsRDD [1225] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3188 { label="WholeStageCodegen (1)"; 1226 [labelType="html" label="MapPartitionsRDD [1226] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3187 { label="Exchange"; 1227 [labelType="html" label="MapPartitionsRDD [1227] [Unordered] start at FileStorageAdapterImpl.java:529"]; } } 1220->1221; 1221->1222; 1222->1223; 1223->1224; 1224->1225; 1225->1226; 1226->1227; }

1219,1220

1222

digraph G { subgraph clusterstage_461 { label="Stage 461"; subgraph cluster3187 { label="Exchange"; 1228 [labelType="html" label="ShuffledRowRDD [1228] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3184 { label="WholeStageCodegen (2)"; 1229 [labelType="html" label="MapPartitionsRDD [1229] [Unordered] start at FileStorageAdapterImpl.java:529"]; } subgraph cluster3200 { label="mapPartitionsInternal"; 1230 [labelType="html" label="MapPartitionsRDD [1230] [Unordered] start at FileStorageAdapterImpl.java:529"]; } } 1228->1229; 1229->1230; }

1227,1228

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
461	tenants-pool-286	stream-10000000096-1 id = 538121c1-b98a-4fa9-8b98-f54594a1c1ac runId = 4a9fac36-cbda-4d33-921d-3feccc1086b2 batch = 0 start at FileStorageAdapterImpl.java:529 +details org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:529) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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/02/06 10:33:53	37 ms	25/25
460	tenants-pool-286	stream-10000000096-1 id = 538121c1-b98a-4fa9-8b98-f54594a1c1ac runId = 4a9fac36-cbda-4d33-921d-3feccc1086b2 batch = 0 start at FileStorageAdapterImpl.java:529 +details org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:529) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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/02/06 10:33:52	0.1 s	25/25
459	tenants-pool-286	stream-10000000096-1 id = 538121c1-b98a-4fa9-8b98-f54594a1c1ac runId = 4a9fac36-cbda-4d33-921d-3feccc1086b2 batch = 0 start at FileStorageAdapterImpl.java:529 +details org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:529) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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/02/06 10:33:52	54 ms	25/25

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

461

tenants-pool-286

stream-10000000096-1 id = 538121c1-b98a-4fa9-8b98-f54594a1c1ac runId = 4a9fac36-cbda-4d33-921d-3feccc1086b2 batch = 0 start at FileStorageAdapterImpl.java:529 +details

org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:529)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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/02/06 10:33:53

37 ms

25/25

460

tenants-pool-286

stream-10000000096-1 id = 538121c1-b98a-4fa9-8b98-f54594a1c1ac runId = 4a9fac36-cbda-4d33-921d-3feccc1086b2 batch = 0 start at FileStorageAdapterImpl.java:529 +details

org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:529)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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/02/06 10:33:52

0.1 s

25/25

459

tenants-pool-286

stream-10000000096-1 id = 538121c1-b98a-4fa9-8b98-f54594a1c1ac runId = 4a9fac36-cbda-4d33-921d-3feccc1086b2 batch = 0 start at FileStorageAdapterImpl.java:529 +details

org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:529)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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/02/06 10:33:52

54 ms

25/25

Page:

Skipped Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
458	default	start at FileStorageAdapterImpl.java:529 +details org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:529) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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)	Unknown	Unknown	0/0

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

458

default

start at FileStorageAdapterImpl.java:529 +details

org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:529)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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)

Unknown

0/0

Page: