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

Status: SUCCEEDED
Submitted: 2026/04/20 06:14:49
Duration: 2 s
Associated SQL Query: 27
Job Group: 36e0914c-7e4e-3a52-bc93-e306e07299ba
Completed Stages: 1
Skipped Stages: 7

Enable zooming

digraph G { id="graph_67"; subgraph graph_stage_67 { id="graph_stage_67"; isCluster="true"; label="Stage 67 (skipped)"; subgraph cluster_453 { id="cluster_453"; isCluster="true"; label="Scan parquet "; 182 [id="node_182" labelType="html" label="FileScanRDD [182] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 183 [id="node_183" labelType="html" label="MapPartitionsRDD [183] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_434 { id="cluster_434"; isCluster="true"; label="WholeStageCodegen (3)"; 186 [id="node_186" labelType="html" label="MapPartitionsRDD [186] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_433 { id="cluster_433"; isCluster="true"; label="Exchange"; 187 [id="node_187" labelType="html" label="MapPartitionsRDD [187] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 188 [id="node_188" labelType="html" label="MapPartitionsRDD [188] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 182->183; 183->186; 186->187; 187->188; }

digraph G { id="graph_68"; subgraph graph_stage_68 { id="graph_stage_68"; isCluster="true"; label="Stage 68 (skipped)"; subgraph cluster_465 { id="cluster_465"; isCluster="true"; label="Exchange"; 191 [id="node_191" labelType="html" label="ShuffledRowRDD [191] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_463 { id="cluster_463"; isCluster="true"; label="Exchange"; 192 [id="node_192" labelType="html" label="MapPartitionsRDD [192] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 191->192; }

188,191

digraph G { id="graph_69"; subgraph graph_stage_69 { id="graph_stage_69"; isCluster="true"; label="Stage 69 (skipped)"; subgraph cluster_451 { id="cluster_451"; isCluster="true"; label="Scan parquet "; 178 [id="node_178" labelType="html" label="FileScanRDD [178] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 180 [id="node_180" labelType="html" label="MapPartitionsRDD [180] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_442 { id="cluster_442"; isCluster="true"; label="WholeStageCodegen (2)"; 181 [id="node_181" labelType="html" label="MapPartitionsRDD [181] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_441 { id="cluster_441"; isCluster="true"; label="Exchange"; 184 [id="node_184" labelType="html" label="MapPartitionsRDD [184] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 185 [id="node_185" labelType="html" label="MapPartitionsRDD [185] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 178->180; 180->181; 181->184; 184->185; }

digraph G { id="graph_70"; subgraph graph_stage_70 { id="graph_stage_70"; isCluster="true"; label="Stage 70 (skipped)"; subgraph cluster_447 { id="cluster_447"; isCluster="true"; label="Scan parquet "; 173 [id="node_173" labelType="html" label="FileScanRDD [173] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 174 [id="node_174" labelType="html" label="MapPartitionsRDD [174] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_430 { id="cluster_430"; isCluster="true"; label="WholeStageCodegen (1)"; 176 [id="node_176" labelType="html" label="MapPartitionsRDD [176] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_429 { id="cluster_429"; isCluster="true"; label="Exchange"; 179 [id="node_179" labelType="html" label="MapPartitionsRDD [179] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 173->174; 174->176; 176->179; }

digraph G { id="graph_71"; subgraph graph_stage_71 { id="graph_stage_71"; isCluster="true"; label="Stage 71 (skipped)"; subgraph cluster_461 { id="cluster_461"; isCluster="true"; label="Exchange"; 189 [id="node_189" labelType="html" label="ShuffledRowRDD [189] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_459 { id="cluster_459"; isCluster="true"; label="Exchange"; 190 [id="node_190" labelType="html" label="MapPartitionsRDD [190] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 189->190; }

179,189

digraph G { id="graph_72"; subgraph graph_stage_72 { id="graph_stage_72"; isCluster="true"; label="Stage 72 (skipped)"; subgraph cluster_472 { id="cluster_472"; isCluster="true"; label="Exchange"; 193 [id="node_193" labelType="html" label="ShuffledRowRDD [193] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_468 { id="cluster_468"; isCluster="true"; label="WholeStageCodegen (5)"; 194 [id="node_194" labelType="html" label="MapPartitionsRDD [194] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_467 { id="cluster_467"; isCluster="true"; label="Exchange"; 195 [id="node_195" labelType="html" label="MapPartitionsRDD [195] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 193->194; 194->195; }

185,193

digraph G { id="graph_73"; subgraph graph_stage_73 { id="graph_stage_73"; isCluster="true"; label="Stage 73 (skipped)"; subgraph cluster_483 { id="cluster_483"; isCluster="true"; label="Exchange"; 196 [id="node_196" labelType="html" label="ShuffledRowRDD [196] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_479 { id="cluster_479"; isCluster="true"; label="WholeStageCodegen (6)"; 197 [id="node_197" labelType="html" label="MapPartitionsRDD [197] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_489 { id="cluster_489"; isCluster="true"; label="Exchange"; 198 [id="node_198" labelType="html" label="ShuffledRowRDD [198] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_485 { id="cluster_485"; isCluster="true"; label="WholeStageCodegen (7)"; 199 [id="node_199" labelType="html" label="MapPartitionsRDD [199] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_475 { id="cluster_475"; isCluster="true"; label="WholeStageCodegen (8)"; 200 [id="node_200" labelType="html" label="ZippedPartitionsRDD2 [200] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 201 [id="node_201" labelType="html" label="MapPartitionsRDD [201] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_474 { id="cluster_474"; isCluster="true"; label="Exchange"; 202 [id="node_202" labelType="html" label="MapPartitionsRDD [202] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 196->197; 198->199; 197->200; 199->200; 200->201; 201->202; }

190,196

195,198

digraph G { id="graph_74"; subgraph graph_stage_74 { id="graph_stage_74"; isCluster="true"; label="Stage 74"; subgraph cluster_511 { id="cluster_511"; isCluster="true"; label="Exchange"; 203 [id="node_203" labelType="html" label="ShuffledRowRDD [203] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_507 { id="cluster_507"; isCluster="true"; label="WholeStageCodegen (9)"; 204 [id="node_204" labelType="html" label="MapPartitionsRDD [204] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_517 { id="cluster_517"; isCluster="true"; label="Exchange"; 205 [id="node_205" labelType="html" label="ShuffledRowRDD [205] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_513 { id="cluster_513"; isCluster="true"; label="WholeStageCodegen (10)"; 206 [id="node_206" labelType="html" label="MapPartitionsRDD [206] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_504 { id="cluster_504"; isCluster="true"; label="WholeStageCodegen (11)"; 207 [id="node_207" labelType="html" label="ZippedPartitionsRDD2 [207] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 208 [id="node_208" labelType="html" label="MapPartitionsRDD [208] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_503 { id="cluster_503"; isCluster="true"; label="Project"; 209 [id="node_209" labelType="html" label="MapPartitionsRDD [209] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_490 { id="cluster_490"; isCluster="true"; label="WholeStageCodegen (12)"; 210 [id="node_210" labelType="html" label="MapPartitionsRDD [210] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_518 { id="cluster_518"; isCluster="true"; label="mapPartitionsInternal"; 211 [id="node_211" labelType="html" label="MapPartitionsRDD [211] [Unordered] isEmpty at InsightHandlerDataAccessImpl.java:62}"]; } subgraph cluster_519 { id="cluster_519"; isCluster="true"; label="mapPartitionsInternal"; 212 [id="node_212" labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- HashAggregate(keys=[product#1127, plant#1128], functions=[], output=[product#1127, plant#1128])\n +- HashAggregate(keys=[product#1127, plant#1128], functions=[], output=[product#1127, plant#1128])\n +- Project [product#1127, plant#1128]\n +- Filter (((size(demandTimeBuckets#1577, true) = 0) OR isnull(demandTimeBuckets#1577)) AND ((size(demandPointInTime#1580, true) = 0) OR isnull(demandPointInTime#1580)))\n +- BroadcastHashJoin [coalesce(plant#1128, ), isnull(plant#1128), coalesce(product#1127, ), isnull(product#1127)], [coalesce(plant#1573, ), isnull(plant#1573), coalesce(product#1572, ), isnull(product#1572)], LeftOuter, BuildRight, false\n :- Project [product#1127, plant#1128]\n : +- Generate explode(_extract_quantityDenominator#1607), [product#1127, plant#1128], true, [quantityDenominator#1216]\n : +- Project [product#1127, plant#1128, filteredUnitOfMeasureConversions#1205.quantityDenominator AS _ex... [212] [Cached] [Unordered] isEmpty at InsightHandlerDataAccessImpl.java:62}"]; } } 203->204; 205->206; 204->207; 206->207; 207->208; 208->209; 209->210; 210->211; 211->212; }

202,203

192,205

212

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
74	tenants-pool-506	replenishmentRunId = 10000000004 tenantId = 8793759653749352888 activityType = BufferDataSnapShot activityId = 36e0914c-7e4e-3a52-bc93-e306e07299ba workflowType = KpiPrepareDataSnapshotWorkflow workflowId = b49fb3c6-88b3-3c61-97e8-cbe3f98f9409 attempt = 1 cornerstoneTenantId = 8445 marketUnit = 10000_OP_PERF scenario = STANDARD isEmpty at InsightHandlerDataAccessImpl.java:62 +details org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.InsightHandlerDataAccessImpl.mapExternalProductPlantIds(InsightHandlerDataAccessImpl.java:62) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.business.insights.InsightHandlerImpl.createUnknownDemandInsight(InsightHandlerImpl.java:34) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.business.datasnapshot.DemandSnapshotEnhancementImpl.attachRawDemand(DemandSnapshotEnhancementImpl.java:65) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.business.datasnapshot.DemandSnapshotEnhancementImpl.withDemand(DemandSnapshotEnhancementImpl.java:35) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:56) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapShot(CreateDataSnapshotForShardActivityImpl.java:44) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)	2026/04/20 06:14:49	2 s	37/37			8.7 MiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

tenants-pool-506

replenishmentRunId = 10000000004 tenantId = 8793759653749352888 activityType = BufferDataSnapShot activityId = 36e0914c-7e4e-3a52-bc93-e306e07299ba workflowType = KpiPrepareDataSnapshotWorkflow workflowId = b49fb3c6-88b3-3c61-97e8-cbe3f98f9409 attempt = 1 cornerstoneTenantId = 8445 marketUnit = 10000_OP_PERF scenario = STANDARD isEmpty at InsightHandlerDataAccessImpl.java:62 +details

org.apache.spark.sql.classic.Dataset.isEmpty(Dataset.scala:559)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.InsightHandlerDataAccessImpl.mapExternalProductPlantIds(InsightHandlerDataAccessImpl.java:62)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.business.insights.InsightHandlerImpl.createUnknownDemandInsight(InsightHandlerImpl.java:34)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.business.datasnapshot.DemandSnapshotEnhancementImpl.attachRawDemand(DemandSnapshotEnhancementImpl.java:65)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.business.datasnapshot.DemandSnapshotEnhancementImpl.withDemand(DemandSnapshotEnhancementImpl.java:35)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:56)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapShot(CreateDataSnapshotForShardActivityImpl.java:44)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44)
io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23)
io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88)
io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)

2026/04/20 06:14:49

2 s

37/37

8.7 MiB

Page:

Skipped Stages (7)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
73	default	$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)	Unknown	Unknown	0/37
72	default	$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)	Unknown	Unknown	0/37
71	default	$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)	Unknown	Unknown	0/37
70	default	$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)	Unknown	Unknown	0/37
69	default	$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)	Unknown	Unknown	0/37
68	default	$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)	Unknown	Unknown	0/37
67	default	$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)	Unknown	Unknown	0/2

Page: