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

Status: SUCCEEDED
Submitted: 2026/07/22 18:08:08
Duration: 0.4 s
Associated SQL Query: 16152
Job Group: 185bab19-86a5-4b48-bb51-7bd63638d291
Completed Stages: 2
Skipped Stages: 6

Enable zooming

digraph G { id="graph_69547"; subgraph graph_stage_69547 { id="graph_stage_69547"; isCluster="true"; label="Stage 69547 (skipped)"; subgraph cluster_516313 { id="cluster_516313"; isCluster="true"; label="Scan parquet "; 195988 [id="node_195988" labelType="html" label="FileScanRDD [195988] start at FileStorageAdapterImpl.java:179}"]; 195989 [id="node_195989" labelType="html" label="MapPartitionsRDD [195989] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516309 { id="cluster_516309"; isCluster="true"; label="WholeStageCodegen (7)"; 195990 [id="node_195990" labelType="html" label="MapPartitionsRDD [195990] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516308 { id="cluster_516308"; isCluster="true"; label="Exchange"; 195991 [id="node_195991" labelType="html" label="MapPartitionsRDD [195991] start at FileStorageAdapterImpl.java:179}"]; } } 195988->195989; 195989->195990; 195990->195991; }

digraph G { id="graph_69548"; subgraph graph_stage_69548 { id="graph_stage_69548"; isCluster="true"; label="Stage 69548 (skipped)"; subgraph cluster_516287 { id="cluster_516287"; isCluster="true"; label="Scan parquet "; 195977 [id="node_195977" labelType="html" label="FileScanRDD [195977] start at FileStorageAdapterImpl.java:179}"]; 195978 [id="node_195978" labelType="html" label="MapPartitionsRDD [195978] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516283 { id="cluster_516283"; isCluster="true"; label="WholeStageCodegen (1)"; 195979 [id="node_195979" labelType="html" label="MapPartitionsRDD [195979] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516282 { id="cluster_516282"; isCluster="true"; label="Exchange"; 195980 [id="node_195980" labelType="html" label="MapPartitionsRDD [195980] start at FileStorageAdapterImpl.java:179}"]; } } 195977->195978; 195978->195979; 195979->195980; }

digraph G { id="graph_69549"; subgraph graph_stage_69549 { id="graph_stage_69549"; isCluster="true"; label="Stage 69549 (skipped)"; subgraph cluster_516282 { id="cluster_516282"; isCluster="true"; label="Exchange"; 195981 [id="node_195981" labelType="html" label="ShuffledRowRDD [195981] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516254 { id="cluster_516254"; isCluster="true"; label="WholeStageCodegen (5)"; 195982 [id="node_195982" labelType="html" label="MapPartitionsRDD [195982] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516253 { id="cluster_516253"; isCluster="true"; label="Exchange"; 195983 [id="node_195983" labelType="html" label="MapPartitionsRDD [195983] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 195981->195982; 195982->195983; }

195980,195981

digraph G { id="graph_69550"; subgraph graph_stage_69550 { id="graph_stage_69550"; isCluster="true"; label="Stage 69550 (skipped)"; subgraph cluster_516308 { id="cluster_516308"; isCluster="true"; label="Exchange"; 195992 [id="node_195992" labelType="html" label="ShuffledRowRDD [195992] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516293 { id="cluster_516293"; isCluster="true"; label="WholeStageCodegen (11)"; 195993 [id="node_195993" labelType="html" label="MapPartitionsRDD [195993] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516292 { id="cluster_516292"; isCluster="true"; label="Exchange"; 195994 [id="node_195994" labelType="html" label="MapPartitionsRDD [195994] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 195992->195993; 195993->195994; }

195991,195992

digraph G { id="graph_69551"; subgraph graph_stage_69551 { id="graph_stage_69551"; isCluster="true"; label="Stage 69551 (skipped)"; subgraph cluster_516253 { id="cluster_516253"; isCluster="true"; label="Exchange"; 195984 [id="node_195984" labelType="html" label="ShuffledRowRDD [195984] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516250 { id="cluster_516250"; isCluster="true"; label="WholeStageCodegen (6)"; 195985 [id="node_195985" labelType="html" label="MapPartitionsRDD [195985] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516292 { id="cluster_516292"; isCluster="true"; label="Exchange"; 195995 [id="node_195995" labelType="html" label="ShuffledRowRDD [195995] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516289 { id="cluster_516289"; isCluster="true"; label="WholeStageCodegen (12)"; 195996 [id="node_195996" labelType="html" label="MapPartitionsRDD [195996] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516246 { id="cluster_516246"; isCluster="true"; label="WholeStageCodegen (13)"; 195997 [id="node_195997" labelType="html" label="ZippedPartitionsRDD2 [195997] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 195998 [id="node_195998" labelType="html" label="MapPartitionsRDD [195998] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516245 { id="cluster_516245"; isCluster="true"; label="ObjectHashAggregate"; 195999 [id="node_195999" labelType="html" label="MapPartitionsRDD [195999] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516244 { id="cluster_516244"; isCluster="true"; label="Exchange"; 196000 [id="node_196000" labelType="html" label="MapPartitionsRDD [196000] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 195984->195985; 195995->195996; 195985->195997; 195996->195997; 195997->195998; 195998->195999; 195999->196000; }

195983,195984

195994,195995

digraph G { id="graph_69552"; subgraph graph_stage_69552 { id="graph_stage_69552"; isCluster="true"; label="Stage 69552 (skipped)"; 196009 [id="node_196009" labelType="html" label="SQLExecutionRDD [196009] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_516244 { id="cluster_516244"; isCluster="true"; label="Exchange"; 196001 [id="node_196001" labelType="html" label="ShuffledRowRDD [196001] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516243 { id="cluster_516243"; isCluster="true"; label="ObjectHashAggregate"; 196002 [id="node_196002" labelType="html" label="MapPartitionsRDD [196002] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516242 { id="cluster_516242"; isCluster="true"; label="Project"; 196003 [id="node_196003" labelType="html" label="MapPartitionsRDD [196003] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516235 { id="cluster_516235"; isCluster="true"; label="WholeStageCodegen (16)"; 196004 [id="node_196004" labelType="html" label="MapPartitionsRDD [196004] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516234 { id="cluster_516234"; isCluster="true"; label="DeserializeToObject"; 196005 [id="node_196005" labelType="html" label="MapPartitionsRDD [196005] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516233 { id="cluster_516233"; isCluster="true"; label="MapPartitions"; 196006 [id="node_196006" labelType="html" label="MapPartitionsRDD [196006] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516165 { id="cluster_516165"; isCluster="true"; label="WholeStageCodegen (19)"; 196007 [id="node_196007" labelType="html" label="MapPartitionsRDD [196007] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516144 { id="cluster_516144"; isCluster="true"; label="DeserializeToObject"; 196008 [id="node_196008" labelType="html" label="MapPartitionsRDD [196008] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516321 { id="cluster_516321"; isCluster="true"; label="mapPartitions"; 196010 [id="node_196010" labelType="html" label="MapPartitionsRDD [196010] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516322 { id="cluster_516322"; isCluster="true"; label="mapPartitions"; 196011 [id="node_196011" labelType="html" label="MapPartitionsRDD [196011] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516390 { id="cluster_516390"; isCluster="true"; label="Scan"; 196017 [id="node_196017" labelType="html" label="MapPartitionsRDD [196017] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516384 { id="cluster_516384"; isCluster="true"; label="WholeStageCodegen (1)"; 196018 [id="node_196018" labelType="html" label="MapPartitionsRDD [196018] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516383 { id="cluster_516383"; isCluster="true"; label="InMemoryTableScan"; 196019 [id="node_196019" labelType="html" label="MapPartitionsRDD [196019] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 196020 [id="node_196020" labelType="html" label="*(1) Generate explode(prodPlantResults#3470018), false, [prodPlantResults#3470025]\n+- *(1) Project [prodPlantResults#3470018]\n +- *(1) Filter ((size(prodPlantResults#3470018, true) > 0) AND isnotnull(prodPlantResults#3470018))\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,String... [196020] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 196021 [id="node_196021" labelType="html" label="MapPartitionsRDD [196021] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 196022 [id="node_196022" labelType="html" label="MapPartitionsRDD [196022] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 196023 [id="node_196023" labelType="html" label="MapPartitionsRDD [196023] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516382 { id="cluster_516382"; isCluster="true"; label="Project"; 196024 [id="node_196024" labelType="html" label="MapPartitionsRDD [196024] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516397 { id="cluster_516397"; isCluster="true"; label="InMemoryTableScan"; 196025 [id="node_196025" labelType="html" label="MapPartitionsRDD [196025] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 196026 [id="node_196026" labelType="html" label="MapPartitionsRDD [196026] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 196027 [id="node_196027" labelType="html" label="MapPartitionsRDD [196027] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516392 { id="cluster_516392"; isCluster="true"; label="WholeStageCodegen (1)"; 196028 [id="node_196028" labelType="html" label="MapPartitionsRDD [196028] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516391 { id="cluster_516391"; isCluster="true"; label="Project"; 196029 [id="node_196029" labelType="html" label="MapPartitionsRDD [196029] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516404 { id="cluster_516404"; isCluster="true"; label="InMemoryTableScan"; 196030 [id="node_196030" labelType="html" label="MapPartitionsRDD [196030] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 196031 [id="node_196031" labelType="html" label="MapPartitionsRDD [196031] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 196032 [id="node_196032" labelType="html" label="MapPartitionsRDD [196032] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516399 { id="cluster_516399"; isCluster="true"; label="WholeStageCodegen (2)"; 196033 [id="node_196033" labelType="html" label="MapPartitionsRDD [196033] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516398 { id="cluster_516398"; isCluster="true"; label="Project"; 196034 [id="node_196034" labelType="html" label="MapPartitionsRDD [196034] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516381 { id="cluster_516381"; isCluster="true"; label="Union"; 196035 [id="node_196035" labelType="html" label="UnionRDD [196035] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516367 { id="cluster_516367"; isCluster="true"; label="WholeStageCodegen (4)"; 196036 [id="node_196036" labelType="html" label="MapPartitionsRDD [196036] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516366 { id="cluster_516366"; isCluster="true"; label="SortAggregate"; 196037 [id="node_196037" labelType="html" label="MapPartitionsRDD [196037] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516365 { id="cluster_516365"; isCluster="true"; label="Exchange"; 196038 [id="node_196038" labelType="html" label="MapPartitionsRDD [196038] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 196001->196002; 196002->196003; 196003->196004; 196004->196005; 196005->196006; 196006->196007; 196007->196008; 196008->196009; 196009->196010; 196010->196011; 196011->196017; 196017->196018; 196018->196019; 196019->196020; 196020->196021; 196021->196022; 196022->196023; 196023->196024; 196020->196025; 196025->196026; 196026->196027; 196027->196028; 196028->196029; 196020->196030; 196030->196031; 196031->196032; 196032->196033; 196033->196034; 196024->196035; 196029->196035; 196034->196035; 196035->196036; 196036->196037; 196037->196038; }

196000,196001

196011

196020

digraph G { id="graph_69553"; subgraph graph_stage_69553 { id="graph_stage_69553"; isCluster="true"; label="Stage 69553"; subgraph cluster_516365 { id="cluster_516365"; isCluster="true"; label="Exchange"; 196039 [id="node_196039" labelType="html" label="ShuffledRowRDD [196039] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516359 { id="cluster_516359"; isCluster="true"; label="WholeStageCodegen (5)"; 196040 [id="node_196040" labelType="html" label="MapPartitionsRDD [196040] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516358 { id="cluster_516358"; isCluster="true"; label="SortAggregate"; 196041 [id="node_196041" labelType="html" label="MapPartitionsRDD [196041] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516357 { id="cluster_516357"; isCluster="true"; label="InMemoryTableScan"; 196042 [id="node_196042" labelType="html" label="MapPartitionsRDD [196042] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 196043 [id="node_196043" labelType="html" label="SortAggregate(key=[demandChannel#3470051, shardId#3371037, qty#3470071, worklistShardItemId#3371038L, demandStream#3470052], functions=[first(kpis#3470080, false)], output=[shardId#3371037, worklistShardItemId#3371038L, qty#3470071, demandChannel#3470051, demandStream#3470052, kpis#3470193])\n+- *(5) Sort [demandChannel#3470051 ASC NULLS FIRST, shardId#3371037 ASC NULLS FIRST, qty#3470071 ASC NULLS FIRST, worklistShardItemId#3371038L ASC NULLS FIRST, demandStream#3470052 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#3470051, shardId#3371037, qty#3470071, worklistShardItemId#3371038L, demandStream#3470052, 30), ENSURE_REQUIREMENTS, [plan_id=5500325]\n +- SortAggregate(key=[demandChannel#3470051, shardId#3371037, knownfloatingpointnormalized(normalizenanandzero(qty#3470071)) AS qty#3470071, worklistShardItemId#3371038L, demandStream#3470052], functions=[partial_first(kpis#3470080, false)], output=[demandChannel#3470051, shardId#3371037, qty#3470071, worklistShardItemId#3371038L,... [196043] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516469 { id="cluster_516469"; isCluster="true"; label="InMemoryTableScan"; 196058 [id="node_196058" labelType="html" label="MapPartitionsRDD [196058] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 196059 [id="node_196059" labelType="html" label="MapPartitionsRDD [196059] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 196060 [id="node_196060" labelType="html" label="MapPartitionsRDD [196060] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516444 { id="cluster_516444"; isCluster="true"; label="WholeStageCodegen (3)"; 196061 [id="node_196061" labelType="html" label="MapPartitionsRDD [196061] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516443 { id="cluster_516443"; isCluster="true"; label="InMemoryTableScan"; 196062 [id="node_196062" labelType="html" label="MapPartitionsRDD [196062] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 196063 [id="node_196063" labelType="html" label="*(3) Project [shardId#3371037, worklistShardItemId#3371038L, version#3470542, qty#3470071, demandChannel#3470051, demandStream#3470052, kpis#3470080]\n+- *(3) BroadcastHashJoin [shardId#3371037, worklistShardItemId#3371038L], [shardId#3470547, worklistShardItemId#3470548L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#3371037) AND isnotnull(worklistShardItemId#3371038L))\n : +- InMemoryTableScan [shardId#3371037, worklistShardItemId#3371038L, qty#3470071, demandChannel#3470051, demandStream#3470052, kpis#3470080], [isnotnull(shardId#3371037), isnotnull(worklistShardItemId#3371038L)]\n : +- InMemoryRelation [shardId#3371037, worklistShardItemId#3371038L, qty#3470071, demandChannel#3470051, demandStream#3470052, kpis#3470080], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#3470051, shardId#3371037, qty#3470071, worklistShardItemId#3371038L, demandStream#3470052], functions=[first(kpis#3470080, false)], output=[shardId#3371037, worklistSh... [196063] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 196064 [id="node_196064" labelType="html" label="MapPartitionsRDD [196064] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 196065 [id="node_196065" labelType="html" label="MapPartitionsRDD [196065] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 196066 [id="node_196066" labelType="html" label="MapPartitionsRDD [196066] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516442 { id="cluster_516442"; isCluster="true"; label="CollectLimit"; 196067 [id="node_196067" labelType="html" label="MapPartitionsRDD [196067] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 196068 [id="node_196068" labelType="html" label="MapPartitionsRDD [196068] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 196039->196040; 196040->196041; 196041->196042; 196042->196043; 196043->196058; 196058->196059; 196059->196060; 196060->196061; 196061->196062; 196062->196063; 196063->196064; 196064->196065; 196065->196066; 196066->196067; 196067->196068; }

196038,196039

196043

196063

digraph G { id="graph_69554"; subgraph graph_stage_69554 { id="graph_stage_69554"; isCluster="true"; label="Stage 69554"; subgraph cluster_516442 { id="cluster_516442"; isCluster="true"; label="CollectLimit"; 196069 [id="node_196069" labelType="html" label="ShuffledRowRDD [196069] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 196070 [id="node_196070" labelType="html" label="MapPartitionsRDD [196070] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516470 { id="cluster_516470"; isCluster="true"; label="mapPartitionsInternal"; 196071 [id="node_196071" labelType="html" label="MapPartitionsRDD [196071] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 196069->196070; 196070->196071; }

196068,196069

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
69554	tenants-pool-562	stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 batch = 10 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor810.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/07/22 18:08:09	6 ms	1/1
69553	tenants-pool-562	stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 batch = 10 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor810.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/07/22 18:08:08	0.4 s	30/30	12.4 KiB			1364.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

69554

tenants-pool-562

stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 batch = 10 start at FileStorageAdapterImpl.java:179 +details

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

6 ms

1/1

69553

tenants-pool-562

stream-10000001136-1 id = 29b65be0-0045-4db1-8a33-ae5d539a12c4 runId = 185bab19-86a5-4b48-bb51-7bd63638d291 batch = 10 start at FileStorageAdapterImpl.java:179 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
jdk.internal.reflect.GeneratedMethodAccessor810.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/07/22 18:08:08

0.4 s

30/30

12.4 KiB

1364.0 B

Page:

Skipped Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
69552	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor810.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
69551	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor810.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
69550	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor810.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
69549	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor810.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
69548	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor810.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/37
69547	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor810.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/37

Page: