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

Status: SUCCEEDED
Submitted: 2026/07/21 18:07:48
Duration: 0.2 s
Associated SQL Query: 6524
Job Group: d96bf115-f542-4550-b53f-c6857f91a685
Completed Stages: 2
Skipped Stages: 6

Enable zooming

digraph G { id="graph_27796"; subgraph graph_stage_27796 { id="graph_stage_27796"; isCluster="true"; label="Stage 27796 (skipped)"; subgraph cluster_205737 { id="cluster_205737"; isCluster="true"; label="Scan parquet "; 78034 [id="node_78034" labelType="html" label="FileScanRDD [78034] start at FileStorageAdapterImpl.java:179}"]; 78035 [id="node_78035" labelType="html" label="MapPartitionsRDD [78035] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205733 { id="cluster_205733"; isCluster="true"; label="WholeStageCodegen (1)"; 78036 [id="node_78036" labelType="html" label="MapPartitionsRDD [78036] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205732 { id="cluster_205732"; isCluster="true"; label="Exchange"; 78037 [id="node_78037" labelType="html" label="MapPartitionsRDD [78037] start at FileStorageAdapterImpl.java:179}"]; } } 78034->78035; 78035->78036; 78036->78037; }

digraph G { id="graph_27797"; subgraph graph_stage_27797 { id="graph_stage_27797"; isCluster="true"; label="Stage 27797 (skipped)"; subgraph cluster_205770 { id="cluster_205770"; isCluster="true"; label="Scan parquet "; 78045 [id="node_78045" labelType="html" label="FileScanRDD [78045] start at FileStorageAdapterImpl.java:179}"]; 78046 [id="node_78046" labelType="html" label="MapPartitionsRDD [78046] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205766 { id="cluster_205766"; isCluster="true"; label="WholeStageCodegen (7)"; 78047 [id="node_78047" labelType="html" label="MapPartitionsRDD [78047] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205765 { id="cluster_205765"; isCluster="true"; label="Exchange"; 78048 [id="node_78048" labelType="html" label="MapPartitionsRDD [78048] start at FileStorageAdapterImpl.java:179}"]; } } 78045->78046; 78046->78047; 78047->78048; }

digraph G { id="graph_27798"; subgraph graph_stage_27798 { id="graph_stage_27798"; isCluster="true"; label="Stage 27798 (skipped)"; subgraph cluster_205765 { id="cluster_205765"; isCluster="true"; label="Exchange"; 78049 [id="node_78049" labelType="html" label="ShuffledRowRDD [78049] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205743 { id="cluster_205743"; isCluster="true"; label="WholeStageCodegen (11)"; 78050 [id="node_78050" labelType="html" label="MapPartitionsRDD [78050] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205742 { id="cluster_205742"; isCluster="true"; label="Exchange"; 78051 [id="node_78051" labelType="html" label="MapPartitionsRDD [78051] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 78049->78050; 78050->78051; }

78048,78049

digraph G { id="graph_27799"; subgraph graph_stage_27799 { id="graph_stage_27799"; isCluster="true"; label="Stage 27799 (skipped)"; subgraph cluster_205732 { id="cluster_205732"; isCluster="true"; label="Exchange"; 78038 [id="node_78038" labelType="html" label="ShuffledRowRDD [78038] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205711 { id="cluster_205711"; isCluster="true"; label="WholeStageCodegen (5)"; 78039 [id="node_78039" labelType="html" label="MapPartitionsRDD [78039] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205710 { id="cluster_205710"; isCluster="true"; label="Exchange"; 78040 [id="node_78040" labelType="html" label="MapPartitionsRDD [78040] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 78038->78039; 78039->78040; }

78037,78038

digraph G { id="graph_27800"; subgraph graph_stage_27800 { id="graph_stage_27800"; isCluster="true"; label="Stage 27800 (skipped)"; subgraph cluster_205710 { id="cluster_205710"; isCluster="true"; label="Exchange"; 78041 [id="node_78041" labelType="html" label="ShuffledRowRDD [78041] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205707 { id="cluster_205707"; isCluster="true"; label="WholeStageCodegen (6)"; 78042 [id="node_78042" labelType="html" label="MapPartitionsRDD [78042] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205742 { id="cluster_205742"; isCluster="true"; label="Exchange"; 78052 [id="node_78052" labelType="html" label="ShuffledRowRDD [78052] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205739 { id="cluster_205739"; isCluster="true"; label="WholeStageCodegen (12)"; 78053 [id="node_78053" labelType="html" label="MapPartitionsRDD [78053] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205703 { id="cluster_205703"; isCluster="true"; label="WholeStageCodegen (13)"; 78054 [id="node_78054" labelType="html" label="ZippedPartitionsRDD2 [78054] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78055 [id="node_78055" labelType="html" label="MapPartitionsRDD [78055] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205702 { id="cluster_205702"; isCluster="true"; label="ObjectHashAggregate"; 78056 [id="node_78056" labelType="html" label="MapPartitionsRDD [78056] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205701 { id="cluster_205701"; isCluster="true"; label="Exchange"; 78057 [id="node_78057" labelType="html" label="MapPartitionsRDD [78057] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 78041->78042; 78052->78053; 78042->78054; 78053->78054; 78054->78055; 78055->78056; 78056->78057; }

78040,78041

78051,78052

digraph G { id="graph_27801"; subgraph graph_stage_27801 { id="graph_stage_27801"; isCluster="true"; label="Stage 27801 (skipped)"; 78066 [id="node_78066" labelType="html" label="SQLExecutionRDD [78066] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_205701 { id="cluster_205701"; isCluster="true"; label="Exchange"; 78058 [id="node_78058" labelType="html" label="ShuffledRowRDD [78058] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205700 { id="cluster_205700"; isCluster="true"; label="ObjectHashAggregate"; 78059 [id="node_78059" labelType="html" label="MapPartitionsRDD [78059] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205699 { id="cluster_205699"; isCluster="true"; label="Project"; 78060 [id="node_78060" labelType="html" label="MapPartitionsRDD [78060] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205692 { id="cluster_205692"; isCluster="true"; label="WholeStageCodegen (16)"; 78061 [id="node_78061" labelType="html" label="MapPartitionsRDD [78061] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205691 { id="cluster_205691"; isCluster="true"; label="DeserializeToObject"; 78062 [id="node_78062" labelType="html" label="MapPartitionsRDD [78062] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205690 { id="cluster_205690"; isCluster="true"; label="MapPartitions"; 78063 [id="node_78063" labelType="html" label="MapPartitionsRDD [78063] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205623 { id="cluster_205623"; isCluster="true"; label="WholeStageCodegen (19)"; 78064 [id="node_78064" labelType="html" label="MapPartitionsRDD [78064] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205601 { id="cluster_205601"; isCluster="true"; label="DeserializeToObject"; 78065 [id="node_78065" labelType="html" label="MapPartitionsRDD [78065] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205778 { id="cluster_205778"; isCluster="true"; label="mapPartitions"; 78067 [id="node_78067" labelType="html" label="MapPartitionsRDD [78067] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205779 { id="cluster_205779"; isCluster="true"; label="mapPartitions"; 78068 [id="node_78068" labelType="html" label="MapPartitionsRDD [78068] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205847 { id="cluster_205847"; isCluster="true"; label="Scan"; 78074 [id="node_78074" labelType="html" label="MapPartitionsRDD [78074] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205841 { id="cluster_205841"; isCluster="true"; label="WholeStageCodegen (1)"; 78075 [id="node_78075" labelType="html" label="MapPartitionsRDD [78075] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205840 { id="cluster_205840"; isCluster="true"; label="InMemoryTableScan"; 78076 [id="node_78076" labelType="html" label="MapPartitionsRDD [78076] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78077 [id="node_78077" labelType="html" label="*(1) Generate explode(prodPlantResults#1363543), false, [prodPlantResults#1363550]\n+- *(1) Project [prodPlantResults#1363543]\n +- *(1) Filter ((size(prodPlantResults#1363543, true) > 0) AND isnotnull(prodPlantResults#1363543))\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... [78077] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78078 [id="node_78078" labelType="html" label="MapPartitionsRDD [78078] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78079 [id="node_78079" labelType="html" label="MapPartitionsRDD [78079] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78080 [id="node_78080" labelType="html" label="MapPartitionsRDD [78080] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205839 { id="cluster_205839"; isCluster="true"; label="Project"; 78081 [id="node_78081" labelType="html" label="MapPartitionsRDD [78081] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205854 { id="cluster_205854"; isCluster="true"; label="InMemoryTableScan"; 78082 [id="node_78082" labelType="html" label="MapPartitionsRDD [78082] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78083 [id="node_78083" labelType="html" label="MapPartitionsRDD [78083] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78084 [id="node_78084" labelType="html" label="MapPartitionsRDD [78084] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205849 { id="cluster_205849"; isCluster="true"; label="WholeStageCodegen (1)"; 78085 [id="node_78085" labelType="html" label="MapPartitionsRDD [78085] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205848 { id="cluster_205848"; isCluster="true"; label="Project"; 78086 [id="node_78086" labelType="html" label="MapPartitionsRDD [78086] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205861 { id="cluster_205861"; isCluster="true"; label="InMemoryTableScan"; 78087 [id="node_78087" labelType="html" label="MapPartitionsRDD [78087] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78088 [id="node_78088" labelType="html" label="MapPartitionsRDD [78088] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78089 [id="node_78089" labelType="html" label="MapPartitionsRDD [78089] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205856 { id="cluster_205856"; isCluster="true"; label="WholeStageCodegen (2)"; 78090 [id="node_78090" labelType="html" label="MapPartitionsRDD [78090] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205855 { id="cluster_205855"; isCluster="true"; label="Project"; 78091 [id="node_78091" labelType="html" label="MapPartitionsRDD [78091] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205838 { id="cluster_205838"; isCluster="true"; label="Union"; 78092 [id="node_78092" labelType="html" label="UnionRDD [78092] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205825 { id="cluster_205825"; isCluster="true"; label="WholeStageCodegen (4)"; 78093 [id="node_78093" labelType="html" label="MapPartitionsRDD [78093] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205824 { id="cluster_205824"; isCluster="true"; label="SortAggregate"; 78094 [id="node_78094" labelType="html" label="MapPartitionsRDD [78094] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205823 { id="cluster_205823"; isCluster="true"; label="Exchange"; 78095 [id="node_78095" labelType="html" label="MapPartitionsRDD [78095] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 78058->78059; 78059->78060; 78060->78061; 78061->78062; 78062->78063; 78063->78064; 78064->78065; 78065->78066; 78066->78067; 78067->78068; 78068->78074; 78074->78075; 78075->78076; 78076->78077; 78077->78078; 78078->78079; 78079->78080; 78080->78081; 78077->78082; 78082->78083; 78083->78084; 78084->78085; 78085->78086; 78077->78087; 78087->78088; 78088->78089; 78089->78090; 78090->78091; 78081->78092; 78086->78092; 78091->78092; 78092->78093; 78093->78094; 78094->78095; }

78057,78058

78068

78077

digraph G { id="graph_27802"; subgraph graph_stage_27802 { id="graph_stage_27802"; isCluster="true"; label="Stage 27802"; subgraph cluster_205823 { id="cluster_205823"; isCluster="true"; label="Exchange"; 78096 [id="node_78096" labelType="html" label="ShuffledRowRDD [78096] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205816 { id="cluster_205816"; isCluster="true"; label="WholeStageCodegen (5)"; 78097 [id="node_78097" labelType="html" label="MapPartitionsRDD [78097] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205815 { id="cluster_205815"; isCluster="true"; label="SortAggregate"; 78098 [id="node_78098" labelType="html" label="MapPartitionsRDD [78098] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205814 { id="cluster_205814"; isCluster="true"; label="InMemoryTableScan"; 78099 [id="node_78099" labelType="html" label="MapPartitionsRDD [78099] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78100 [id="node_78100" labelType="html" label="SortAggregate(key=[demandChannel#1363576, shardId#1310127, qty#1363596, worklistShardItemId#1310128L, demandStream#1363577], functions=[first(kpis#1363605, false)], output=[shardId#1310127, worklistShardItemId#1310128L, qty#1363596, demandChannel#1363576, demandStream#1363577, kpis#1363718])\n+- *(5) Sort [demandChannel#1363576 ASC NULLS FIRST, shardId#1310127 ASC NULLS FIRST, qty#1363596 ASC NULLS FIRST, worklistShardItemId#1310128L ASC NULLS FIRST, demandStream#1363577 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1363576, shardId#1310127, qty#1363596, worklistShardItemId#1310128L, demandStream#1363577, 30), ENSURE_REQUIREMENTS, [plan_id=2205987]\n +- SortAggregate(key=[demandChannel#1363576, shardId#1310127, knownfloatingpointnormalized(normalizenanandzero(qty#1363596)) AS qty#1363596, worklistShardItemId#1310128L, demandStream#1363577], functions=[partial_first(kpis#1363605, false)], output=[demandChannel#1363576, shardId#1310127, qty#1363596, worklistShardItemId#1310128L,... [78100] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205926 { id="cluster_205926"; isCluster="true"; label="InMemoryTableScan"; 78115 [id="node_78115" labelType="html" label="MapPartitionsRDD [78115] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78116 [id="node_78116" labelType="html" label="MapPartitionsRDD [78116] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78117 [id="node_78117" labelType="html" label="MapPartitionsRDD [78117] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205901 { id="cluster_205901"; isCluster="true"; label="WholeStageCodegen (3)"; 78118 [id="node_78118" labelType="html" label="MapPartitionsRDD [78118] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205900 { id="cluster_205900"; isCluster="true"; label="InMemoryTableScan"; 78119 [id="node_78119" labelType="html" label="MapPartitionsRDD [78119] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78120 [id="node_78120" labelType="html" label="*(3) Project [shardId#1310127, worklistShardItemId#1310128L, version#1364067, qty#1363596, demandChannel#1363576, demandStream#1363577, kpis#1363605]\n+- *(3) BroadcastHashJoin [shardId#1310127, worklistShardItemId#1310128L], [shardId#1364072, worklistShardItemId#1364073L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#1310127) AND isnotnull(worklistShardItemId#1310128L))\n : +- InMemoryTableScan [shardId#1310127, worklistShardItemId#1310128L, qty#1363596, demandChannel#1363576, demandStream#1363577, kpis#1363605], [isnotnull(shardId#1310127), isnotnull(worklistShardItemId#1310128L)]\n : +- InMemoryRelation [shardId#1310127, worklistShardItemId#1310128L, qty#1363596, demandChannel#1363576, demandStream#1363577, kpis#1363605], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#1363576, shardId#1310127, qty#1363596, worklistShardItemId#1310128L, demandStream#1363577], functions=[first(kpis#1363605, false)], output=[shardId#1310127, worklistSh... [78120] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78121 [id="node_78121" labelType="html" label="MapPartitionsRDD [78121] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78122 [id="node_78122" labelType="html" label="MapPartitionsRDD [78122] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78123 [id="node_78123" labelType="html" label="MapPartitionsRDD [78123] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205899 { id="cluster_205899"; isCluster="true"; label="CollectLimit"; 78124 [id="node_78124" labelType="html" label="MapPartitionsRDD [78124] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78125 [id="node_78125" labelType="html" label="MapPartitionsRDD [78125] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 78096->78097; 78097->78098; 78098->78099; 78099->78100; 78100->78115; 78115->78116; 78116->78117; 78117->78118; 78118->78119; 78119->78120; 78120->78121; 78121->78122; 78122->78123; 78123->78124; 78124->78125; }

78095,78096

78100

78120

digraph G { id="graph_27803"; subgraph graph_stage_27803 { id="graph_stage_27803"; isCluster="true"; label="Stage 27803"; subgraph cluster_205899 { id="cluster_205899"; isCluster="true"; label="CollectLimit"; 78126 [id="node_78126" labelType="html" label="ShuffledRowRDD [78126] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78127 [id="node_78127" labelType="html" label="MapPartitionsRDD [78127] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205927 { id="cluster_205927"; isCluster="true"; label="mapPartitionsInternal"; 78128 [id="node_78128" labelType="html" label="MapPartitionsRDD [78128] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 78126->78127; 78127->78128; }

78125,78126

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
27803	tenants-pool-562	stream-10000001127-1 id = 716dccd8-00fd-4bd0-80ff-071a254ffe2f runId = d96bf115-f542-4550-b53f-c6857f91a685 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/21 18:07:48	8 ms	1/1
27802	tenants-pool-562	stream-10000001127-1 id = 716dccd8-00fd-4bd0-80ff-071a254ffe2f runId = d96bf115-f542-4550-b53f-c6857f91a685 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/21 18:07:48	0.2 s	30/30	13.4 KiB			1488.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

27803

tenants-pool-562

stream-10000001127-1 id = 716dccd8-00fd-4bd0-80ff-071a254ffe2f runId = d96bf115-f542-4550-b53f-c6857f91a685 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/21 18:07:48

8 ms

1/1

27802

tenants-pool-562

stream-10000001127-1 id = 716dccd8-00fd-4bd0-80ff-071a254ffe2f runId = d96bf115-f542-4550-b53f-c6857f91a685 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/21 18:07:48

0.2 s

30/30

13.4 KiB

1488.0 B

Page:

Skipped Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
27801	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
27800	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
27799	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
27798	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
27797	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
27796	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: