crp-order-qty-opt-service - SQL / DataFrame

Completed Queries: 176
Failed Queries: 3

Completed Queries (176)

Page:

Description ▴

Submitted

Duration

Job IDs

Sub Execution IDs

2666

Delta: replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 716ccf9b-cdb1-3562-9443-25d61a221cf2 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query +details

Delta: replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 716ccf9b-cdb1-3562-9443-25d61a221cf2 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:28:31

0.4 s

[4110]

2669

Delta: replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 716ccf9b-cdb1-3562-9443-25d61a221cf2 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:28:33

0.5 s

[4115]

2913

Delta: replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 90f9ebe0-40ee-3f09-bb94-59e27ef54873 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query +details

Delta: replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 90f9ebe0-40ee-3f09-bb94-59e27ef54873 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:30:33

0.5 s

[4442]

2915

Delta: replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 90f9ebe0-40ee-3f09-bb94-59e27ef54873 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:30:34

0.4 s

[4445]

3021

Delta: replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 8342fa88-71bd-3ec6-8290-5039bab47486 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query +details

Delta: replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 8342fa88-71bd-3ec6-8290-5039bab47486 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:32:12

0.3 s

[4587]

3023

Delta: replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 8342fa88-71bd-3ec6-8290-5039bab47486 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:32:13

0.4 s

[4590]

2815

Delta: replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = c200dc59-c1f7-300a-b37d-17484e4f2e65 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query +details

Delta: replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = c200dc59-c1f7-300a-b37d-17484e4f2e65 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:29:44

0.4 s

[4306]

2819

Delta: replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = c200dc59-c1f7-300a-b37d-17484e4f2e65 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:29:45

0.6 s

[4311]

2534

Delta: replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = dc786804-b74a-3530-91a2-06c952aec822 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query +details

Delta: replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = dc786804-b74a-3530-91a2-06c952aec822 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:27:29

0.4 s

[3933]

2536

Delta: replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = dc786804-b74a-3530-91a2-06c952aec822 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:27:30

0.4 s

[3936]

2951

Delta: replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = df5151cb-8e9d-3520-b3aa-2b3e86dbc916 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query +details

Delta: replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = df5151cb-8e9d-3520-b3aa-2b3e86dbc916 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:31:12

0.4 s

[4492]

2953

Delta: replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = df5151cb-8e9d-3520-b3aa-2b3e86dbc916 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:31:13

0.4 s

[4495]

2699

Delta: replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = ef1473b3-9ea5-3eda-a8a6-975260371fc7 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query +details

Delta: replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = ef1473b3-9ea5-3eda-a8a6-975260371fc7 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:28:44

0.4 s

[4158]

2701

Delta: replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = ef1473b3-9ea5-3eda-a8a6-975260371fc7 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:28:45

0.4 s

[4161]

3132

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query +details

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1207)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:36:33

0.2 s

[4784]

3133

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:36:33

0.2 s

[4785]

3134

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:36:33

0.1 s

[4786]

3135

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1207)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:36:34

83 ms

[4787]

3136

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1207)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:36:34

79 ms

[4788]

3137

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1207)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:36:35

0.2 s

[4790]

3138

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1207)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:36:36

84 ms

[4791]

3100

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = CreateOrderProposalShards activityId = 7538468d-5364-3382-88f1-3674ecb3dbd2 workflowType = CalculateOrderProposalsWorkflow workflowId = 7f29dd6c-bb2a-338b-ab47-145833577bd7 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query +details

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = CreateOrderProposalShards activityId = 7538468d-5364-3382-88f1-3674ecb3dbd2 workflowType = CalculateOrderProposalsWorkflow workflowId = 7f29dd6c-bb2a-338b-ab47-145833577bd7 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:35:55

0.2 s

[4707]

3102

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = CreateOrderProposalShards activityId = 7538468d-5364-3382-88f1-3674ecb3dbd2 workflowType = CalculateOrderProposalsWorkflow workflowId = 7f29dd6c-bb2a-338b-ab47-145833577bd7 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:35:58

0.2 s

[4720]

3373

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 9277fdd4-3375-3cde-91b4-0447cc725260 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 65cbadef-b0dc-3362-9abf-dfc8eed4dc74 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query +details

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 9277fdd4-3375-3cde-91b4-0447cc725260 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 65cbadef-b0dc-3362-9abf-dfc8eed4dc74 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:40:47

0.3 s

[5131]

3375

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 9277fdd4-3375-3cde-91b4-0447cc725260 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 65cbadef-b0dc-3362-9abf-dfc8eed4dc74 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:40:48

0.4 s

[5134]

3157

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 9602ac1a-1ef6-3cc3-8d36-88a63bd1a15e workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 65cbadef-b0dc-3362-9abf-dfc8eed4dc74 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query +details

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 9602ac1a-1ef6-3cc3-8d36-88a63bd1a15e workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 65cbadef-b0dc-3362-9abf-dfc8eed4dc74 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:37:47

0.5 s

[4850]

3158

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 9602ac1a-1ef6-3cc3-8d36-88a63bd1a15e workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 65cbadef-b0dc-3362-9abf-dfc8eed4dc74 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:37:47

57 ms

3159

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 9602ac1a-1ef6-3cc3-8d36-88a63bd1a15e workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 65cbadef-b0dc-3362-9abf-dfc8eed4dc74 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:37:47

0.9 s

[4851]

3161

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 9602ac1a-1ef6-3cc3-8d36-88a63bd1a15e workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 65cbadef-b0dc-3362-9abf-dfc8eed4dc74 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:37:49

0.4 s

[4854]

3268

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = e3d6dfa4-4832-3c51-ae01-5e437471ac9f workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 65cbadef-b0dc-3362-9abf-dfc8eed4dc74 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query +details

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = e3d6dfa4-4832-3c51-ae01-5e437471ac9f workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 65cbadef-b0dc-3362-9abf-dfc8eed4dc74 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:39:16

0.4 s

[4992]

3270

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = e3d6dfa4-4832-3c51-ae01-5e437471ac9f workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 65cbadef-b0dc-3362-9abf-dfc8eed4dc74 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:39:17

0.4 s

[4995]

2659

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 716ccf9b-cdb1-3562-9443-25d61a221cf2 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD +details

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 716ccf9b-cdb1-3562-9443-25d61a221cf2 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.DataFrameWriter.text(DataFrameWriter.scala:409)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.writeWorkflowAssignment(FileStorageAdapterImpl.java:689)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:44)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:30

1 s

[4105]

2663

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 716ccf9b-cdb1-3562-9443-25d61a221cf2 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.Dataset.javaRDD(Dataset.scala:3270)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.removeShardsFromCache(KpiCurveCacheImpl.java:97)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:144)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:31

8 ms

2667

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 716ccf9b-cdb1-3562-9443-25d61a221cf2 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.readShardWorkList(OrderQuantityOptimizationImpl.java:188)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:152)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:32

1 s

[4111][4114]

2671

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 716ccf9b-cdb1-3562-9443-25d61a221cf2 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:154)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:34

0.5 s

[4117][4118][4119]

2672

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 716ccf9b-cdb1-3562-9443-25d61a221cf2 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.collectAsList(Dataset.scala:1485)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:32)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:34

0.5 s

[4120][4122]

2675

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 716ccf9b-cdb1-3562-9443-25d61a221cf2 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.collectAsList(Dataset.scala:1485)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:35)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:35

3 ms

2676

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 716ccf9b-cdb1-3562-9443-25d61a221cf2 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:597)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:35

0.2 s

[4123][4124]

2678

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 716ccf9b-cdb1-3562-9443-25d61a221cf2 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:619)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:35

1 s

[2680]

+details

Description

Submitted

Duration

Job IDs

2680

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 716ccf9b-cdb1-3562-9443-25d61a221cf2 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:619)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:35

0.8 s

[4126]

2683

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 716ccf9b-cdb1-3562-9443-25d61a221cf2 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.Dataset.javaRDD(Dataset.scala:3270)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.addToCache(OptimalQuantitiesCacheImpl.java:177)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.initializeWithWorklist(OptimalQuantitiesCacheImpl.java:71)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:163)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:36

1.0 s

[4130][4131][4132][4133][4134]

2688

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 716ccf9b-cdb1-3562-9443-25d61a221cf2 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storePerformanceMetrics(FileStorageAdapterImpl.java:824)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:48)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:37

1 s

[4137][4138][4139][4140][4142]

2910

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 90f9ebe0-40ee-3f09-bb94-59e27ef54873 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD +details

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 90f9ebe0-40ee-3f09-bb94-59e27ef54873 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.DataFrameWriter.text(DataFrameWriter.scala:409)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.writeWorkflowAssignment(FileStorageAdapterImpl.java:689)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:44)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:30:32

1 s

[4436]

2912

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 90f9ebe0-40ee-3f09-bb94-59e27ef54873 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.Dataset.javaRDD(Dataset.scala:3270)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.removeShardsFromCache(KpiCurveCacheImpl.java:97)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:144)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:30:33

7 ms

2914

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 90f9ebe0-40ee-3f09-bb94-59e27ef54873 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.readShardWorkList(OrderQuantityOptimizationImpl.java:188)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:152)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:30:33

0.5 s

[4443][4444]

2916

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 90f9ebe0-40ee-3f09-bb94-59e27ef54873 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:154)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:30:34

0.5 s

[4446][4447][4448]

2917

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 90f9ebe0-40ee-3f09-bb94-59e27ef54873 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.collectAsList(Dataset.scala:1485)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:32)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:30:35

0.3 s

[4449][4450]

2918

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 90f9ebe0-40ee-3f09-bb94-59e27ef54873 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.collectAsList(Dataset.scala:1485)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:35)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:30:35

2 ms

2919

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 90f9ebe0-40ee-3f09-bb94-59e27ef54873 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:597)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:30:35

0.2 s

[4451][4452]

2920

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 90f9ebe0-40ee-3f09-bb94-59e27ef54873 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:619)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:30:35

1 s

[2921]

+details

Description

Submitted

Duration

Job IDs

2921

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 90f9ebe0-40ee-3f09-bb94-59e27ef54873 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:619)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:30:36

0.7 s

[4453]

3018

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 8342fa88-71bd-3ec6-8290-5039bab47486 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD +details

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 8342fa88-71bd-3ec6-8290-5039bab47486 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.DataFrameWriter.text(DataFrameWriter.scala:409)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.writeWorkflowAssignment(FileStorageAdapterImpl.java:689)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:44)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:32:11

1.0 s

[4584]

3020

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 8342fa88-71bd-3ec6-8290-5039bab47486 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.Dataset.javaRDD(Dataset.scala:3270)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.removeShardsFromCache(KpiCurveCacheImpl.java:97)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:144)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:32:12

6 ms

3022

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 8342fa88-71bd-3ec6-8290-5039bab47486 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.readShardWorkList(OrderQuantityOptimizationImpl.java:188)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:152)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:32:12

0.5 s

[4588][4589]

3024

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 8342fa88-71bd-3ec6-8290-5039bab47486 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:154)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:32:13

0.5 s

[4591][4592][4593]

3025

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 8342fa88-71bd-3ec6-8290-5039bab47486 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.collectAsList(Dataset.scala:1485)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:32)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:32:14

0.3 s

[4594][4595]

3026

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 8342fa88-71bd-3ec6-8290-5039bab47486 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.collectAsList(Dataset.scala:1485)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:35)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:32:14

2 ms

3027

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 8342fa88-71bd-3ec6-8290-5039bab47486 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:597)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:32:14

0.1 s

[4596][4597]

3028

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 8342fa88-71bd-3ec6-8290-5039bab47486 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:619)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:32:14

1 s

[3029]

+details

Description

Submitted

Duration

Job IDs

3029

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 8342fa88-71bd-3ec6-8290-5039bab47486 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:619)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:32:15

0.6 s

[4598]

3030

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 8342fa88-71bd-3ec6-8290-5039bab47486 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.Dataset.javaRDD(Dataset.scala:3270)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.addToCache(OptimalQuantitiesCacheImpl.java:177)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.initializeWithWorklist(OptimalQuantitiesCacheImpl.java:71)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:163)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:32:16

0.9 s

[4599][4600][4601][4602][4603]

3031

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 8342fa88-71bd-3ec6-8290-5039bab47486 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storePerformanceMetrics(FileStorageAdapterImpl.java:824)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:48)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:32:17

2 s

[4605][4606][4607][4608][4609]

2812

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = c200dc59-c1f7-300a-b37d-17484e4f2e65 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD +details

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = c200dc59-c1f7-300a-b37d-17484e4f2e65 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.DataFrameWriter.text(DataFrameWriter.scala:409)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.writeWorkflowAssignment(FileStorageAdapterImpl.java:689)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:44)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:29:43

1 s

[4302]

2814

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = c200dc59-c1f7-300a-b37d-17484e4f2e65 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.Dataset.javaRDD(Dataset.scala:3270)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.removeShardsFromCache(KpiCurveCacheImpl.java:97)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:144)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:29:44

14 ms

2817

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = c200dc59-c1f7-300a-b37d-17484e4f2e65 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.readShardWorkList(OrderQuantityOptimizationImpl.java:188)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:152)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:29:45

0.6 s

[4308][4309]

2821

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = c200dc59-c1f7-300a-b37d-17484e4f2e65 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:154)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:29:46

1 s

[4314][4316][4317]

2822

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = c200dc59-c1f7-300a-b37d-17484e4f2e65 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.collectAsList(Dataset.scala:1485)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:32)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:29:47

0.5 s

[4318][4319]

2823

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = c200dc59-c1f7-300a-b37d-17484e4f2e65 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.collectAsList(Dataset.scala:1485)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:35)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:29:48

5 ms

2824

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = c200dc59-c1f7-300a-b37d-17484e4f2e65 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:597)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:29:48

0.3 s

[4320][4321]

2825

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = c200dc59-c1f7-300a-b37d-17484e4f2e65 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:619)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:29:48

2 s

[2826]

+details

Description

Submitted

Duration

Job IDs

2826

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = c200dc59-c1f7-300a-b37d-17484e4f2e65 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:619)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:29:48

1 s

[4322]

2827

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = c200dc59-c1f7-300a-b37d-17484e4f2e65 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.Dataset.javaRDD(Dataset.scala:3270)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.addToCache(OptimalQuantitiesCacheImpl.java:177)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.initializeWithWorklist(OptimalQuantitiesCacheImpl.java:71)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:163)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:29:50

1 s

[4323][4324][4325][4326][4328]

2830

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = c200dc59-c1f7-300a-b37d-17484e4f2e65 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storePerformanceMetrics(FileStorageAdapterImpl.java:824)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:48)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:29:51

2 s

[4330][4331][4332][4333][4335]

2531

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = dc786804-b74a-3530-91a2-06c952aec822 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD +details

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = dc786804-b74a-3530-91a2-06c952aec822 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.DataFrameWriter.text(DataFrameWriter.scala:409)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.writeWorkflowAssignment(FileStorageAdapterImpl.java:689)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:44)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:27:27

1 s

[3931]

2533

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = dc786804-b74a-3530-91a2-06c952aec822 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.Dataset.javaRDD(Dataset.scala:3270)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.removeShardsFromCache(KpiCurveCacheImpl.java:97)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:144)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:27:29

7 ms

2535

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = dc786804-b74a-3530-91a2-06c952aec822 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.readShardWorkList(OrderQuantityOptimizationImpl.java:188)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:152)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:27:29

0.5 s

[3934][3935]

2537

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = dc786804-b74a-3530-91a2-06c952aec822 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:154)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:27:30

0.5 s

[3937][3938][3939]

2538

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = dc786804-b74a-3530-91a2-06c952aec822 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.collectAsList(Dataset.scala:1485)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:32)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:27:31

0.3 s

[3940][3941]

2539

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = dc786804-b74a-3530-91a2-06c952aec822 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.collectAsList(Dataset.scala:1485)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:35)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:27:31

3 ms

2540

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = dc786804-b74a-3530-91a2-06c952aec822 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:597)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:27:31

0.1 s

[3942][3943]

2541

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = dc786804-b74a-3530-91a2-06c952aec822 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:619)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:27:31

1 s

[2542]

+details

Description

Submitted

Duration

Job IDs

2542

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = dc786804-b74a-3530-91a2-06c952aec822 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:619)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:27:31

0.6 s

[3944]

2543

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = dc786804-b74a-3530-91a2-06c952aec822 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.Dataset.javaRDD(Dataset.scala:3270)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.addToCache(OptimalQuantitiesCacheImpl.java:177)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.initializeWithWorklist(OptimalQuantitiesCacheImpl.java:71)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:163)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:27:33

0.9 s

[3945][3946][3947][3948][3949]

2544

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = dc786804-b74a-3530-91a2-06c952aec822 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storePerformanceMetrics(FileStorageAdapterImpl.java:824)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:48)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:27:34

1 s

[3951][3952][3953][3954][3955]

2948

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = df5151cb-8e9d-3520-b3aa-2b3e86dbc916 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD +details

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = df5151cb-8e9d-3520-b3aa-2b3e86dbc916 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.DataFrameWriter.text(DataFrameWriter.scala:409)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.writeWorkflowAssignment(FileStorageAdapterImpl.java:689)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:44)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:31:11

1 s

[4490]

2950

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = df5151cb-8e9d-3520-b3aa-2b3e86dbc916 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.Dataset.javaRDD(Dataset.scala:3270)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.removeShardsFromCache(KpiCurveCacheImpl.java:97)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:144)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:31:12

11 ms

2952

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = df5151cb-8e9d-3520-b3aa-2b3e86dbc916 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.readShardWorkList(OrderQuantityOptimizationImpl.java:188)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:152)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:31:13

0.5 s

[4493][4494]

2954

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = df5151cb-8e9d-3520-b3aa-2b3e86dbc916 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:154)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:31:14

0.5 s

[4496][4497][4498]

2955

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = df5151cb-8e9d-3520-b3aa-2b3e86dbc916 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.collectAsList(Dataset.scala:1485)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:32)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:31:14

0.3 s

[4499][4500]

2956

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = df5151cb-8e9d-3520-b3aa-2b3e86dbc916 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.collectAsList(Dataset.scala:1485)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:35)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:31:15

2 ms

2957

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = df5151cb-8e9d-3520-b3aa-2b3e86dbc916 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:597)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:31:15

0.2 s

[4501][4502]

2958

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = df5151cb-8e9d-3520-b3aa-2b3e86dbc916 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:619)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:31:15

1 s

[2959]

+details

Description

Submitted

Duration

Job IDs

2959

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = df5151cb-8e9d-3520-b3aa-2b3e86dbc916 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:619)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:31:15

0.6 s

[4503]

2960

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = df5151cb-8e9d-3520-b3aa-2b3e86dbc916 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.Dataset.javaRDD(Dataset.scala:3270)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.addToCache(OptimalQuantitiesCacheImpl.java:177)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.initializeWithWorklist(OptimalQuantitiesCacheImpl.java:71)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:163)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:31:16

0.9 s

[4504][4505][4506][4507][4508]

2961

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = df5151cb-8e9d-3520-b3aa-2b3e86dbc916 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storePerformanceMetrics(FileStorageAdapterImpl.java:824)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:48)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:31:17

2 s

[4510][4511][4512][4513][4514]

2696

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = ef1473b3-9ea5-3eda-a8a6-975260371fc7 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD +details

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = ef1473b3-9ea5-3eda-a8a6-975260371fc7 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.DataFrameWriter.text(DataFrameWriter.scala:409)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.writeWorkflowAssignment(FileStorageAdapterImpl.java:689)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:44)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:43

1 s

[4156]

2698

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = ef1473b3-9ea5-3eda-a8a6-975260371fc7 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.Dataset.javaRDD(Dataset.scala:3270)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.removeShardsFromCache(KpiCurveCacheImpl.java:97)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:144)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:44

8 ms

2700

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = ef1473b3-9ea5-3eda-a8a6-975260371fc7 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.readShardWorkList(OrderQuantityOptimizationImpl.java:188)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:152)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:44

0.5 s

[4159][4160]

2702

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = ef1473b3-9ea5-3eda-a8a6-975260371fc7 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:154)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:45

0.5 s

[4162][4163][4164]

2703

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = ef1473b3-9ea5-3eda-a8a6-975260371fc7 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.collectAsList(Dataset.scala:1485)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:32)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:46

0.3 s

[4165][4166]

2704

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = ef1473b3-9ea5-3eda-a8a6-975260371fc7 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.collectAsList(Dataset.scala:1485)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:35)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:46

2 ms

2705

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = ef1473b3-9ea5-3eda-a8a6-975260371fc7 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:597)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:46

0.1 s

[4167][4168]

2706

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = ef1473b3-9ea5-3eda-a8a6-975260371fc7 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:619)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:46

1 s

[2707]

+details

Description

Submitted

Duration

Job IDs

2707

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = ef1473b3-9ea5-3eda-a8a6-975260371fc7 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:619)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:206)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:161)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:46

0.6 s

[4169]

2708

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = ef1473b3-9ea5-3eda-a8a6-975260371fc7 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.Dataset.javaRDD(Dataset.scala:3270)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.addToCache(OptimalQuantitiesCacheImpl.java:177)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.initializeWithWorklist(OptimalQuantitiesCacheImpl.java:71)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:163)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:47

1.0 s

[4170][4171][4172][4173][4174]

2709

replenishmentRunId = 10000002107 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = ef1473b3-9ea5-3eda-a8a6-975260371fc7 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0b4ce30c-509e-3e3d-aaeb-4c7478c46dc4 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storePerformanceMetrics(FileStorageAdapterImpl.java:824)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:48)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:28:49

2 s

[4176][4177][4178][4179][4180]

3127

replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD +details

replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.Dataset.collectAsList(Dataset.scala:1485)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.MarketUnitDeterminationImpl.getMarketUnitRow(MarketUnitDeterminationImpl.java:62)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.MarketUnitDeterminationImpl.determineMarketUnit(MarketUnitDeterminationImpl.java:27)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:73)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapshotInternal(CreateDataSnapshotForShardActivityImpl.java:55)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapShot(CreateDataSnapshotForShardActivityImpl.java:40)
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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)

2026/08/10 09:36:28

0.8 s

[4776][4777]

[3128]

+details

Description

Submitted

Duration

Job IDs

3128

Delta: replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD: Filtering files for query

org.apache.spark.sql.delta.metering.DeltaLogging.$anonfun$recordDeltaOperationInternal$1(DeltaLogging.scala:139)
com.databricks.spark.util.DatabricksLogging.recordOperation(DatabricksLogging.scala:128)
com.databricks.spark.util.DatabricksLogging.recordOperation$(DatabricksLogging.scala:117)
org.apache.spark.sql.delta.Snapshot.recordOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperationInternal(DeltaLogging.scala:138)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation(DeltaLogging.scala:128)
org.apache.spark.sql.delta.metering.DeltaLogging.recordDeltaOperation$(DeltaLogging.scala:118)
org.apache.spark.sql.delta.Snapshot.recordDeltaOperation(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan(DataSkippingReader.scala:1265)
org.apache.spark.sql.delta.stats.DataSkippingReaderBase.filesForScan$(DataSkippingReader.scala:1204)
org.apache.spark.sql.delta.Snapshot.filesForScan(Snapshot.scala:87)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.$anonfun$filesForScan$1(PrepareDeltaScan.scala:134)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withJobDescription(DeltaProgressReporter.scala:56)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode(DeltaProgressReporter.scala:35)
org.apache.spark.sql.delta.util.DeltaProgressReporter.withStatusCode$(DeltaProgressReporter.scala:29)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.withStatusCode(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan(PrepareDeltaScan.scala:119)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase.filesForScan$(PrepareDeltaScan.scala:114)
org.apache.spark.sql.delta.stats.PrepareDeltaScan.filesForScan(PrepareDeltaScan.scala:308)
org.apache.spark.sql.delta.stats.PrepareDeltaScanBase$$anonfun$prepareDeltaScan$1.$anonfun$applyOrElse$1(PrepareDeltaScan.scala:152)

2026/08/10 09:36:28

0.3 s

[4775]

Page:

Failed Queries (3)

Page:

ID ▾	Description	Submitted	Duration	Succeeded Job IDs	Failed Job IDs	Error Message
3131	replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD +details replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD org.apache.spark.sql.classic.DataFrameReader.load(DataFrameReader.scala:58) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.readFromUriWithSchema(FileStorageAdapterImpl.java:362) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.readPRPExternalData(FileStorageAdapterImpl.java:335) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.DataSnapshotGenerationDataAccessImpl.readRoundingRules(DataSnapshotGenerationDataAccessImpl.java:120) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.PreferredUOMDeterminationImpl.determineRoundingRules(PreferredUOMDeterminationImpl.java:66) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.PreferredUOMDeterminationImpl.determinePreferredUOMs(PreferredUOMDeterminationImpl.java:36) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.LogisticUnitSnapshotEnhancementImpl.withLogisticUnits(LogisticUnitSnapshotEnhancementImpl.java:41) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:80) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapshotInternal(CreateDataSnapshotForShardActivityImpl.java:55) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapShot(CreateDataSnapshotForShardActivityImpl.java:40) 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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)	2026/08/10 09:36:31	0 ms			DELTA_TABLE_NOT_FOUND +details [DELTA_TABLE_NOT_FOUND] Delta table `hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-common-logisticalroundingrulecodes` doesn't exist.
3130	replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD +details replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD org.apache.spark.sql.classic.DataFrameReader.load(DataFrameReader.scala:58) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.readFromUriWithSchema(FileStorageAdapterImpl.java:362) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.readPRPExternalData(FileStorageAdapterImpl.java:335) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.DataSnapshotGenerationDataAccessImpl.readRoundingProfiles(DataSnapshotGenerationDataAccessImpl.java:114) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.PreferredUOMDeterminationImpl.determineRoundingRules(PreferredUOMDeterminationImpl.java:65) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.PreferredUOMDeterminationImpl.determinePreferredUOMs(PreferredUOMDeterminationImpl.java:36) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.LogisticUnitSnapshotEnhancementImpl.withLogisticUnits(LogisticUnitSnapshotEnhancementImpl.java:41) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:80) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapshotInternal(CreateDataSnapshotForShardActivityImpl.java:55) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapShot(CreateDataSnapshotForShardActivityImpl.java:40) 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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)	2026/08/10 09:36:31	0 ms			DELTA_TABLE_NOT_FOUND +details [DELTA_TABLE_NOT_FOUND] Delta table `hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-common-logisticalroundingprofilecodes` doesn't exist.
2922	replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 90f9ebe0-40ee-3f09-bb94-59e27ef54873 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD +details replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 90f9ebe0-40ee-3f09-bb94-59e27ef54873 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD org.apache.spark.sql.Dataset.javaRDD(Dataset.scala:3270) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.addToCache(OptimalQuantitiesCacheImpl.java:177) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.initializeWithWorklist(OptimalQuantitiesCacheImpl.java:71) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:163) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47) jdk.internal.reflect.GeneratedMethodAccessor679.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/08/10 09:30:37	0.5 s	[4454][4455]	[4456][4457]	SPARK_JOB_CANCELLED +details [SPARK_JOB_CANCELLED] Job 4456 cancelled SQLSTATE: XXKDA

ID ▾

Description

Submitted

Duration

Succeeded Job IDs

Failed Job IDs

Error Message

Sub Execution IDs

3131

replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameReader.load(DataFrameReader.scala:58)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.readFromUriWithSchema(FileStorageAdapterImpl.java:362)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.readPRPExternalData(FileStorageAdapterImpl.java:335)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.DataSnapshotGenerationDataAccessImpl.readRoundingRules(DataSnapshotGenerationDataAccessImpl.java:120)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.PreferredUOMDeterminationImpl.determineRoundingRules(PreferredUOMDeterminationImpl.java:66)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.PreferredUOMDeterminationImpl.determinePreferredUOMs(PreferredUOMDeterminationImpl.java:36)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.LogisticUnitSnapshotEnhancementImpl.withLogisticUnits(LogisticUnitSnapshotEnhancementImpl.java:41)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:80)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapshotInternal(CreateDataSnapshotForShardActivityImpl.java:55)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapShot(CreateDataSnapshotForShardActivityImpl.java:40)
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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)

2026/08/10 09:36:31

0 ms

DELTA_TABLE_NOT_FOUND +details

[DELTA_TABLE_NOT_FOUND] Delta table `hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-common-logisticalroundingrulecodes` doesn't exist.

3130

replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.classic.DataFrameReader.load(DataFrameReader.scala:58)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.readFromUriWithSchema(FileStorageAdapterImpl.java:362)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.readPRPExternalData(FileStorageAdapterImpl.java:335)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.DataSnapshotGenerationDataAccessImpl.readRoundingProfiles(DataSnapshotGenerationDataAccessImpl.java:114)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.PreferredUOMDeterminationImpl.determineRoundingRules(PreferredUOMDeterminationImpl.java:65)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.PreferredUOMDeterminationImpl.determinePreferredUOMs(PreferredUOMDeterminationImpl.java:36)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.LogisticUnitSnapshotEnhancementImpl.withLogisticUnits(LogisticUnitSnapshotEnhancementImpl.java:41)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:80)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapshotInternal(CreateDataSnapshotForShardActivityImpl.java:55)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapShot(CreateDataSnapshotForShardActivityImpl.java:40)
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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)

2026/08/10 09:36:31

0 ms

DELTA_TABLE_NOT_FOUND +details

[DELTA_TABLE_NOT_FOUND] Delta table `hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-common-logisticalroundingprofilecodes` doesn't exist.

2922

replenishmentRunId = 10000002106 tenantId = 6944346648028224943 activityType = TriggerOptimize activityId = 90f9ebe0-40ee-3f09-bb94-59e27ef54873 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 0f4250b6-1406-3df5-adfb-4c8fbb62ac56 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD

org.apache.spark.sql.Dataset.javaRDD(Dataset.scala:3270)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.addToCache(OptimalQuantitiesCacheImpl.java:177)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.initializeWithWorklist(OptimalQuantitiesCacheImpl.java:71)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:163)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:47)
jdk.internal.reflect.GeneratedMethodAccessor679.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/08/10 09:30:37

0.5 s

[4454][4455]

[4456][4457]

SPARK_JOB_CANCELLED +details

[SPARK_JOB_CANCELLED] Job 4456 cancelled  SQLSTATE: XXKDA

Page: