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

Status: SUCCEEDED
Submitted: 2026/05/22 09:08:58
Duration: 0.4 s
Associated SQL Query: 24543
Job Group: 98c9eb76-6961-30fe-bc89-63eb83c5edfa
Completed Stages: 1
Skipped Stages: 2

Event Timeline

Enable zooming

No DAG visualization information to display for job 40969

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
1267906	tenants-pool-169	replenishmentRunId = 10000000244 tenantId = 7625924700692506924 activityType = TriggerOptimize activityId = 98c9eb76-6961-30fe-bc89-63eb83c5edfa workflowType = CalculateOrderProposalsForShardWorkflow workflowId = b6d18d7d-2942-32f8-a34a-d38fc7159bf3 attempt = 1 cornerstoneTenantId = 7287 marketUnit = IW_MU_CRP-128628_3 scenario = STANDARD $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128 +details 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.DeltaLog.recordOperation(DeltaLog.scala:79) 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.DeltaLog.recordDeltaOperation(DeltaLog.scala:79) org.apache.spark.sql.delta.Checkpoints.checkpoint(Checkpoints.scala:308) org.apache.spark.sql.delta.Checkpoints.checkpoint$(Checkpoints.scala:304) org.apache.spark.sql.delta.DeltaLog.checkpoint(DeltaLog.scala:79) org.apache.spark.sql.delta.hooks.CheckpointHook$.run(CheckpointHook.scala:44) org.apache.spark.sql.delta.DeltaTransaction.runPostCommitHook(DeltaTransaction.scala:109) org.apache.spark.sql.delta.DeltaTransaction.runPostCommitHook$(DeltaTransaction.scala:99) org.apache.spark.sql.delta.OptimisticTransaction.runPostCommitHook(OptimisticTransaction.scala:169) org.apache.spark.sql.delta.OptimisticTransactionImpl.$anonfun$runPostCommitHooks$2(OptimisticTransaction.scala:2809) org.apache.spark.sql.delta.OptimisticTransactionImpl.$anonfun$runPostCommitHooks$2$adapted(OptimisticTransaction.scala:2809) scala.collection.immutable.List.foreach(List.scala:334) org.apache.spark.sql.delta.OptimisticTransactionImpl.runPostCommitHooks(OptimisticTransaction.scala:2809) org.apache.spark.sql.delta.OptimisticTransactionImpl.runPostCommitHooks$(OptimisticTransaction.scala:2800)	2026/05/22 09:08:58	0.4 s	1/1			80.6 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1267906

tenants-pool-169

replenishmentRunId = 10000000244 tenantId = 7625924700692506924 activityType = TriggerOptimize activityId = 98c9eb76-6961-30fe-bc89-63eb83c5edfa workflowType = CalculateOrderProposalsForShardWorkflow workflowId = b6d18d7d-2942-32f8-a34a-d38fc7159bf3 attempt = 1 cornerstoneTenantId = 7287 marketUnit = IW_MU_CRP-128628_3 scenario = STANDARD $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128 +details

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.DeltaLog.recordOperation(DeltaLog.scala:79)
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.DeltaLog.recordDeltaOperation(DeltaLog.scala:79)
org.apache.spark.sql.delta.Checkpoints.checkpoint(Checkpoints.scala:308)
org.apache.spark.sql.delta.Checkpoints.checkpoint$(Checkpoints.scala:304)
org.apache.spark.sql.delta.DeltaLog.checkpoint(DeltaLog.scala:79)
org.apache.spark.sql.delta.hooks.CheckpointHook$.run(CheckpointHook.scala:44)
org.apache.spark.sql.delta.DeltaTransaction.runPostCommitHook(DeltaTransaction.scala:109)
org.apache.spark.sql.delta.DeltaTransaction.runPostCommitHook$(DeltaTransaction.scala:99)
org.apache.spark.sql.delta.OptimisticTransaction.runPostCommitHook(OptimisticTransaction.scala:169)
org.apache.spark.sql.delta.OptimisticTransactionImpl.$anonfun$runPostCommitHooks$2(OptimisticTransaction.scala:2809)
org.apache.spark.sql.delta.OptimisticTransactionImpl.$anonfun$runPostCommitHooks$2$adapted(OptimisticTransaction.scala:2809)
scala.collection.immutable.List.foreach(List.scala:334)
org.apache.spark.sql.delta.OptimisticTransactionImpl.runPostCommitHooks(OptimisticTransaction.scala:2809)
org.apache.spark.sql.delta.OptimisticTransactionImpl.runPostCommitHooks$(OptimisticTransaction.scala:2800)

2026/05/22 09:08:58

0.4 s

1/1

80.6 KiB

Page:

Skipped Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
1267905		Unknown +details Unknown	Unknown	Unknown	0/0
1267904		Unknown +details Unknown	Unknown	Unknown	0/0

Page: