crp-order-qty-opt-service - Details for Job 312

Status: SUCCEEDED
Submitted: 2026/02/06 10:34:35
Duration: 1 s
Associated SQL Query: 151
Job Group: 9aa5a928-b219-375b-ac11-54040e15cd53
Completed Stages: 1
Skipped Stages: 1

Enable zooming

digraph G { subgraph clusterstage_582 { label="Stage 582 (skipped)"; subgraph cluster3983 { label="Scan parquet "; 1489 [labelType="html" label="FileScanRDD [1489] save at FileStorageAdapterImpl.java:290"]; 1490 [labelType="html" label="MapPartitionsRDD [1490] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster3980 { label="WholeStageCodegen (1)"; 1491 [labelType="html" label="MapPartitionsRDD [1491] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster3979 { label="Exchange"; 1492 [labelType="html" label="MapPartitionsRDD [1492] save at FileStorageAdapterImpl.java:290"]; } } 1489->1490; 1490->1491; 1491->1492; }

digraph G { subgraph clusterstage_583 { label="Stage 583"; subgraph cluster4181 { label="Exchange"; 1556 [labelType="html" label="ShuffledRowRDD [1556] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4166 { label="WholeStageCodegen (12)"; 1557 [labelType="html" label="MapPartitionsRDD [1557] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4163 { label="BroadcastHashJoin"; 1558 [labelType="html" label="MapPartitionsRDD [1558] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4162 { label="Project"; 1559 [labelType="html" label="MapPartitionsRDD [1559] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4161 { label="Project"; 1560 [labelType="html" label="MapPartitionsRDD [1560] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4160 { label="Project"; 1561 [labelType="html" label="MapPartitionsRDD [1561] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4159 { label="Project"; 1562 [labelType="html" label="MapPartitionsRDD [1562] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4156 { label="WholeStageCodegen (13)"; 1563 [labelType="html" label="MapPartitionsRDD [1563] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4155 { label="Project"; 1564 [labelType="html" label="MapPartitionsRDD [1564] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4154 { label="Project"; 1565 [labelType="html" label="MapPartitionsRDD [1565] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4151 { label="BroadcastHashJoin"; 1566 [labelType="html" label="MapPartitionsRDD [1566] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4150 { label="Project"; 1567 [labelType="html" label="MapPartitionsRDD [1567] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4147 { label="BroadcastHashJoin"; 1568 [labelType="html" label="MapPartitionsRDD [1568] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4146 { label="Project"; 1569 [labelType="html" label="MapPartitionsRDD [1569] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4145 { label="Project"; 1570 [labelType="html" label="MapPartitionsRDD [1570] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4144 { label="Project"; 1571 [labelType="html" label="MapPartitionsRDD [1571] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4141 { label="BroadcastHashJoin"; 1572 [labelType="html" label="MapPartitionsRDD [1572] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4140 { label="Project"; 1573 [labelType="html" label="MapPartitionsRDD [1573] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4136 { label="BroadcastHashJoin"; 1574 [labelType="html" label="MapPartitionsRDD [1574] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4135 { label="Project"; 1575 [labelType="html" label="MapPartitionsRDD [1575] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4127 { label="WholeStageCodegen (14)"; 1576 [labelType="html" label="MapPartitionsRDD [1576] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4182 { label="mapPartitionsInternal"; 1577 [labelType="html" label="MapPartitionsRDD [1577] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4183 { label="mapPartitionsInternal"; 1578 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, ... 14 more fields]\n +- BroadcastHashJoin [coalesce(supplierGroup#46713, ), isnull(supplierGroup#46713), coalesce(supplier#46714, ), isnull(supplier#46714), coalesce(subrange#46717, ), isnull(subrange#46717), coalesce(plant#46715, ), isnull(plant#46715), coalesce(deliveryDateTime#46716, 1970-01-01 00:00:00), isnull(deliveryDateTime#46716)], [coalesce(supplierGroup#49333, ), isnull(supplier... [1578] [Cached] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4186 { label="InMemoryTableScan"; 1579 [labelType="html" label="MapPartitionsRDD [1579] [Unordered] save at FileStorageAdapterImpl.java:290"]; 1580 [labelType="html" label="MapPartitionsRDD [1580] [Unordered] save at FileStorageAdapterImpl.java:290"]; 1581 [labelType="html" label="MapPartitionsRDD [1581] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4184 { label="WriteFiles"; 1582 [labelType="html" label="MapPartitionsRDD [1582] [Unordered] save at FileStorageAdapterImpl.java:290"]; } } 1556->1557; 1557->1558; 1558->1559; 1559->1560; 1560->1561; 1561->1562; 1562->1563; 1563->1564; 1564->1565; 1565->1566; 1566->1567; 1567->1568; 1568->1569; 1569->1570; 1570->1571; 1571->1572; 1572->1573; 1573->1574; 1574->1575; 1575->1576; 1576->1577; 1577->1578; 1578->1579; 1579->1580; 1580->1581; 1581->1582; }

1492,1556

1578

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
583	tenants-pool-286	replenishmentRunId = 10000000096 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = 9aa5a928-b219-375b-ac11-54040e15cd53 workflowType = PrepareDataSnapshotWorkflow workflowId = b23ef421-1eee-3d30-a73f-c7878eb04008 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD save at FileStorageAdapterImpl.java:290 +details org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:243) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeDataSnapshot(FileStorageAdapterImpl.java:290) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeProdPlantSnapshot(FileStorageAdapterImpl.java:273) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.DataSnapshotGenerationDataAccessImpl.storeProdPlantSnapshot(DataSnapshotGenerationDataAccessImpl.java:62) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:95) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapshotInternal(CreateDataSnapshotForShardActivityImpl.java:53) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapShot(CreateDataSnapshotForShardActivityImpl.java:38) 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/02/06 10:34:35	1 s	25/25	279.8 KiB	613.8 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

583

tenants-pool-286

replenishmentRunId = 10000000096 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = 9aa5a928-b219-375b-ac11-54040e15cd53 workflowType = PrepareDataSnapshotWorkflow workflowId = b23ef421-1eee-3d30-a73f-c7878eb04008 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD save at FileStorageAdapterImpl.java:290 +details

org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:243)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeDataSnapshot(FileStorageAdapterImpl.java:290)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeProdPlantSnapshot(FileStorageAdapterImpl.java:273)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.DataSnapshotGenerationDataAccessImpl.storeProdPlantSnapshot(DataSnapshotGenerationDataAccessImpl.java:62)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:95)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapshotInternal(CreateDataSnapshotForShardActivityImpl.java:53)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapShot(CreateDataSnapshotForShardActivityImpl.java:38)
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/02/06 10:34:35

1 s

25/25

279.8 KiB

613.8 KiB

Page:

Skipped Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
582	default	save at FileStorageAdapterImpl.java:290 +details org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:243) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeDataSnapshot(FileStorageAdapterImpl.java:290) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeProdPlantSnapshot(FileStorageAdapterImpl.java:273) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.DataSnapshotGenerationDataAccessImpl.storeProdPlantSnapshot(DataSnapshotGenerationDataAccessImpl.java:62) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:95) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapshotInternal(CreateDataSnapshotForShardActivityImpl.java:53) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapShot(CreateDataSnapshotForShardActivityImpl.java:38) 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)	Unknown	Unknown	0/1

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

582

default

save at FileStorageAdapterImpl.java:290 +details

org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:243)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeDataSnapshot(FileStorageAdapterImpl.java:290)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeProdPlantSnapshot(FileStorageAdapterImpl.java:273)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.DataSnapshotGenerationDataAccessImpl.storeProdPlantSnapshot(DataSnapshotGenerationDataAccessImpl.java:62)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:95)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapshotInternal(CreateDataSnapshotForShardActivityImpl.java:53)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapShot(CreateDataSnapshotForShardActivityImpl.java:38)
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)

Unknown

0/1

Page: