crp-order-quantity-kpi-service - Details for Job 5342

Status: SUCCEEDED
Submitted: 2026/03/20 05:59:01
Duration: 0.2 s
Associated SQL Query: 2980
Job Group: 372339e3-e78f-3202-9d96-da74ae3e269f
Completed Stages: 1

Enable zooming

digraph G { id="graph_100759"; subgraph graph_stage_100759 { id="graph_stage_100759"; isCluster="true"; label="Stage 100759"; subgraph cluster_121932 { id="cluster_121932"; isCluster="true"; label="Scan parquet "; 47000 [id="node_47000" labelType="html" label="FileScanRDD [47000] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; 47001 [id="node_47001" labelType="html" label="MapPartitionsRDD [47001] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; } subgraph cluster_121923 { id="cluster_121923"; isCluster="true"; label="WholeStageCodegen (1)"; 47002 [id="node_47002" labelType="html" label="MapPartitionsRDD [47002] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; } subgraph cluster_121937 { id="cluster_121937"; isCluster="true"; label="Scan json "; 47003 [id="node_47003" labelType="html" label="FileScanRDD [47003] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; 47004 [id="node_47004" labelType="html" label="MapPartitionsRDD [47004] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; } subgraph cluster_121933 { id="cluster_121933"; isCluster="true"; label="WholeStageCodegen (2)"; 47005 [id="node_47005" labelType="html" label="MapPartitionsRDD [47005] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; } subgraph cluster_121922 { id="cluster_121922"; isCluster="true"; label="Union"; 47006 [id="node_47006" labelType="html" label="UnionRDD [47006] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; } subgraph cluster_121938 { id="cluster_121938"; isCluster="true"; label="mapPartitionsInternal"; 47007 [id="node_47007" labelType="html" label="MapPartitionsRDD [47007] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128}"]; } } 47000->47001; 47001->47002; 47003->47004; 47004->47005; 47002->47006; 47005->47006; 47006->47007; }

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
100759	tenants-pool-451	replenishmentRunId = 10000000678 tenantId = 6951945722030153353 activityType = BufferDataSnapShot activityId = 372339e3-e78f-3202-9d96-da74ae3e269f workflowType = KpiPrepareDataSnapshotWorkflow workflowId = df824559-c1c8-3a48-92fe-1082cc951e9b attempt = 1 cornerstoneTenantId = 8468 marketUnit = IW_MU_CRP-125444_1 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: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 05:59:01	0.2 s	5/5

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

100759

tenants-pool-451

replenishmentRunId = 10000000678 tenantId = 6951945722030153353 activityType = BufferDataSnapShot activityId = 372339e3-e78f-3202-9d96-da74ae3e269f workflowType = KpiPrepareDataSnapshotWorkflow workflowId = df824559-c1c8-3a48-92fe-1082cc951e9b attempt = 1 cornerstoneTenantId = 8468 marketUnit = IW_MU_CRP-125444_1 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: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 05:59:01

0.2 s

5/5

Page: