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

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

Enable zooming

digraph G { id="graph_435"; subgraph graph_stage_435 { id="graph_stage_435"; isCluster="true"; label="Stage 435 (skipped)"; subgraph cluster_1125 { id="cluster_1125"; isCluster="true"; label="Scan parquet "; 385 [id="node_385" labelType="html" label="FileScanRDD [385] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 386 [id="node_386" labelType="html" label="MapPartitionsRDD [386] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1091 { id="cluster_1091"; isCluster="true"; label="WholeStageCodegen (2)"; 387 [id="node_387" labelType="html" label="MapPartitionsRDD [387] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1090 { id="cluster_1090"; isCluster="true"; label="Exchange"; 388 [id="node_388" labelType="html" label="MapPartitionsRDD [388] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 389 [id="node_389" labelType="html" label="MapPartitionsRDD [389] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 385->386; 386->387; 387->388; 388->389; }

digraph G { id="graph_436"; subgraph graph_stage_436 { id="graph_stage_436"; isCluster="true"; label="Stage 436 (skipped)"; subgraph cluster_1709 { id="cluster_1709"; isCluster="true"; label="Exchange"; 629 [id="node_629" labelType="html" label="ShuffledRowRDD [629] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1688 { id="cluster_1688"; isCluster="true"; label="WholeStageCodegen (82)"; 630 [id="node_630" labelType="html" label="MapPartitionsRDD [630] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1687 { id="cluster_1687"; isCluster="true"; label="Exchange"; 631 [id="node_631" labelType="html" label="MapPartitionsRDD [631] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 629->630; 630->631; }

389,629

digraph G { id="graph_437"; subgraph graph_stage_437 { id="graph_stage_437"; isCluster="true"; label="Stage 437 (skipped)"; subgraph cluster_1150 { id="cluster_1150"; isCluster="true"; label="Scan parquet "; 405 [id="node_405" labelType="html" label="FileScanRDD [405] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 406 [id="node_406" labelType="html" label="MapPartitionsRDD [406] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1085 { id="cluster_1085"; isCluster="true"; label="WholeStageCodegen (1)"; 407 [id="node_407" labelType="html" label="MapPartitionsRDD [407] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1084 { id="cluster_1084"; isCluster="true"; label="Exchange"; 408 [id="node_408" labelType="html" label="MapPartitionsRDD [408] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 405->406; 406->407; 407->408; }

digraph G { id="graph_438"; subgraph graph_stage_438 { id="graph_stage_438"; isCluster="true"; label="Stage 438 (skipped)"; subgraph cluster_1685 { id="cluster_1685"; isCluster="true"; label="Exchange"; 621 [id="node_621" labelType="html" label="ShuffledRowRDD [621] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1683 { id="cluster_1683"; isCluster="true"; label="Exchange"; 622 [id="node_622" labelType="html" label="MapPartitionsRDD [622] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 621->622; }

408,621

digraph G { id="graph_439"; subgraph graph_stage_439 { id="graph_stage_439"; isCluster="true"; label="Stage 439 (skipped)"; subgraph cluster_1794 { id="cluster_1794"; isCluster="true"; label="Exchange"; 643 [id="node_643" labelType="html" label="ShuffledRowRDD [643] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1782 { id="cluster_1782"; isCluster="true"; label="WholeStageCodegen (111)"; 647 [id="node_647" labelType="html" label="MapPartitionsRDD [647] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1820 { id="cluster_1820"; isCluster="true"; label="Exchange"; 651 [id="node_651" labelType="html" label="ShuffledRowRDD [651] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1803 { id="cluster_1803"; isCluster="true"; label="WholeStageCodegen (112)"; 652 [id="node_652" labelType="html" label="MapPartitionsRDD [652] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1759 { id="cluster_1759"; isCluster="true"; label="WholeStageCodegen (113)"; 656 [id="node_656" labelType="html" label="ZippedPartitionsRDD2 [656] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 660 [id="node_660" labelType="html" label="MapPartitionsRDD [660] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1758 { id="cluster_1758"; isCluster="true"; label="Exchange"; 662 [id="node_662" labelType="html" label="MapPartitionsRDD [662] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 643->647; 651->652; 647->656; 652->656; 656->660; 660->662; }

622,643

631,651

digraph G { id="graph_440"; subgraph graph_stage_440 { id="graph_stage_440"; isCluster="true"; label="Stage 440 (skipped)"; subgraph cluster_1138 { id="cluster_1138"; isCluster="true"; label="Scan parquet "; 395 [id="node_395" labelType="html" label="FileScanRDD [395] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 396 [id="node_396" labelType="html" label="MapPartitionsRDD [396] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1097 { id="cluster_1097"; isCluster="true"; label="WholeStageCodegen (3)"; 397 [id="node_397" labelType="html" label="MapPartitionsRDD [397] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1096 { id="cluster_1096"; isCluster="true"; label="Exchange"; 398 [id="node_398" labelType="html" label="MapPartitionsRDD [398] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 399 [id="node_399" labelType="html" label="MapPartitionsRDD [399] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 395->396; 396->397; 397->398; 398->399; }

digraph G { id="graph_441"; subgraph graph_stage_441 { id="graph_stage_441"; isCluster="true"; label="Stage 441 (skipped)"; subgraph cluster_1694 { id="cluster_1694"; isCluster="true"; label="Exchange"; 623 [id="node_623" labelType="html" label="ShuffledRowRDD [623] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1692 { id="cluster_1692"; isCluster="true"; label="Exchange"; 624 [id="node_624" labelType="html" label="MapPartitionsRDD [624] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 623->624; }

399,623

digraph G { id="graph_442"; subgraph graph_stage_442 { id="graph_stage_442"; isCluster="true"; label="Stage 442 (skipped)"; subgraph cluster_1845 { id="cluster_1845"; isCluster="true"; label="Exchange"; 668 [id="node_668" labelType="html" label="ShuffledRowRDD [668] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1841 { id="cluster_1841"; isCluster="true"; label="WholeStageCodegen (165)"; 669 [id="node_669" labelType="html" label="MapPartitionsRDD [669] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1851 { id="cluster_1851"; isCluster="true"; label="Exchange"; 670 [id="node_670" labelType="html" label="ShuffledRowRDD [670] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1847 { id="cluster_1847"; isCluster="true"; label="WholeStageCodegen (166)"; 671 [id="node_671" labelType="html" label="MapPartitionsRDD [671] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1838 { id="cluster_1838"; isCluster="true"; label="WholeStageCodegen (167)"; 672 [id="node_672" labelType="html" label="ZippedPartitionsRDD2 [672] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 673 [id="node_673" labelType="html" label="MapPartitionsRDD [673] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1837 { id="cluster_1837"; isCluster="true"; label="Project"; 674 [id="node_674" labelType="html" label="MapPartitionsRDD [674] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1830 { id="cluster_1830"; isCluster="true"; label="WholeStageCodegen (168)"; 675 [id="node_675" labelType="html" label="MapPartitionsRDD [675] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1829 { id="cluster_1829"; isCluster="true"; label="Exchange"; 676 [id="node_676" labelType="html" label="MapPartitionsRDD [676] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 668->669; 670->671; 669->672; 671->672; 672->673; 673->674; 674->675; 675->676; }

662,668

624,670

digraph G { id="graph_443"; subgraph graph_stage_443 { id="graph_stage_443"; isCluster="true"; label="Stage 443 (skipped)"; subgraph cluster_1202 { id="cluster_1202"; isCluster="true"; label="Scan parquet "; 476 [id="node_476" labelType="html" label="FileScanRDD [476] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 478 [id="node_478" labelType="html" label="MapPartitionsRDD [478] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1120 { id="cluster_1120"; isCluster="true"; label="WholeStageCodegen (21)"; 483 [id="node_483" labelType="html" label="MapPartitionsRDD [483] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1119 { id="cluster_1119"; isCluster="true"; label="Exchange"; 484 [id="node_484" labelType="html" label="MapPartitionsRDD [484] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 485 [id="node_485" labelType="html" label="MapPartitionsRDD [485] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 476->478; 478->483; 483->484; 484->485; }

digraph G { id="graph_444"; subgraph graph_stage_444 { id="graph_stage_444"; isCluster="true"; label="Stage 444 (skipped)"; subgraph cluster_1713 { id="cluster_1713"; isCluster="true"; label="Exchange"; 635 [id="node_635" labelType="html" label="ShuffledRowRDD [635] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1705 { id="cluster_1705"; isCluster="true"; label="WholeStageCodegen (89)"; 636 [id="node_636" labelType="html" label="MapPartitionsRDD [636] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1704 { id="cluster_1704"; isCluster="true"; label="Exchange"; 637 [id="node_637" labelType="html" label="MapPartitionsRDD [637] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 635->636; 636->637; }

485,635

digraph G { id="graph_445"; subgraph graph_stage_445 { id="graph_stage_445"; isCluster="true"; label="Stage 445 (skipped)"; subgraph cluster_1794 { id="cluster_1794"; isCluster="true"; label="Exchange"; 643 [id="node_643" labelType="html" label="ShuffledRowRDD [643] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1857 { id="cluster_1857"; isCluster="true"; label="WholeStageCodegen (169)"; 677 [id="node_677" labelType="html" label="MapPartitionsRDD [677] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1868 { id="cluster_1868"; isCluster="true"; label="Exchange"; 678 [id="node_678" labelType="html" label="ShuffledRowRDD [678] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1864 { id="cluster_1864"; isCluster="true"; label="WholeStageCodegen (170)"; 679 [id="node_679" labelType="html" label="MapPartitionsRDD [679] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1854 { id="cluster_1854"; isCluster="true"; label="WholeStageCodegen (171)"; 680 [id="node_680" labelType="html" label="ZippedPartitionsRDD2 [680] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 681 [id="node_681" labelType="html" label="MapPartitionsRDD [681] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1853 { id="cluster_1853"; isCluster="true"; label="Exchange"; 682 [id="node_682" labelType="html" label="MapPartitionsRDD [682] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 643->677; 678->679; 677->680; 679->680; 680->681; 681->682; }

622,643

637,678

digraph G { id="graph_446"; subgraph graph_stage_446 { id="graph_stage_446"; isCluster="true"; label="Stage 446 (skipped)"; subgraph cluster_1851 { id="cluster_1851"; isCluster="true"; label="Exchange"; 670 [id="node_670" labelType="html" label="ShuffledRowRDD [670] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2071 { id="cluster_2071"; isCluster="true"; label="Exchange"; 727 [id="node_727" labelType="html" label="ShuffledRowRDD [727] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2083 { id="cluster_2083"; isCluster="true"; label="WholeStageCodegen (261)"; 738 [id="node_738" labelType="html" label="MapPartitionsRDD [738] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2089 { id="cluster_2089"; isCluster="true"; label="WholeStageCodegen (262)"; 739 [id="node_739" labelType="html" label="MapPartitionsRDD [739] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2080 { id="cluster_2080"; isCluster="true"; label="WholeStageCodegen (263)"; 740 [id="node_740" labelType="html" label="ZippedPartitionsRDD2 [740] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 741 [id="node_741" labelType="html" label="MapPartitionsRDD [741] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2079 { id="cluster_2079"; isCluster="true"; label="Project"; 742 [id="node_742" labelType="html" label="MapPartitionsRDD [742] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2049 { id="cluster_2049"; isCluster="true"; label="WholeStageCodegen (264)"; 743 [id="node_743" labelType="html" label="MapPartitionsRDD [743] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2048 { id="cluster_2048"; isCluster="true"; label="ObjectHashAggregate"; 744 [id="node_744" labelType="html" label="MapPartitionsRDD [744] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2047 { id="cluster_2047"; isCluster="true"; label="ObjectHashAggregate"; 745 [id="node_745" labelType="html" label="MapPartitionsRDD [745] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2008 { id="cluster_2008"; isCluster="true"; label="WholeStageCodegen (265)"; 746 [id="node_746" labelType="html" label="MapPartitionsRDD [746] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2007 { id="cluster_2007"; isCluster="true"; label="Exchange"; 747 [id="node_747" labelType="html" label="MapPartitionsRDD [747] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 727->738; 670->739; 738->740; 739->740; 740->741; 741->742; 742->743; 743->744; 744->745; 745->746; 746->747; }

624,670

682,727

digraph G { id="graph_447"; subgraph graph_stage_447 { id="graph_stage_447"; isCluster="true"; label="Stage 447 (skipped)"; subgraph cluster_2005 { id="cluster_2005"; isCluster="true"; label="AQEShuffleRead"; 722 [id="node_722" labelType="html" label="ShuffledRowRDD [722] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1994 { id="cluster_1994"; isCluster="true"; label="WholeStageCodegen (259)"; 725 [id="node_725" labelType="html" label="MapPartitionsRDD [725] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1993 { id="cluster_1993"; isCluster="true"; label="Exchange"; 726 [id="node_726" labelType="html" label="MapPartitionsRDD [726] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 722->725; 725->726; }

676,722

digraph G { id="graph_448"; subgraph graph_stage_448 { id="graph_stage_448"; isCluster="true"; label="Stage 448 (skipped)"; subgraph cluster_2104 { id="cluster_2104"; isCluster="true"; label="AQEShuffleRead"; 748 [id="node_748" labelType="html" label="ShuffledRowRDD [748] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2101 { id="cluster_2101"; isCluster="true"; label="WholeStageCodegen (271)"; 749 [id="node_749" labelType="html" label="MapPartitionsRDD [749] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2109 { id="cluster_2109"; isCluster="true"; label="AQEShuffleRead"; 750 [id="node_750" labelType="html" label="ShuffledRowRDD [750] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2106 { id="cluster_2106"; isCluster="true"; label="WholeStageCodegen (272)"; 751 [id="node_751" labelType="html" label="MapPartitionsRDD [751] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2097 { id="cluster_2097"; isCluster="true"; label="WholeStageCodegen (273)"; 752 [id="node_752" labelType="html" label="ZippedPartitionsRDD2 [752] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 753 [id="node_753" labelType="html" label="MapPartitionsRDD [753] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2096 { id="cluster_2096"; isCluster="true"; label="Exchange"; 754 [id="node_754" labelType="html" label="MapPartitionsRDD [754] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 748->749; 750->751; 749->752; 751->752; 752->753; 753->754; }

726,748

747,750

digraph G { id="graph_449"; subgraph graph_stage_449 { id="graph_stage_449"; isCluster="true"; label="Stage 449"; subgraph cluster_2145 { id="cluster_2145"; isCluster="true"; label="AQEShuffleRead"; 770 [id="node_770" labelType="html" label="ShuffledRowRDD [770] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2141 { id="cluster_2141"; isCluster="true"; label="WholeStageCodegen (278)"; 771 [id="node_771" labelType="html" label="MapPartitionsRDD [771] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 770->771; }

754,770

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
449	tenants-pool-506	replenishmentRunId = 10000000004 tenantId = 8793759653749352888 activityType = BufferDataSnapShot activityId = 36e0914c-7e4e-3a52-bc93-e306e07299ba workflowType = KpiPrepareDataSnapshotWorkflow workflowId = b49fb3c6-88b3-3c61-97e8-cbe3f98f9409 attempt = 1 cornerstoneTenantId = 8445 marketUnit = 10000_OP_PERF scenario = STANDARD save at FileStorageAdapterImpl.java:262 +details org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.storeDataSnapshot(FileStorageAdapterImpl.java:262) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.DataSnapshotGenerationDataAccessImpl.storeDataSnapshot(DataSnapshotGenerationDataAccessImpl.java:39) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:62) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapShot(CreateDataSnapshotForShardActivityImpl.java:44) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/04/20 06:17:01	2 s	12/12		259.3 KiB	833.9 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

449

tenants-pool-506

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

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.storeDataSnapshot(FileStorageAdapterImpl.java:262)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.DataSnapshotGenerationDataAccessImpl.storeDataSnapshot(DataSnapshotGenerationDataAccessImpl.java:39)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:62)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapShot(CreateDataSnapshotForShardActivityImpl.java:44)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44)
io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23)
io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88)
io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/04/20 06:17:01

2 s

12/12

259.3 KiB

833.9 KiB

Page:

Skipped Stages (14)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
448	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/18
447	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/9
446	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
445	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
444	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
443	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
442	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
441	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
440	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/2
439	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
438	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
437	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
436	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37
435	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/37

Page: