|
31
|
replenishmentRunId = 10000000902 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = b194c067-6245-3131-ba7b-65c470fe45a7 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 1d59eea7-23ff-3984-8e52-305b4ad53466 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD
+details
replenishmentRunId = 10000000902 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = b194c067-6245-3131-ba7b-65c470fe45a7 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 1d59eea7-23ff-3984-8e52-305b4ad53466 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
jdk.internal.reflect.GeneratedMethodAccessor358.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/06/10 23:45:31
|
19 ms
|
[31]
|
|
30
|
replenishmentRunId = 10000000897 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = 47846976-2a6e-3d2f-9a4d-edd5ec4077aa workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 2a1b8a27-e1ed-358f-b982-72199cb19ad3 attempt = 1 cornerstoneTenantId = 8378 marketUnit = FALLBACK_INSIGHT scenario = STANDARD
+details
replenishmentRunId = 10000000897 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = 47846976-2a6e-3d2f-9a4d-edd5ec4077aa workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 2a1b8a27-e1ed-358f-b982-72199cb19ad3 attempt = 1 cornerstoneTenantId = 8378 marketUnit = FALLBACK_INSIGHT scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
jdk.internal.reflect.GeneratedMethodAccessor358.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/06/10 23:17:38
|
17 ms
|
[30]
|
|
29
|
replenishmentRunId = 10000001690 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = b729ecf9-796b-3013-9dce-adc100c509fc workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 14911a66-7215-3ba9-8be7-c5eff1026ab3 attempt = 1 cornerstoneTenantId = 8449 marketUnit = Daily_Grocery scenario = STANDARD
+details
replenishmentRunId = 10000001690 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = b729ecf9-796b-3013-9dce-adc100c509fc workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 14911a66-7215-3ba9-8be7-c5eff1026ab3 attempt = 1 cornerstoneTenantId = 8449 marketUnit = Daily_Grocery scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
jdk.internal.reflect.GeneratedMethodAccessor358.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/06/10 23:12:11
|
18 ms
|
[29]
|
|
28
|
replenishmentRunId = 10000001689 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = a2ec44b3-7849-39ed-aef5-89335ba342e9 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = bf24c164-7193-383f-83ca-25dd8955c2ae attempt = 1 cornerstoneTenantId = 8449 marketUnit = Grocery_SS scenario = STANDARD
+details
replenishmentRunId = 10000001689 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = a2ec44b3-7849-39ed-aef5-89335ba342e9 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = bf24c164-7193-383f-83ca-25dd8955c2ae attempt = 1 cornerstoneTenantId = 8449 marketUnit = Grocery_SS scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
jdk.internal.reflect.GeneratedMethodAccessor358.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/06/10 23:00:22
|
19 ms
|
[28]
|
|
27
|
replenishmentRunId = 10000001692 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 555929e3-a441-3831-8cfe-984098faf746 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 72af70e4-dea4-3ceb-9f3b-6492a077a71c attempt = 1 cornerstoneTenantId = 8449 marketUnit = ani-test scenario = STANDARD
+details
replenishmentRunId = 10000001692 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 555929e3-a441-3831-8cfe-984098faf746 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 72af70e4-dea4-3ceb-9f3b-6492a077a71c attempt = 1 cornerstoneTenantId = 8449 marketUnit = ani-test scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
jdk.internal.reflect.GeneratedMethodAccessor358.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/06/10 22:55:05
|
18 ms
|
[27]
|
|
26
|
replenishmentRunId = 10000001691 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 299f054a-84a2-3ec3-a73e-bd40e2662fca workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = c7481d65-cba4-3443-a0b6-425b5ad98130 attempt = 1 cornerstoneTenantId = 8449 marketUnit = Kyma_Test_24 scenario = STANDARD
+details
replenishmentRunId = 10000001691 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 299f054a-84a2-3ec3-a73e-bd40e2662fca workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = c7481d65-cba4-3443-a0b6-425b5ad98130 attempt = 1 cornerstoneTenantId = 8449 marketUnit = Kyma_Test_24 scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
jdk.internal.reflect.GeneratedMethodAccessor358.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/06/10 22:51:53
|
60 ms
|
[26]
|
|
25
|
replenishmentRunId = 10000001687 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 20cefeb3-5624-3007-8db2-3bd4336fef08 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 482176a2-fa43-363e-851a-549290a9832b attempt = 1 cornerstoneTenantId = 8449 marketUnit = ani-test scenario = STANDARD
+details
replenishmentRunId = 10000001687 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 20cefeb3-5624-3007-8db2-3bd4336fef08 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 482176a2-fa43-363e-851a-549290a9832b attempt = 1 cornerstoneTenantId = 8449 marketUnit = ani-test scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
jdk.internal.reflect.GeneratedMethodAccessor358.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/06/10 16:40:37
|
14 ms
|
[25]
|
|
24
|
replenishmentRunId = 10000001686 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = c6a5eb79-310d-3443-9caf-a2f5265ebcab workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = ef81cf6f-0caa-3d07-878b-74cdcb67efc2 attempt = 1 cornerstoneTenantId = 8449 marketUnit = IW_MU_CRP-128628_1 scenario = STANDARD
+details
replenishmentRunId = 10000001686 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = c6a5eb79-310d-3443-9caf-a2f5265ebcab workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = ef81cf6f-0caa-3d07-878b-74cdcb67efc2 attempt = 1 cornerstoneTenantId = 8449 marketUnit = IW_MU_CRP-128628_1 scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
jdk.internal.reflect.GeneratedMethodAccessor358.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/06/10 16:04:14
|
14 ms
|
[24]
|
|
23
|
replenishmentRunId = 10000001685 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = d77c66ea-85f2-34f2-9ae0-daba39eb4eb5 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 44bf0cdb-0c4c-38e5-8382-bb5c31723417 attempt = 1 cornerstoneTenantId = 8449 marketUnit = SS_Test_1 scenario = STANDARD
+details
replenishmentRunId = 10000001685 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = d77c66ea-85f2-34f2-9ae0-daba39eb4eb5 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 44bf0cdb-0c4c-38e5-8382-bb5c31723417 attempt = 1 cornerstoneTenantId = 8449 marketUnit = SS_Test_1 scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
jdk.internal.reflect.GeneratedMethodAccessor358.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/06/10 15:57:26
|
15 ms
|
[23]
|
|
22
|
replenishmentRunId = 10000000896 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = b6eb6d30-589f-335d-a9e7-b4301f2228f5 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = c5a7f9fb-9051-37a6-bd51-9fed4591c7ff attempt = 1 cornerstoneTenantId = 8378 marketUnit = FALLBACK_INSIGHT scenario = STANDARD
+details
replenishmentRunId = 10000000896 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = b6eb6d30-589f-335d-a9e7-b4301f2228f5 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = c5a7f9fb-9051-37a6-bd51-9fed4591c7ff attempt = 1 cornerstoneTenantId = 8378 marketUnit = FALLBACK_INSIGHT scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
jdk.internal.reflect.GeneratedMethodAccessor358.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/06/10 15:39:18
|
15 ms
|
[22]
|
|
21
|
replenishmentRunId = 10000001684 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = f19e84f6-38ee-3a0b-8b46-4c6f8d919f6e workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = a835f0bc-5223-383f-b4c2-6f19060ac074 attempt = 1 cornerstoneTenantId = 8449 marketUnit = SS_Test_1 scenario = STANDARD
+details
replenishmentRunId = 10000001684 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = f19e84f6-38ee-3a0b-8b46-4c6f8d919f6e workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = a835f0bc-5223-383f-b4c2-6f19060ac074 attempt = 1 cornerstoneTenantId = 8449 marketUnit = SS_Test_1 scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
jdk.internal.reflect.GeneratedMethodAccessor358.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/06/10 15:15:07
|
18 ms
|
[21]
|
|
20
|
replenishmentRunId = 10000000895 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = cfe18ede-ff60-358d-b823-ed67716cc32b workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 8e294dec-3d6d-391e-bea3-e61a2fdf7be4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = FALLBACK scenario = STANDARD
+details
replenishmentRunId = 10000000895 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = cfe18ede-ff60-358d-b823-ed67716cc32b workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 8e294dec-3d6d-391e-bea3-e61a2fdf7be4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = FALLBACK scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
jdk.internal.reflect.GeneratedMethodAccessor358.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/06/10 14:47:29
|
15 ms
|
[20]
|
|
19
|
replenishmentRunId = 10000000894 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = 8da4a39f-47ca-3db3-b0fd-9030b8fb6f9b workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = d415076d-d31d-392d-854b-ee111600b258 attempt = 1 cornerstoneTenantId = 8378 marketUnit = ARAVIND_MU_TEST scenario = STANDARD
+details
replenishmentRunId = 10000000894 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = 8da4a39f-47ca-3db3-b0fd-9030b8fb6f9b workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = d415076d-d31d-392d-854b-ee111600b258 attempt = 1 cornerstoneTenantId = 8378 marketUnit = ARAVIND_MU_TEST scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
jdk.internal.reflect.GeneratedMethodAccessor358.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/06/10 14:22:16
|
15 ms
|
[19]
|
|
18
|
replenishmentRunId = 10000000893 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = 2743a717-1aec-3a98-867b-ad3dbdc0c32b workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 56234b22-d133-31dc-aed4-283a1992eef6 attempt = 1 cornerstoneTenantId = 8378 marketUnit = IW_MU_CRP-127007_2 scenario = STANDARD
+details
replenishmentRunId = 10000000893 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = 2743a717-1aec-3a98-867b-ad3dbdc0c32b workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 56234b22-d133-31dc-aed4-283a1992eef6 attempt = 1 cornerstoneTenantId = 8378 marketUnit = IW_MU_CRP-127007_2 scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
jdk.internal.reflect.GeneratedMethodAccessor358.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/06/10 14:02:09
|
17 ms
|
[18]
|
|
17
|
replenishmentRunId = 10000000892 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = 221589e3-ac6d-3950-bf34-85d65c168e97 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 470be057-f36d-372e-84f0-4994a87a2471 attempt = 1 cornerstoneTenantId = 8378 marketUnit = CRP-128704 scenario = STANDARD
+details
replenishmentRunId = 10000000892 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = 221589e3-ac6d-3950-bf34-85d65c168e97 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 470be057-f36d-372e-84f0-4994a87a2471 attempt = 1 cornerstoneTenantId = 8378 marketUnit = CRP-128704 scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
jdk.internal.reflect.GeneratedMethodAccessor358.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/06/10 13:55:35
|
16 ms
|
[17]
|
|
16
|
replenishmentRunId = 10000000891 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = 3906073e-7e6a-3690-be45-d48db2ee9329 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 12878ff3-b041-3757-a6dd-7d7c7e9a4d3f attempt = 1 cornerstoneTenantId = 8378 marketUnit = PRP_MU_02 scenario = RECALCULATION
+details
replenishmentRunId = 10000000891 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = 3906073e-7e6a-3690-be45-d48db2ee9329 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 12878ff3-b041-3757-a6dd-7d7c7e9a4d3f attempt = 1 cornerstoneTenantId = 8378 marketUnit = PRP_MU_02 scenario = RECALCULATION
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
jdk.internal.reflect.GeneratedMethodAccessor358.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/06/10 13:47:23
|
16 ms
|
[16]
|
|
15
|
replenishmentRunId = 10000000890 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = d04361ec-3b47-371f-8fb8-15d93e3c45d5 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = afb1103e-8a2d-313f-bd64-e86c5d425cb2 attempt = 1 cornerstoneTenantId = 8378 marketUnit = FALLBACK scenario = STANDARD
+details
replenishmentRunId = 10000000890 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = d04361ec-3b47-371f-8fb8-15d93e3c45d5 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = afb1103e-8a2d-313f-bd64-e86c5d425cb2 attempt = 1 cornerstoneTenantId = 8378 marketUnit = FALLBACK scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
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/06/10 13:42:59
|
16 ms
|
[15]
|
|
14
|
replenishmentRunId = 10000001683 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 32055f5d-b0e1-3b7a-befd-a115c67cfbd8 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 4904042c-8bfc-3c18-8b42-52722398e2d6 attempt = 1 cornerstoneTenantId = 8449 marketUnit = ani-test scenario = STANDARD
+details
replenishmentRunId = 10000001683 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 32055f5d-b0e1-3b7a-befd-a115c67cfbd8 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 4904042c-8bfc-3c18-8b42-52722398e2d6 attempt = 1 cornerstoneTenantId = 8449 marketUnit = ani-test scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
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/06/10 13:20:43
|
18 ms
|
[14]
|
|
13
|
replenishmentRunId = 10000001682 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = a76e6d1b-dc1f-316e-95ec-106de488579f workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = a2cd84cd-b07e-3e03-bbf7-97e57012ad76 attempt = 1 cornerstoneTenantId = 8449 marketUnit = IW_MU_CRP-127007_1 scenario = STANDARD
+details
replenishmentRunId = 10000001682 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = a76e6d1b-dc1f-316e-95ec-106de488579f workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = a2cd84cd-b07e-3e03-bbf7-97e57012ad76 attempt = 1 cornerstoneTenantId = 8449 marketUnit = IW_MU_CRP-127007_1 scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
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/06/10 13:09:09
|
16 ms
|
[13]
|
|
12
|
replenishmentRunId = 10000001681 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 7939c4fc-ba17-3cc5-8006-83aa49bbc991 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 3a717d30-32fc-3e9e-ac19-3202aef4889b attempt = 1 cornerstoneTenantId = 8449 marketUnit = crp_128704 scenario = STANDARD
+details
replenishmentRunId = 10000001681 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 7939c4fc-ba17-3cc5-8006-83aa49bbc991 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 3a717d30-32fc-3e9e-ac19-3202aef4889b attempt = 1 cornerstoneTenantId = 8449 marketUnit = crp_128704 scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
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/06/10 13:03:11
|
19 ms
|
[12]
|
|
11
|
replenishmentRunId = 10000001680 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 5e4bf1b8-448d-3355-ba6f-607f7a7d1486 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = ce7cbc67-9087-389d-a0b2-3c263557f677 attempt = 1 cornerstoneTenantId = 8449 marketUnit = IW_DIP-2432_1 scenario = STANDARD
+details
replenishmentRunId = 10000001680 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 5e4bf1b8-448d-3355-ba6f-607f7a7d1486 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = ce7cbc67-9087-389d-a0b2-3c263557f677 attempt = 1 cornerstoneTenantId = 8449 marketUnit = IW_DIP-2432_1 scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
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/06/10 11:41:34
|
17 ms
|
[11]
|
|
10
|
replenishmentRunId = 10000001679 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = ff22a02b-e3c2-32d7-bf11-641e7f7f8d9d workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 6290460d-6a00-3f1b-8aa4-6d73ba857f4b attempt = 1 cornerstoneTenantId = 8449 marketUnit = Grocery_SS scenario = STANDARD
+details
replenishmentRunId = 10000001679 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = ff22a02b-e3c2-32d7-bf11-641e7f7f8d9d workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 6290460d-6a00-3f1b-8aa4-6d73ba857f4b attempt = 1 cornerstoneTenantId = 8449 marketUnit = Grocery_SS scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
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/06/10 11:32:23
|
19 ms
|
[10]
|
|
9
|
replenishmentRunId = 10000000889 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = 3a39ed2b-0038-3aaa-be5d-22ad4439eaf9 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 601cbba2-64d7-3b17-9069-33d979672e5e attempt = 1 cornerstoneTenantId = 8378 marketUnit = FALLBACK scenario = STANDARD
+details
replenishmentRunId = 10000000889 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = 3a39ed2b-0038-3aaa-be5d-22ad4439eaf9 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 601cbba2-64d7-3b17-9069-33d979672e5e attempt = 1 cornerstoneTenantId = 8378 marketUnit = FALLBACK scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
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/06/10 11:09:00
|
19 ms
|
[9]
|
|
8
|
replenishmentRunId = 10000001678 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 2b5386fc-5e67-3ded-9a4d-74ae364f0609 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 1d25cd52-81de-36a3-aaa0-a95463c3b357 attempt = 1 cornerstoneTenantId = 8449 marketUnit = MU_2510826 scenario = STANDARD
+details
replenishmentRunId = 10000001678 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 2b5386fc-5e67-3ded-9a4d-74ae364f0609 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 1d25cd52-81de-36a3-aaa0-a95463c3b357 attempt = 1 cornerstoneTenantId = 8449 marketUnit = MU_2510826 scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
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/06/10 11:07:32
|
21 ms
|
[8]
|
|
7
|
replenishmentRunId = 10000001677 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = fc1c5124-da41-3c9c-a031-501cd6e4fa43 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 4a62ff64-53d8-3f84-916c-98570262a048 attempt = 1 cornerstoneTenantId = 8449 marketUnit = Daily_Grocery scenario = STANDARD
+details
replenishmentRunId = 10000001677 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = fc1c5124-da41-3c9c-a031-501cd6e4fa43 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 4a62ff64-53d8-3f84-916c-98570262a048 attempt = 1 cornerstoneTenantId = 8449 marketUnit = Daily_Grocery scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
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/06/10 10:59:35
|
23 ms
|
[7]
|
|
6
|
replenishmentRunId = 10000001676 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = aea33a61-f032-3d9d-a0f1-becb21342be9 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 33c94ed1-65df-309a-8bb1-280e69ea5f23 attempt = 1 cornerstoneTenantId = 8449 marketUnit = Daily_Grocery scenario = STANDARD
+details
replenishmentRunId = 10000001676 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = aea33a61-f032-3d9d-a0f1-becb21342be9 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 33c94ed1-65df-309a-8bb1-280e69ea5f23 attempt = 1 cornerstoneTenantId = 8449 marketUnit = Daily_Grocery scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
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/06/10 10:57:49
|
36 ms
|
[6]
|
|
5
|
replenishmentRunId = 10000001675 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 06c1089b-34c6-39c0-b10f-d1e60d997e90 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = af74e555-0137-3abf-ad0b-d009a34c2475 attempt = 1 cornerstoneTenantId = 8449 marketUnit = ani-test scenario = STANDARD
+details
replenishmentRunId = 10000001675 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 06c1089b-34c6-39c0-b10f-d1e60d997e90 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = af74e555-0137-3abf-ad0b-d009a34c2475 attempt = 1 cornerstoneTenantId = 8449 marketUnit = ani-test scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
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/06/10 10:31:19
|
23 ms
|
[5]
|
|
4
|
replenishmentRunId = 10000001674 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 4ee0054c-240d-32a3-940f-1f232fac5b81 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = b5ef2142-26de-381c-99b1-c85baeaa517f attempt = 1 cornerstoneTenantId = 8449 marketUnit = PS_MU_CRP-128234_1 scenario = STANDARD
+details
replenishmentRunId = 10000001674 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 4ee0054c-240d-32a3-940f-1f232fac5b81 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = b5ef2142-26de-381c-99b1-c85baeaa517f attempt = 1 cornerstoneTenantId = 8449 marketUnit = PS_MU_CRP-128234_1 scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
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/06/10 09:35:21
|
20 ms
|
[4]
|
|
3
|
replenishmentRunId = 10000000888 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = 71c53099-dbc0-3ae9-8104-a3eba3a45214 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 07ba00b2-d45c-3700-a77b-b96d4e6fed1d attempt = 1 cornerstoneTenantId = 8378 marketUnit = FALLBACK scenario = STANDARD
+details
replenishmentRunId = 10000000888 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = 71c53099-dbc0-3ae9-8104-a3eba3a45214 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 07ba00b2-d45c-3700-a77b-b96d4e6fed1d attempt = 1 cornerstoneTenantId = 8378 marketUnit = FALLBACK scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
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/06/10 09:34:16
|
24 ms
|
[3]
|
|
2
|
replenishmentRunId = 10000001673 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = a35cae10-9a91-3122-a1bf-a429bf9eb860 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 2d94cbd5-830a-38f9-9a3d-1378aa70c175 attempt = 1 cornerstoneTenantId = 8449 marketUnit = Daily_Grocery scenario = STANDARD
+details
replenishmentRunId = 10000001673 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = a35cae10-9a91-3122-a1bf-a429bf9eb860 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 2d94cbd5-830a-38f9-9a3d-1378aa70c175 attempt = 1 cornerstoneTenantId = 8449 marketUnit = Daily_Grocery scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
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/06/10 09:33:19
|
26 ms
|
[2]
|
|
1
|
replenishmentRunId = 10000000887 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = 7f8a4fc7-7a7f-378c-b437-2cac0dc51d41 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 8aaf4fa1-6454-36dc-93e0-9ccb180d6acc attempt = 1 cornerstoneTenantId = 8378 marketUnit = FALLBACK_INSIGHT scenario = STANDARD
+details
replenishmentRunId = 10000000887 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = 7f8a4fc7-7a7f-378c-b437-2cac0dc51d41 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 8aaf4fa1-6454-36dc-93e0-9ccb180d6acc attempt = 1 cornerstoneTenantId = 8378 marketUnit = FALLBACK_INSIGHT scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
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/06/10 09:29:44
|
36 ms
|
[1]
|
|
0
|
replenishmentRunId = 10000000886 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = ec8d8d09-eea1-36b2-8b78-4cc4f27d1233 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 7fd1bbd9-d346-3a4c-9fd2-0e79a1a08e0d attempt = 1 cornerstoneTenantId = 8378 marketUnit = FALLBACK_INSIGHT scenario = STANDARD
+details
replenishmentRunId = 10000000886 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = ec8d8d09-eea1-36b2-8b78-4cc4f27d1233 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 7fd1bbd9-d346-3a4c-9fd2-0e79a1a08e0d attempt = 1 cornerstoneTenantId = 8378 marketUnit = FALLBACK_INSIGHT scenario = STANDARD
org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishMessage(KafkaMessagePublisher.java:119)
com.sap.s4hana.eureka.business.crpdemandservice.storageaccess.KafkaMessagePublisher.publishInsight(KafkaMessagePublisher.java:50)
com.sap.s4hana.eureka.business.crpdemandservice.core.business.insights.InsightHandler.processAndPublishInsights(InsightHandler.java:17)
com.sap.s4hana.eureka.business.crpdemandservice.core.controller.NotifyDemandServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyDemandServiceReplRunFinishedActivityImpl.java:35)
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/06/10 09:27:24
|
0.7 s
|
[0]
|