| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 99068 | tenants-pool-780 | replenishmentRunId = 10000000348 tenantId = 7233423560970044043 activityType = BufferDataSnapShot activityId = cef5d1bf-9c10-3645-a9ca-4bab0d7169c0 workflowType = KpiPrepareDataSnapshotWorkflow workflowId = 141c3efe-47f0-32a8-981f-09028ec902c6 attempt = 1 cornerstoneTenantId = 8469 marketUnit = AUTO_ALL_ProdLoc 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:693) 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:693) org.apache.spark.sql.delta.DeltaLog$.createDeltaLog$1(DeltaLog.scala:972) org.apache.spark.sql.delta.DeltaLog$.$anonfun$apply$5(DeltaLog.scala:996) com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4903) com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3574) com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2316) com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2190) com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2080) com.google.common.cache.LocalCache.get(LocalCache.java:4017) com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4898) org.apache.spark.sql.delta.DeltaLog$.getDeltaLogFromCache$1(DeltaLog.scala:995) org.apache.spark.sql.delta.DeltaLog$.initializeDeltaLog$1(DeltaLog.scala:1006) org.apache.spark.sql.delta.DeltaLog$.apply(DeltaLog.scala:1017) | 2026/03/20 01:06:04 | 0.4 s |
2/2
|