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

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

Enable zooming

digraph G { subgraph clusterstage_606 { label="Stage 606 (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_607 { label="Stage 607 (skipped)"; 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 cluster4241 { label="InMemoryTableScan"; 1598 [labelType="html" label="MapPartitionsRDD [1598] [Unordered] save at FileStorageAdapterImpl.java:290"]; 1599 [labelType="html" label="MapPartitionsRDD [1599] [Unordered] save at FileStorageAdapterImpl.java:290"]; 1600 [labelType="html" label="MapPartitionsRDD [1600] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4237 { label="WholeStageCodegen (4)"; 1601 [labelType="html" label="MapPartitionsRDD [1601] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4236 { label="Exchange"; 1602 [labelType="html" label="MapPartitionsRDD [1602] [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->1598; 1598->1599; 1599->1600; 1600->1601; 1601->1602; }

1492,1556

1578

digraph G { subgraph clusterstage_608 { label="Stage 608 (skipped)"; 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 cluster4248 { label="InMemoryTableScan"; 1603 [labelType="html" label="MapPartitionsRDD [1603] [Unordered] save at FileStorageAdapterImpl.java:290"]; 1604 [labelType="html" label="MapPartitionsRDD [1604] [Unordered] save at FileStorageAdapterImpl.java:290"]; 1605 [labelType="html" label="MapPartitionsRDD [1605] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4243 { label="WholeStageCodegen (5)"; 1606 [labelType="html" label="MapPartitionsRDD [1606] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4242 { label="Exchange"; 1607 [labelType="html" label="MapPartitionsRDD [1607] [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->1603; 1603->1604; 1604->1605; 1605->1606; 1606->1607; }

1492,1556

1578

digraph G { subgraph clusterstage_609 { label="Stage 609"; subgraph cluster4289 { label="Exchange"; 1617 [labelType="html" label="ShuffledRowRDD [1617] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4284 { label="WholeStageCodegen (7)"; 1618 [labelType="html" label="MapPartitionsRDD [1618] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4306 { label="Exchange"; 1619 [labelType="html" label="ShuffledRowRDD [1619] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4291 { label="WholeStageCodegen (8)"; 1620 [labelType="html" label="MapPartitionsRDD [1620] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4280 { label="WholeStageCodegen (9)"; 1621 [labelType="html" label="ZippedPartitionsRDD2 [1621] [Unordered] save at FileStorageAdapterImpl.java:290"]; 1622 [labelType="html" label="MapPartitionsRDD [1622] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4279 { label="ObjectHashAggregate"; 1623 [labelType="html" label="MapPartitionsRDD [1623] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4278 { label="ObjectHashAggregate"; 1624 [labelType="html" label="MapPartitionsRDD [1624] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4307 { label="mapPartitionsInternal"; 1625 [labelType="html" label="MapPartitionsRDD [1625] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4308 { label="mapPartitionsInternal"; 1626 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- ObjectHashAggregate(keys=[orderProposalId#46726L], functions=[collect_list(struct(optGroupId, optGroupId#51603, minOrderProfile, minOrderProfile#52159, assignmentDetails, assignmentDetails#52161, minOrderGoal, minOrderGoal#51907), 0, 0)], output=[orderProposalId#46726L, optimizationGroups#52187])\n +- ObjectHashAggregate(keys=[orderProposalId#46726L], functions=[partial_collect_list(struct(optGroupId, optGroupId#51603, minOrderProfile, minOrderProfile#52159, assignmentDetails, assignmentDetails#52161, minOrderGoal, minOrderGoal#51907), 0, 0)], output=[orderProposalId#46726L, buf#54891])\n +- Project [orderProposalId#46726L, optGroupId#51603, minOrderProfile#52159, assignmentDetails#52161, minOrderGoal#51907]\n +- SortMergeJoin [orderProposalId#46726L], [orderProposalId#51960L], LeftOuter\n :- Sort [orderProposalId#46726L ASC NULLS FIRST], false, 0\n : +- HashAggregate(keys=[orderProposalId#46726L], functions=[], output=[orderProposalId... [1626] [Cached] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4406 { label="InMemoryTableScan"; 1651 [labelType="html" label="MapPartitionsRDD [1651] [Unordered] save at FileStorageAdapterImpl.java:290"]; 1652 [labelType="html" label="MapPartitionsRDD [1652] [Unordered] save at FileStorageAdapterImpl.java:290"]; 1653 [labelType="html" label="MapPartitionsRDD [1653] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4397 { label="WholeStageCodegen (2)"; 1654 [labelType="html" label="MapPartitionsRDD [1654] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4396 { label="Project"; 1655 [labelType="html" label="MapPartitionsRDD [1655] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4395 { label="ObjectHashAggregate"; 1656 [labelType="html" label="MapPartitionsRDD [1656] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster4394 { label="Exchange"; 1657 [labelType="html" label="MapPartitionsRDD [1657] [Unordered] save at FileStorageAdapterImpl.java:290"]; } } 1617->1618; 1619->1620; 1618->1621; 1620->1621; 1621->1622; 1622->1623; 1623->1624; 1624->1625; 1625->1626; 1626->1651; 1651->1652; 1652->1653; 1653->1654; 1654->1655; 1655->1656; 1656->1657; }

1602,1617

1607,1619

1626

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
609	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.storeCommonDataSnapshot(FileStorageAdapterImpl.java:283) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.DataSnapshotGenerationDataAccessImpl.storeCommonDataSnapshot(DataSnapshotGenerationDataAccessImpl.java:72) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:97) 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:53	93 ms	25/25	3.0 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

609

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.storeCommonDataSnapshot(FileStorageAdapterImpl.java:283)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.DataSnapshotGenerationDataAccessImpl.storeCommonDataSnapshot(DataSnapshotGenerationDataAccessImpl.java:72)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:97)
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:53

93 ms

25/25

3.0 KiB

Page:

Skipped Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
608	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.storeOrderProposalSnapshot(FileStorageAdapterImpl.java:278) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.DataSnapshotGenerationDataAccessImpl.storeOrderProposalSnapshot(DataSnapshotGenerationDataAccessImpl.java:67) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:96) 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/25
607	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.storeOrderProposalSnapshot(FileStorageAdapterImpl.java:278) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.DataSnapshotGenerationDataAccessImpl.storeOrderProposalSnapshot(DataSnapshotGenerationDataAccessImpl.java:67) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:96) 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/25
606	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

608

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.storeOrderProposalSnapshot(FileStorageAdapterImpl.java:278)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.DataSnapshotGenerationDataAccessImpl.storeOrderProposalSnapshot(DataSnapshotGenerationDataAccessImpl.java:67)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:96)
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/25

607

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.storeOrderProposalSnapshot(FileStorageAdapterImpl.java:278)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.DataSnapshotGenerationDataAccessImpl.storeOrderProposalSnapshot(DataSnapshotGenerationDataAccessImpl.java:67)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:96)
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/25

606

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: