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

Status: SUCCEEDED
Submitted: 2026/03/21 01:07:54
Duration: 0.4 s
Associated SQL Query: 3482
Job Group: d11927ad-3153-358a-914c-ba06a15db40a
Completed Stages: 1

Enable zooming

digraph G { id="graph_115263"; subgraph graph_stage_115263 { id="graph_stage_115263"; isCluster="true"; label="Stage 115263"; subgraph cluster_142872 { id="cluster_142872"; isCluster="true"; label="Scan parquet "; 55020 [id="node_55020" labelType="html" label="FileScanRDD [55020] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 55021 [id="node_55021" labelType="html" label="MapPartitionsRDD [55021] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_142868 { id="cluster_142868"; isCluster="true"; label="WholeStageCodegen (1)"; 55022 [id="node_55022" labelType="html" label="MapPartitionsRDD [55022] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_142876 { id="cluster_142876"; isCluster="true"; label="Scan json "; 55023 [id="node_55023" labelType="html" label="FileScanRDD [55023] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 55024 [id="node_55024" labelType="html" label="MapPartitionsRDD [55024] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_142873 { id="cluster_142873"; isCluster="true"; label="WholeStageCodegen (2)"; 55025 [id="node_55025" labelType="html" label="MapPartitionsRDD [55025] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_142867 { id="cluster_142867"; isCluster="true"; label="Union"; 55026 [id="node_55026" labelType="html" label="UnionRDD [55026] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_142866 { id="cluster_142866"; isCluster="true"; label="Exchange"; 55027 [id="node_55027" labelType="html" label="MapPartitionsRDD [55027] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 55020->55021; 55021->55022; 55023->55024; 55024->55025; 55022->55026; 55025->55026; 55026->55027; }

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
115263	tenants-pool-780	Delta: replenishmentRunId = 10000000350 tenantId = 7233423560970044043 activityType = BufferDataSnapShot activityId = d11927ad-3153-358a-914c-ba06a15db40a workflowType = KpiPrepareDataSnapshotWorkflow workflowId = ae4415f9-75c3-3ec1-ab81-34528dde231c attempt = 1 cornerstoneTenantId = 8469 marketUnit = AUTO_ALL_ProdLoc scenario = STANDARD: Filtering files for query $anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) 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/03/21 01:07:54	0.4 s	9/9				59.3 KiB

Page: