crp-demand-service - SQL / DataFrame

SQL / DataFrame

Completed Queries: 4

Completed Queries (4)

Page:

1

ID ▾	Description	Submitted	Duration	Job IDs
3	replenishmentRunId = 10000000120 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = 7e0a64e3-6076-3bc0-bad2-05bbb1136caa workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 0a8fb40b-8eaa-30aa-8d10-725aa375104e attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD +details replenishmentRunId = 10000000120 tenantId = 6944346648028224943 activityType = NotifyReplRunFinished activityId = 7e0a64e3-6076-3bc0-bad2-05bbb1136caa workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 0a8fb40b-8eaa-30aa-8d10-725aa375104e 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) 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/04/11 14:42:29	28 ms	[13]
2	replenishmentRunId = 10000000280 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 5b46022a-4c16-33b0-a7fe-d390b86e397d workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 86794b01-af73-3e20-9154-48788a3809cc attempt = 1 cornerstoneTenantId = 8449 marketUnit = Grocery_SS scenario = RECALCULATION +details replenishmentRunId = 10000000280 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 5b46022a-4c16-33b0-a7fe-d390b86e397d workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 86794b01-af73-3e20-9154-48788a3809cc attempt = 1 cornerstoneTenantId = 8449 marketUnit = Grocery_SS 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) 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/04/11 07:43:51	65 ms	[7]
1	replenishmentRunId = 10000000279 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = d8addfcd-124e-3fdd-8919-4fb5321427e1 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = eb80befe-5d93-34a6-9eac-70a2a0ede81e attempt = 1 cornerstoneTenantId = 8449 marketUnit = IW_MU_CRP-127007_1 scenario = STANDARD +details replenishmentRunId = 10000000279 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = d8addfcd-124e-3fdd-8919-4fb5321427e1 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = eb80befe-5d93-34a6-9eac-70a2a0ede81e 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/04/10 15:04:23	24 ms	[6]
0	replenishmentRunId = 10000000278 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 095c13f1-1284-35ee-9ed2-561492a5f528 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 03bbbace-314b-380c-9ef2-9af2df16c6ea attempt = 1 cornerstoneTenantId = 8449 marketUnit = Grocery_SS scenario = STANDARD +details replenishmentRunId = 10000000278 tenantId = 1699186316786241789 activityType = NotifyReplRunFinished activityId = 095c13f1-1284-35ee-9ed2-561492a5f528 workflowType = NotifyDemandServiceReplRunFinishedWorkflow workflowId = 03bbbace-314b-380c-9ef2-9af2df16c6ea 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/04/10 14:54:04	0.7 s	[0]

Page:

1