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

Status: SUCCEEDED
Submitted: 2026/05/22 09:54:45
Duration: 0.5 s
Associated SQL Query: 73101
Job Group: 326fbe20-7556-41a9-9fce-e25b8059f480
Completed Stages: 1
Skipped Stages: 6

Enable zooming

digraph G { id="graph_319399"; subgraph graph_stage_319399 { id="graph_stage_319399"; isCluster="true"; label="Stage 319399 (skipped)"; subgraph cluster_2316103 { id="cluster_2316103"; isCluster="true"; label="Scan parquet "; 893717 [id="node_893717" labelType="html" label="FileScanRDD [893717] start at FileStorageAdapterImpl.java:174}"]; 893718 [id="node_893718" labelType="html" label="MapPartitionsRDD [893718] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316099 { id="cluster_2316099"; isCluster="true"; label="WholeStageCodegen (1)"; 893719 [id="node_893719" labelType="html" label="MapPartitionsRDD [893719] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316098 { id="cluster_2316098"; isCluster="true"; label="Exchange"; 893720 [id="node_893720" labelType="html" label="MapPartitionsRDD [893720] start at FileStorageAdapterImpl.java:174}"]; } } 893717->893718; 893718->893719; 893719->893720; }

digraph G { id="graph_319400"; subgraph graph_stage_319400 { id="graph_stage_319400"; isCluster="true"; label="Stage 319400 (skipped)"; subgraph cluster_2316129 { id="cluster_2316129"; isCluster="true"; label="Scan parquet "; 893728 [id="node_893728" labelType="html" label="FileScanRDD [893728] start at FileStorageAdapterImpl.java:174}"]; 893729 [id="node_893729" labelType="html" label="MapPartitionsRDD [893729] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316125 { id="cluster_2316125"; isCluster="true"; label="WholeStageCodegen (7)"; 893730 [id="node_893730" labelType="html" label="MapPartitionsRDD [893730] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316124 { id="cluster_2316124"; isCluster="true"; label="Exchange"; 893731 [id="node_893731" labelType="html" label="MapPartitionsRDD [893731] start at FileStorageAdapterImpl.java:174}"]; } } 893728->893729; 893729->893730; 893730->893731; }

digraph G { id="graph_319401"; subgraph graph_stage_319401 { id="graph_stage_319401"; isCluster="true"; label="Stage 319401 (skipped)"; subgraph cluster_2316124 { id="cluster_2316124"; isCluster="true"; label="Exchange"; 893732 [id="node_893732" labelType="html" label="ShuffledRowRDD [893732] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316109 { id="cluster_2316109"; isCluster="true"; label="WholeStageCodegen (11)"; 893733 [id="node_893733" labelType="html" label="MapPartitionsRDD [893733] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316108 { id="cluster_2316108"; isCluster="true"; label="Exchange"; 893734 [id="node_893734" labelType="html" label="MapPartitionsRDD [893734] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 893732->893733; 893733->893734; }

893731,893732

digraph G { id="graph_319402"; subgraph graph_stage_319402 { id="graph_stage_319402"; isCluster="true"; label="Stage 319402 (skipped)"; subgraph cluster_2316098 { id="cluster_2316098"; isCluster="true"; label="Exchange"; 893721 [id="node_893721" labelType="html" label="ShuffledRowRDD [893721] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316086 { id="cluster_2316086"; isCluster="true"; label="WholeStageCodegen (5)"; 893722 [id="node_893722" labelType="html" label="MapPartitionsRDD [893722] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316085 { id="cluster_2316085"; isCluster="true"; label="Exchange"; 893723 [id="node_893723" labelType="html" label="MapPartitionsRDD [893723] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 893721->893722; 893722->893723; }

893720,893721

digraph G { id="graph_319403"; subgraph graph_stage_319403 { id="graph_stage_319403"; isCluster="true"; label="Stage 319403 (skipped)"; subgraph cluster_2316085 { id="cluster_2316085"; isCluster="true"; label="Exchange"; 893724 [id="node_893724" labelType="html" label="ShuffledRowRDD [893724] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316082 { id="cluster_2316082"; isCluster="true"; label="WholeStageCodegen (6)"; 893725 [id="node_893725" labelType="html" label="MapPartitionsRDD [893725] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316108 { id="cluster_2316108"; isCluster="true"; label="Exchange"; 893735 [id="node_893735" labelType="html" label="ShuffledRowRDD [893735] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316105 { id="cluster_2316105"; isCluster="true"; label="WholeStageCodegen (12)"; 893736 [id="node_893736" labelType="html" label="MapPartitionsRDD [893736] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316078 { id="cluster_2316078"; isCluster="true"; label="WholeStageCodegen (13)"; 893737 [id="node_893737" labelType="html" label="ZippedPartitionsRDD2 [893737] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 893738 [id="node_893738" labelType="html" label="MapPartitionsRDD [893738] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316077 { id="cluster_2316077"; isCluster="true"; label="ObjectHashAggregate"; 893739 [id="node_893739" labelType="html" label="MapPartitionsRDD [893739] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316076 { id="cluster_2316076"; isCluster="true"; label="Exchange"; 893740 [id="node_893740" labelType="html" label="MapPartitionsRDD [893740] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 893724->893725; 893735->893736; 893725->893737; 893736->893737; 893737->893738; 893738->893739; 893739->893740; }

893723,893724

893734,893735

digraph G { id="graph_319404"; subgraph graph_stage_319404 { id="graph_stage_319404"; isCluster="true"; label="Stage 319404 (skipped)"; 893749 [id="node_893749" labelType="html" label="SQLExecutionRDD [893749] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_2316076 { id="cluster_2316076"; isCluster="true"; label="Exchange"; 893741 [id="node_893741" labelType="html" label="ShuffledRowRDD [893741] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316075 { id="cluster_2316075"; isCluster="true"; label="ObjectHashAggregate"; 893742 [id="node_893742" labelType="html" label="MapPartitionsRDD [893742] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316074 { id="cluster_2316074"; isCluster="true"; label="Project"; 893743 [id="node_893743" labelType="html" label="MapPartitionsRDD [893743] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316067 { id="cluster_2316067"; isCluster="true"; label="WholeStageCodegen (16)"; 893744 [id="node_893744" labelType="html" label="MapPartitionsRDD [893744] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316066 { id="cluster_2316066"; isCluster="true"; label="DeserializeToObject"; 893745 [id="node_893745" labelType="html" label="MapPartitionsRDD [893745] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316065 { id="cluster_2316065"; isCluster="true"; label="MapPartitions"; 893746 [id="node_893746" labelType="html" label="MapPartitionsRDD [893746] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315984 { id="cluster_2315984"; isCluster="true"; label="WholeStageCodegen (19)"; 893747 [id="node_893747" labelType="html" label="MapPartitionsRDD [893747] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2315960 { id="cluster_2315960"; isCluster="true"; label="DeserializeToObject"; 893748 [id="node_893748" labelType="html" label="MapPartitionsRDD [893748] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316137 { id="cluster_2316137"; isCluster="true"; label="mapPartitions"; 893750 [id="node_893750" labelType="html" label="MapPartitionsRDD [893750] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316138 { id="cluster_2316138"; isCluster="true"; label="mapPartitions"; 893751 [id="node_893751" labelType="html" label="MapPartitionsRDD [893751] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316206 { id="cluster_2316206"; isCluster="true"; label="Scan"; 893757 [id="node_893757" labelType="html" label="MapPartitionsRDD [893757] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316200 { id="cluster_2316200"; isCluster="true"; label="WholeStageCodegen (1)"; 893758 [id="node_893758" labelType="html" label="MapPartitionsRDD [893758] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316199 { id="cluster_2316199"; isCluster="true"; label="InMemoryTableScan"; 893759 [id="node_893759" labelType="html" label="MapPartitionsRDD [893759] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 893760 [id="node_893760" labelType="html" label="*(1) Generate explode(prodPlantResults#15616226), false, [prodPlantResults#15616233]\n+- *(1) Project [prodPlantResults#15616226]\n +- *(1) Filter ((size(prodPlantResults#15616226, true) > 0) AND isnotnull(prodPlantResults#15616226))\n +- *(1) SerializeFromObject [mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement)))) null else named_struct(measuredUnit, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,S... [893760] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 893761 [id="node_893761" labelType="html" label="MapPartitionsRDD [893761] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 893762 [id="node_893762" labelType="html" label="MapPartitionsRDD [893762] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 893763 [id="node_893763" labelType="html" label="MapPartitionsRDD [893763] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316198 { id="cluster_2316198"; isCluster="true"; label="Project"; 893764 [id="node_893764" labelType="html" label="MapPartitionsRDD [893764] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316213 { id="cluster_2316213"; isCluster="true"; label="InMemoryTableScan"; 893765 [id="node_893765" labelType="html" label="MapPartitionsRDD [893765] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 893766 [id="node_893766" labelType="html" label="MapPartitionsRDD [893766] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 893767 [id="node_893767" labelType="html" label="MapPartitionsRDD [893767] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316208 { id="cluster_2316208"; isCluster="true"; label="WholeStageCodegen (1)"; 893768 [id="node_893768" labelType="html" label="MapPartitionsRDD [893768] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316207 { id="cluster_2316207"; isCluster="true"; label="Project"; 893769 [id="node_893769" labelType="html" label="MapPartitionsRDD [893769] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316220 { id="cluster_2316220"; isCluster="true"; label="InMemoryTableScan"; 893770 [id="node_893770" labelType="html" label="MapPartitionsRDD [893770] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 893771 [id="node_893771" labelType="html" label="MapPartitionsRDD [893771] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 893772 [id="node_893772" labelType="html" label="MapPartitionsRDD [893772] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316215 { id="cluster_2316215"; isCluster="true"; label="WholeStageCodegen (2)"; 893773 [id="node_893773" labelType="html" label="MapPartitionsRDD [893773] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316214 { id="cluster_2316214"; isCluster="true"; label="Project"; 893774 [id="node_893774" labelType="html" label="MapPartitionsRDD [893774] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316197 { id="cluster_2316197"; isCluster="true"; label="Union"; 893775 [id="node_893775" labelType="html" label="UnionRDD [893775] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316182 { id="cluster_2316182"; isCluster="true"; label="WholeStageCodegen (4)"; 893776 [id="node_893776" labelType="html" label="MapPartitionsRDD [893776] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316181 { id="cluster_2316181"; isCluster="true"; label="SortAggregate"; 893777 [id="node_893777" labelType="html" label="MapPartitionsRDD [893777] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316180 { id="cluster_2316180"; isCluster="true"; label="Exchange"; 893778 [id="node_893778" labelType="html" label="MapPartitionsRDD [893778] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 893741->893742; 893742->893743; 893743->893744; 893744->893745; 893745->893746; 893746->893747; 893747->893748; 893748->893749; 893749->893750; 893750->893751; 893751->893757; 893757->893758; 893758->893759; 893759->893760; 893760->893761; 893761->893762; 893762->893763; 893763->893764; 893760->893765; 893765->893766; 893766->893767; 893767->893768; 893768->893769; 893760->893770; 893770->893771; 893771->893772; 893772->893773; 893773->893774; 893764->893775; 893769->893775; 893774->893775; 893775->893776; 893776->893777; 893777->893778; }

893740,893741

893751

893760

digraph G { id="graph_319405"; subgraph graph_stage_319405 { id="graph_stage_319405"; isCluster="true"; label="Stage 319405"; subgraph cluster_2316180 { id="cluster_2316180"; isCluster="true"; label="Exchange"; 893779 [id="node_893779" labelType="html" label="ShuffledRowRDD [893779] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316175 { id="cluster_2316175"; isCluster="true"; label="WholeStageCodegen (5)"; 893780 [id="node_893780" labelType="html" label="MapPartitionsRDD [893780] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316174 { id="cluster_2316174"; isCluster="true"; label="SortAggregate"; 893781 [id="node_893781" labelType="html" label="MapPartitionsRDD [893781] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316173 { id="cluster_2316173"; isCluster="true"; label="InMemoryTableScan"; 893782 [id="node_893782" labelType="html" label="MapPartitionsRDD [893782] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 893783 [id="node_893783" labelType="html" label="SortAggregate(key=[demandChannel#15616259, shardId#15458341, qty#15616279, worklistShardItemId#15458342L, demandStream#15616260], functions=[first(kpis#15616288, false)], output=[shardId#15458341, worklistShardItemId#15458342L, qty#15616279, demandChannel#15616259, demandStream#15616260, kpis#15616401])\n+- *(5) Sort [demandChannel#15616259 ASC NULLS FIRST, shardId#15458341 ASC NULLS FIRST, qty#15616279 ASC NULLS FIRST, worklistShardItemId#15458342L ASC NULLS FIRST, demandStream#15616260 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#15616259, shardId#15458341, qty#15616279, worklistShardItemId#15458342L, demandStream#15616260, 30), ENSURE_REQUIREMENTS, [plan_id=21821947]\n +- SortAggregate(key=[demandChannel#15616259, shardId#15458341, knownfloatingpointnormalized(normalizenanandzero(qty#15616279)) AS qty#15616279, worklistShardItemId#15458342L, demandStream#15616260], functions=[partial_first(kpis#15616288, false)], output=[demandChannel#15616259, shardId#15458341, qty#156162... [893783] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316285 { id="cluster_2316285"; isCluster="true"; label="InMemoryTableScan"; 893798 [id="node_893798" labelType="html" label="MapPartitionsRDD [893798] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 893799 [id="node_893799" labelType="html" label="MapPartitionsRDD [893799] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 893800 [id="node_893800" labelType="html" label="MapPartitionsRDD [893800] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316260 { id="cluster_2316260"; isCluster="true"; label="WholeStageCodegen (3)"; 893801 [id="node_893801" labelType="html" label="MapPartitionsRDD [893801] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316259 { id="cluster_2316259"; isCluster="true"; label="InMemoryTableScan"; 893802 [id="node_893802" labelType="html" label="MapPartitionsRDD [893802] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 893803 [id="node_893803" labelType="html" label="*(3) Project [shardId#15458341, worklistShardItemId#15458342L, version#15616750, qty#15616279, demandChannel#15616259, demandStream#15616260, kpis#15616288]\n+- *(3) BroadcastHashJoin [shardId#15458341, worklistShardItemId#15458342L], [shardId#15616755, worklistShardItemId#15616756L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#15458341) AND isnotnull(worklistShardItemId#15458342L))\n : +- InMemoryTableScan [shardId#15458341, worklistShardItemId#15458342L, qty#15616279, demandChannel#15616259, demandStream#15616260, kpis#15616288], [isnotnull(shardId#15458341), isnotnull(worklistShardItemId#15458342L)]\n : +- InMemoryRelation [shardId#15458341, worklistShardItemId#15458342L, qty#15616279, demandChannel#15616259, demandStream#15616260, kpis#15616288], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#15616259, shardId#15458341, qty#15616279, worklistShardItemId#15458342L, demandStream#15616260], functions=[first(kpis#15616288, false)], ou... [893803] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2316303 { id="cluster_2316303"; isCluster="true"; label="InMemoryTableScan"; 893812 [id="node_893812" labelType="html" label="MapPartitionsRDD [893812] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 893813 [id="node_893813" labelType="html" label="MapPartitionsRDD [893813] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 893814 [id="node_893814" labelType="html" label="MapPartitionsRDD [893814] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 893779->893780; 893780->893781; 893781->893782; 893782->893783; 893783->893798; 893798->893799; 893799->893800; 893800->893801; 893801->893802; 893802->893803; 893803->893812; 893812->893813; 893813->893814; }

893778,893779

893783

893803

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
319405	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 39 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.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/05/22 09:54:45	0.4 s	30/30	1159.0 B	4.3 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

319405

tenants-pool-169

stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 39 start at FileStorageAdapterImpl.java:174 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
jdk.internal.reflect.GeneratedMethodAccessor724.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/05/22 09:54:45

0.4 s

30/30

1159.0 B

4.3 KiB

Page:

Skipped Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
319404	default	start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.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/90
319403	default	start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.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/30
319402	default	start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.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/30
319401	default	start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.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/30
319400	default	start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.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
319399	default	start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.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

Page: