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

Status: SUCCEEDED
Submitted: 2026/02/06 06:56:22
Duration: 1 s
Associated SQL Query: 73
Job Group: 4ed5a2f4-9ab7-3eed-9f6f-05c008033ee1
Completed Stages: 1
Skipped Stages: 3

Enable zooming

digraph G { subgraph clusterstage_288 { label="Stage 288 (skipped)"; subgraph cluster1748 { label="Scan parquet "; 647 [labelType="html" label="FileScanRDD [647] save at FileStorageAdapterImpl.java:290"]; 648 [labelType="html" label="MapPartitionsRDD [648] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1745 { label="WholeStageCodegen (1)"; 649 [labelType="html" label="MapPartitionsRDD [649] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1744 { label="Exchange"; 650 [labelType="html" label="MapPartitionsRDD [650] save at FileStorageAdapterImpl.java:290"]; } } 647->648; 648->649; 649->650; }

digraph G { subgraph clusterstage_289 { label="Stage 289 (skipped)"; subgraph cluster1946 { label="Exchange"; 714 [labelType="html" label="ShuffledRowRDD [714] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1931 { label="WholeStageCodegen (12)"; 715 [labelType="html" label="MapPartitionsRDD [715] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1928 { label="BroadcastHashJoin"; 716 [labelType="html" label="MapPartitionsRDD [716] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1927 { label="Project"; 717 [labelType="html" label="MapPartitionsRDD [717] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1926 { label="Project"; 718 [labelType="html" label="MapPartitionsRDD [718] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1925 { label="Project"; 719 [labelType="html" label="MapPartitionsRDD [719] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1924 { label="Project"; 720 [labelType="html" label="MapPartitionsRDD [720] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1921 { label="WholeStageCodegen (13)"; 721 [labelType="html" label="MapPartitionsRDD [721] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1920 { label="Project"; 722 [labelType="html" label="MapPartitionsRDD [722] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1919 { label="Project"; 723 [labelType="html" label="MapPartitionsRDD [723] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1916 { label="BroadcastHashJoin"; 724 [labelType="html" label="MapPartitionsRDD [724] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1915 { label="Project"; 725 [labelType="html" label="MapPartitionsRDD [725] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1912 { label="BroadcastHashJoin"; 726 [labelType="html" label="MapPartitionsRDD [726] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1911 { label="Project"; 727 [labelType="html" label="MapPartitionsRDD [727] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1910 { label="Project"; 728 [labelType="html" label="MapPartitionsRDD [728] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1909 { label="Project"; 729 [labelType="html" label="MapPartitionsRDD [729] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1906 { label="BroadcastHashJoin"; 730 [labelType="html" label="MapPartitionsRDD [730] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1905 { label="Project"; 731 [labelType="html" label="MapPartitionsRDD [731] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1901 { label="BroadcastHashJoin"; 732 [labelType="html" label="MapPartitionsRDD [732] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1900 { label="Project"; 733 [labelType="html" label="MapPartitionsRDD [733] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1892 { label="WholeStageCodegen (14)"; 734 [labelType="html" label="MapPartitionsRDD [734] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1947 { label="mapPartitionsInternal"; 735 [labelType="html" label="MapPartitionsRDD [735] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1948 { label="mapPartitionsInternal"; 736 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, ... 14 more fields]\n +- BroadcastHashJoin [coalesce(supplierGroup#17253, ), isnull(supplierGroup#17253), coalesce(supplier#17254, ), isnull(supplier#17254), coalesce(subrange#17257, ), isnull(subrange#17257), coalesce(plant#17255, ), isnull(plant#17255), coalesce(deliveryDateTime#17256, 1970-01-01 00:00:00), isnull(deliveryDateTime#17256)], [coalesce(supplierGroup#19873, ), isnull(supplier... [736] [Cached] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster2006 { label="InMemoryTableScan"; 756 [labelType="html" label="MapPartitionsRDD [756] [Unordered] save at FileStorageAdapterImpl.java:290"]; 757 [labelType="html" label="MapPartitionsRDD [757] [Unordered] save at FileStorageAdapterImpl.java:290"]; 758 [labelType="html" label="MapPartitionsRDD [758] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster2002 { label="WholeStageCodegen (4)"; 759 [labelType="html" label="MapPartitionsRDD [759] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster2001 { label="Exchange"; 760 [labelType="html" label="MapPartitionsRDD [760] [Unordered] save at FileStorageAdapterImpl.java:290"]; } } 714->715; 715->716; 716->717; 717->718; 718->719; 719->720; 720->721; 721->722; 722->723; 723->724; 724->725; 725->726; 726->727; 727->728; 728->729; 729->730; 730->731; 731->732; 732->733; 733->734; 734->735; 735->736; 736->756; 756->757; 757->758; 758->759; 759->760; }

650,714

736

digraph G { subgraph clusterstage_290 { label="Stage 290 (skipped)"; subgraph cluster1946 { label="Exchange"; 714 [labelType="html" label="ShuffledRowRDD [714] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1931 { label="WholeStageCodegen (12)"; 715 [labelType="html" label="MapPartitionsRDD [715] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1928 { label="BroadcastHashJoin"; 716 [labelType="html" label="MapPartitionsRDD [716] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1927 { label="Project"; 717 [labelType="html" label="MapPartitionsRDD [717] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1926 { label="Project"; 718 [labelType="html" label="MapPartitionsRDD [718] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1925 { label="Project"; 719 [labelType="html" label="MapPartitionsRDD [719] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1924 { label="Project"; 720 [labelType="html" label="MapPartitionsRDD [720] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1921 { label="WholeStageCodegen (13)"; 721 [labelType="html" label="MapPartitionsRDD [721] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1920 { label="Project"; 722 [labelType="html" label="MapPartitionsRDD [722] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1919 { label="Project"; 723 [labelType="html" label="MapPartitionsRDD [723] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1916 { label="BroadcastHashJoin"; 724 [labelType="html" label="MapPartitionsRDD [724] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1915 { label="Project"; 725 [labelType="html" label="MapPartitionsRDD [725] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1912 { label="BroadcastHashJoin"; 726 [labelType="html" label="MapPartitionsRDD [726] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1911 { label="Project"; 727 [labelType="html" label="MapPartitionsRDD [727] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1910 { label="Project"; 728 [labelType="html" label="MapPartitionsRDD [728] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1909 { label="Project"; 729 [labelType="html" label="MapPartitionsRDD [729] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1906 { label="BroadcastHashJoin"; 730 [labelType="html" label="MapPartitionsRDD [730] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1905 { label="Project"; 731 [labelType="html" label="MapPartitionsRDD [731] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1901 { label="BroadcastHashJoin"; 732 [labelType="html" label="MapPartitionsRDD [732] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1900 { label="Project"; 733 [labelType="html" label="MapPartitionsRDD [733] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1892 { label="WholeStageCodegen (14)"; 734 [labelType="html" label="MapPartitionsRDD [734] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1947 { label="mapPartitionsInternal"; 735 [labelType="html" label="MapPartitionsRDD [735] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster1948 { label="mapPartitionsInternal"; 736 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, ... 14 more fields]\n +- BroadcastHashJoin [coalesce(supplierGroup#17253, ), isnull(supplierGroup#17253), coalesce(supplier#17254, ), isnull(supplier#17254), coalesce(subrange#17257, ), isnull(subrange#17257), coalesce(plant#17255, ), isnull(plant#17255), coalesce(deliveryDateTime#17256, 1970-01-01 00:00:00), isnull(deliveryDateTime#17256)], [coalesce(supplierGroup#19873, ), isnull(supplier... [736] [Cached] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster2013 { label="InMemoryTableScan"; 761 [labelType="html" label="MapPartitionsRDD [761] [Unordered] save at FileStorageAdapterImpl.java:290"]; 762 [labelType="html" label="MapPartitionsRDD [762] [Unordered] save at FileStorageAdapterImpl.java:290"]; 763 [labelType="html" label="MapPartitionsRDD [763] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster2008 { label="WholeStageCodegen (5)"; 764 [labelType="html" label="MapPartitionsRDD [764] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster2007 { label="Exchange"; 765 [labelType="html" label="MapPartitionsRDD [765] [Unordered] save at FileStorageAdapterImpl.java:290"]; } } 714->715; 715->716; 716->717; 717->718; 718->719; 719->720; 720->721; 721->722; 722->723; 723->724; 724->725; 725->726; 726->727; 727->728; 728->729; 729->730; 730->731; 731->732; 732->733; 733->734; 734->735; 735->736; 736->761; 761->762; 762->763; 763->764; 764->765; }

650,714

736

digraph G { subgraph clusterstage_291 { label="Stage 291"; subgraph cluster2054 { label="Exchange"; 775 [labelType="html" label="ShuffledRowRDD [775] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster2049 { label="WholeStageCodegen (7)"; 776 [labelType="html" label="MapPartitionsRDD [776] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster2071 { label="Exchange"; 777 [labelType="html" label="ShuffledRowRDD [777] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster2056 { label="WholeStageCodegen (8)"; 778 [labelType="html" label="MapPartitionsRDD [778] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster2045 { label="WholeStageCodegen (9)"; 779 [labelType="html" label="ZippedPartitionsRDD2 [779] [Unordered] save at FileStorageAdapterImpl.java:290"]; 780 [labelType="html" label="MapPartitionsRDD [780] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster2044 { label="ObjectHashAggregate"; 781 [labelType="html" label="MapPartitionsRDD [781] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster2043 { label="ObjectHashAggregate"; 782 [labelType="html" label="MapPartitionsRDD [782] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster2072 { label="mapPartitionsInternal"; 783 [labelType="html" label="MapPartitionsRDD [783] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster2073 { label="mapPartitionsInternal"; 784 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- ObjectHashAggregate(keys=[orderProposalId#17266L], functions=[collect_list(struct(optGroupId, optGroupId#22161, minOrderProfile, minOrderProfile#22717, assignmentDetails, assignmentDetails#22719, minOrderGoal, minOrderGoal#22465), 0, 0)], output=[orderProposalId#17266L, optimizationGroups#22745])\n +- ObjectHashAggregate(keys=[orderProposalId#17266L], functions=[partial_collect_list(struct(optGroupId, optGroupId#22161, minOrderProfile, minOrderProfile#22717, assignmentDetails, assignmentDetails#22719, minOrderGoal, minOrderGoal#22465), 0, 0)], output=[orderProposalId#17266L, buf#25449])\n +- Project [orderProposalId#17266L, optGroupId#22161, minOrderProfile#22717, assignmentDetails#22719, minOrderGoal#22465]\n +- SortMergeJoin [orderProposalId#17266L], [orderProposalId#22518L], LeftOuter\n :- Sort [orderProposalId#17266L ASC NULLS FIRST], false, 0\n : +- HashAggregate(keys=[orderProposalId#17266L], functions=[], output=[orderProposalId... [784] [Cached] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster2076 { label="InMemoryTableScan"; 785 [labelType="html" label="MapPartitionsRDD [785] [Unordered] save at FileStorageAdapterImpl.java:290"]; 786 [labelType="html" label="MapPartitionsRDD [786] [Unordered] save at FileStorageAdapterImpl.java:290"]; 787 [labelType="html" label="MapPartitionsRDD [787] [Unordered] save at FileStorageAdapterImpl.java:290"]; } subgraph cluster2074 { label="WriteFiles"; 788 [labelType="html" label="MapPartitionsRDD [788] [Unordered] save at FileStorageAdapterImpl.java:290"]; } } 775->776; 777->778; 776->779; 778->779; 779->780; 780->781; 781->782; 782->783; 783->784; 784->785; 785->786; 786->787; 787->788; }

760,775

765,777

784

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
291	tenants-pool-286	replenishmentRunId = 10000000095 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = 4ed5a2f4-9ab7-3eed-9f6f-05c008033ee1 workflowType = PrepareDataSnapshotWorkflow workflowId = 40151c89-de61-38cf-b7f5-9acab77d9e03 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.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)	2026/02/06 06:56:22	1 s	25/25	3.0 KiB	78.9 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

291

tenants-pool-286

replenishmentRunId = 10000000095 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = 4ed5a2f4-9ab7-3eed-9f6f-05c008033ee1 workflowType = PrepareDataSnapshotWorkflow workflowId = 40151c89-de61-38cf-b7f5-9acab77d9e03 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.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)

2026/02/06 06:56:22

1 s

25/25

3.0 KiB

78.9 KiB

Page:

Skipped Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
290	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
289	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
288	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

290

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

289

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

288

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: