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

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

Enable zooming

digraph G { subgraph clusterstage_617 { label="Stage 617 (skipped)"; subgraph cluster4415 { label="LocalTableScan"; 1664 [labelType="html" label="ParallelCollectionRDD [1664] save at FileStorageAdapterImpl.java:755"]; 1665 [labelType="html" label="MapPartitionsRDD [1665] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster4414 { label="Exchange"; 1666 [labelType="html" label="MapPartitionsRDD [1666] save at FileStorageAdapterImpl.java:755"]; } } 1664->1665; 1665->1666; }

digraph G { subgraph clusterstage_618 { label="Stage 618 (skipped)"; subgraph cluster4413 { label="LocalTableScan"; 1661 [labelType="html" label="ParallelCollectionRDD [1661] save at FileStorageAdapterImpl.java:755"]; 1662 [labelType="html" label="MapPartitionsRDD [1662] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster4412 { label="Exchange"; 1663 [labelType="html" label="MapPartitionsRDD [1663] save at FileStorageAdapterImpl.java:755"]; } } 1661->1662; 1662->1663; }

digraph G { subgraph clusterstage_619 { label="Stage 619 (skipped)"; subgraph cluster4426 { label="AQEShuffleRead"; 1670 [labelType="html" label="ShuffledRowRDD [1670] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster4423 { label="WholeStageCodegen (1)"; 1671 [labelType="html" label="MapPartitionsRDD [1671] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster4431 { label="AQEShuffleRead"; 1672 [labelType="html" label="ShuffledRowRDD [1672] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster4428 { label="WholeStageCodegen (2)"; 1673 [labelType="html" label="MapPartitionsRDD [1673] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster4419 { label="WholeStageCodegen (3)"; 1674 [labelType="html" label="ZippedPartitionsRDD2 [1674] [Unordered] save at FileStorageAdapterImpl.java:755"]; 1675 [labelType="html" label="MapPartitionsRDD [1675] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster4418 { label="Exchange"; 1676 [labelType="html" label="MapPartitionsRDD [1676] [Unordered] save at FileStorageAdapterImpl.java:755"]; } } 1670->1671; 1672->1673; 1671->1674; 1673->1674; 1674->1675; 1675->1676; }

1663,1670

1666,1672

digraph G { subgraph clusterstage_620 { label="Stage 620 (skipped)"; subgraph cluster4417 { label="LocalTableScan"; 1667 [labelType="html" label="ParallelCollectionRDD [1667] save at FileStorageAdapterImpl.java:755"]; 1668 [labelType="html" label="MapPartitionsRDD [1668] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster4416 { label="Exchange"; 1669 [labelType="html" label="MapPartitionsRDD [1669] save at FileStorageAdapterImpl.java:755"]; } } 1667->1668; 1668->1669; }

digraph G { subgraph clusterstage_621 { label="Stage 621"; subgraph cluster4441 { label="AQEShuffleRead"; 1677 [labelType="html" label="ShuffledRowRDD [1677] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster4438 { label="WholeStageCodegen (4)"; 1678 [labelType="html" label="MapPartitionsRDD [1678] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster4446 { label="AQEShuffleRead"; 1679 [labelType="html" label="ShuffledRowRDD [1679] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster4443 { label="WholeStageCodegen (5)"; 1680 [labelType="html" label="MapPartitionsRDD [1680] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster4433 { label="WholeStageCodegen (6)"; 1681 [labelType="html" label="ZippedPartitionsRDD2 [1681] [Unordered] save at FileStorageAdapterImpl.java:755"]; 1682 [labelType="html" label="MapPartitionsRDD [1682] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster4432 { label="WriteFiles"; 1683 [labelType="html" label="MapPartitionsRDD [1683] [Unordered] save at FileStorageAdapterImpl.java:755"]; } } 1677->1678; 1679->1680; 1678->1681; 1680->1681; 1681->1682; 1682->1683; }

1676,1677

1669,1679

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
621	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:755 +details org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:243) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storePerformanceMetrics(FileStorageAdapterImpl.java:755) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapshotInternal(CreateDataSnapshotForShardActivityImpl.java:55) 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) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 10:34:55	0.5 s	1/1		40.8 KiB	18.2 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

621

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:755 +details

org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:243)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storePerformanceMetrics(FileStorageAdapterImpl.java:755)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapshotInternal(CreateDataSnapshotForShardActivityImpl.java:55)
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)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/02/06 10:34:55

0.5 s

1/1

40.8 KiB

18.2 KiB

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
620	default	save at FileStorageAdapterImpl.java:755 +details org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:243) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storePerformanceMetrics(FileStorageAdapterImpl.java:755) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapshotInternal(CreateDataSnapshotForShardActivityImpl.java:55) 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) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/25
619	default	save at FileStorageAdapterImpl.java:755 +details org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:243) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storePerformanceMetrics(FileStorageAdapterImpl.java:755) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapshotInternal(CreateDataSnapshotForShardActivityImpl.java:55) 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) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
618	default	save at FileStorageAdapterImpl.java:755 +details org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:243) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storePerformanceMetrics(FileStorageAdapterImpl.java:755) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapshotInternal(CreateDataSnapshotForShardActivityImpl.java:55) 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) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/25
617	default	save at FileStorageAdapterImpl.java:755 +details org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:243) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storePerformanceMetrics(FileStorageAdapterImpl.java:755) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapshotInternal(CreateDataSnapshotForShardActivityImpl.java:55) 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) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/25

Page: