| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 16 | tenants-pool-582 | replenishmentRunId = 10000003977 tenantId = 8322290869003019352 activityType = GetDemands activityId = 80ab2e30-7ec4-39fd-8c9f-3de75f2c4bf4 workflowType = GetDemandsWorkflow workflowId = 5731084e-62a2-34e7-abfe-3ab62c0765d1 attempt = 1 cornerstoneTenantId = 7354 marketUnit = NML_DLY scenario = STANDARD $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128 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:677) 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:677) org.apache.spark.sql.delta.DeltaLog$.createDeltaLog$1(DeltaLog.scala:922) org.apache.spark.sql.delta.DeltaLog$.$anonfun$apply$5(DeltaLog.scala:942) com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4860) com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3551) com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2302) com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2177) com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2068) com.google.common.cache.LocalCache.get(LocalCache.java:3986) com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4855) org.apache.spark.sql.delta.DeltaLog$.getDeltaLogFromCache$1(DeltaLog.scala:941) org.apache.spark.sql.delta.DeltaLog$.apply(DeltaLog.scala:951) org.apache.spark.sql.delta.DeltaLog$.forTable(DeltaLog.scala:782) | 2025/12/18 04:04:46 | 0.3 s |
2/2
| 51.8 KiB |