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

Status: SUCCEEDED
Submitted: 2026/08/10 09:41:34
Duration: 0.4 s
Associated SQL Query: 843
Job Group: 3653a010-ae51-4869-9921-1deae7ee7835
Completed Stages: 2
Skipped Stages: 6

Enable zooming

digraph G { id="graph_3956"; subgraph graph_stage_3956 { id="graph_stage_3956"; isCluster="true"; label="Stage 3956 (skipped)"; subgraph cluster_27306 { id="cluster_27306"; isCluster="true"; label="Scan parquet "; 10117 [id="node_10117" labelType="html" label="FileScanRDD [10117] start at FileStorageAdapterImpl.java:177}"]; 10118 [id="node_10118" labelType="html" label="MapPartitionsRDD [10118] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27302 { id="cluster_27302"; isCluster="true"; label="WholeStageCodegen (7)"; 10119 [id="node_10119" labelType="html" label="MapPartitionsRDD [10119] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27301 { id="cluster_27301"; isCluster="true"; label="Exchange"; 10120 [id="node_10120" labelType="html" label="MapPartitionsRDD [10120] start at FileStorageAdapterImpl.java:177}"]; } } 10117->10118; 10118->10119; 10119->10120; }

digraph G { id="graph_3957"; subgraph graph_stage_3957 { id="graph_stage_3957"; isCluster="true"; label="Stage 3957 (skipped)"; subgraph cluster_27280 { id="cluster_27280"; isCluster="true"; label="Scan parquet "; 10106 [id="node_10106" labelType="html" label="FileScanRDD [10106] start at FileStorageAdapterImpl.java:177}"]; 10107 [id="node_10107" labelType="html" label="MapPartitionsRDD [10107] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27276 { id="cluster_27276"; isCluster="true"; label="WholeStageCodegen (1)"; 10108 [id="node_10108" labelType="html" label="MapPartitionsRDD [10108] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27275 { id="cluster_27275"; isCluster="true"; label="Exchange"; 10109 [id="node_10109" labelType="html" label="MapPartitionsRDD [10109] start at FileStorageAdapterImpl.java:177}"]; } } 10106->10107; 10107->10108; 10108->10109; }

digraph G { id="graph_3958"; subgraph graph_stage_3958 { id="graph_stage_3958"; isCluster="true"; label="Stage 3958 (skipped)"; subgraph cluster_27275 { id="cluster_27275"; isCluster="true"; label="Exchange"; 10110 [id="node_10110" labelType="html" label="ShuffledRowRDD [10110] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27247 { id="cluster_27247"; isCluster="true"; label="WholeStageCodegen (5)"; 10111 [id="node_10111" labelType="html" label="MapPartitionsRDD [10111] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27246 { id="cluster_27246"; isCluster="true"; label="Exchange"; 10112 [id="node_10112" labelType="html" label="MapPartitionsRDD [10112] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 10110->10111; 10111->10112; }

10109,10110

digraph G { id="graph_3959"; subgraph graph_stage_3959 { id="graph_stage_3959"; isCluster="true"; label="Stage 3959 (skipped)"; subgraph cluster_27301 { id="cluster_27301"; isCluster="true"; label="Exchange"; 10121 [id="node_10121" labelType="html" label="ShuffledRowRDD [10121] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27286 { id="cluster_27286"; isCluster="true"; label="WholeStageCodegen (11)"; 10122 [id="node_10122" labelType="html" label="MapPartitionsRDD [10122] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27285 { id="cluster_27285"; isCluster="true"; label="Exchange"; 10123 [id="node_10123" labelType="html" label="MapPartitionsRDD [10123] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 10121->10122; 10122->10123; }

10120,10121

digraph G { id="graph_3960"; subgraph graph_stage_3960 { id="graph_stage_3960"; isCluster="true"; label="Stage 3960 (skipped)"; subgraph cluster_27246 { id="cluster_27246"; isCluster="true"; label="Exchange"; 10113 [id="node_10113" labelType="html" label="ShuffledRowRDD [10113] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27243 { id="cluster_27243"; isCluster="true"; label="WholeStageCodegen (6)"; 10114 [id="node_10114" labelType="html" label="MapPartitionsRDD [10114] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27285 { id="cluster_27285"; isCluster="true"; label="Exchange"; 10124 [id="node_10124" labelType="html" label="ShuffledRowRDD [10124] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27282 { id="cluster_27282"; isCluster="true"; label="WholeStageCodegen (12)"; 10125 [id="node_10125" labelType="html" label="MapPartitionsRDD [10125] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27239 { id="cluster_27239"; isCluster="true"; label="WholeStageCodegen (13)"; 10126 [id="node_10126" labelType="html" label="ZippedPartitionsRDD2 [10126] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10127 [id="node_10127" labelType="html" label="MapPartitionsRDD [10127] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27238 { id="cluster_27238"; isCluster="true"; label="ObjectHashAggregate"; 10128 [id="node_10128" labelType="html" label="MapPartitionsRDD [10128] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27237 { id="cluster_27237"; isCluster="true"; label="Exchange"; 10129 [id="node_10129" labelType="html" label="MapPartitionsRDD [10129] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 10113->10114; 10124->10125; 10114->10126; 10125->10126; 10126->10127; 10127->10128; 10128->10129; }

10112,10113

10123,10124

digraph G { id="graph_3961"; subgraph graph_stage_3961 { id="graph_stage_3961"; isCluster="true"; label="Stage 3961 (skipped)"; 10138 [id="node_10138" labelType="html" label="SQLExecutionRDD [10138] [Unordered] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_27237 { id="cluster_27237"; isCluster="true"; label="Exchange"; 10130 [id="node_10130" labelType="html" label="ShuffledRowRDD [10130] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27236 { id="cluster_27236"; isCluster="true"; label="ObjectHashAggregate"; 10131 [id="node_10131" labelType="html" label="MapPartitionsRDD [10131] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27235 { id="cluster_27235"; isCluster="true"; label="Project"; 10132 [id="node_10132" labelType="html" label="MapPartitionsRDD [10132] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27228 { id="cluster_27228"; isCluster="true"; label="WholeStageCodegen (16)"; 10133 [id="node_10133" labelType="html" label="MapPartitionsRDD [10133] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27227 { id="cluster_27227"; isCluster="true"; label="DeserializeToObject"; 10134 [id="node_10134" labelType="html" label="MapPartitionsRDD [10134] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27226 { id="cluster_27226"; isCluster="true"; label="MapPartitions"; 10135 [id="node_10135" labelType="html" label="MapPartitionsRDD [10135] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27158 { id="cluster_27158"; isCluster="true"; label="WholeStageCodegen (19)"; 10136 [id="node_10136" labelType="html" label="MapPartitionsRDD [10136] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27137 { id="cluster_27137"; isCluster="true"; label="DeserializeToObject"; 10137 [id="node_10137" labelType="html" label="MapPartitionsRDD [10137] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27314 { id="cluster_27314"; isCluster="true"; label="mapPartitions"; 10139 [id="node_10139" labelType="html" label="MapPartitionsRDD [10139] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27315 { id="cluster_27315"; isCluster="true"; label="mapPartitions"; 10140 [id="node_10140" labelType="html" label="MapPartitionsRDD [10140] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27383 { id="cluster_27383"; isCluster="true"; label="Scan"; 10146 [id="node_10146" labelType="html" label="MapPartitionsRDD [10146] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27377 { id="cluster_27377"; isCluster="true"; label="WholeStageCodegen (1)"; 10147 [id="node_10147" labelType="html" label="MapPartitionsRDD [10147] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27376 { id="cluster_27376"; isCluster="true"; label="InMemoryTableScan"; 10148 [id="node_10148" labelType="html" label="MapPartitionsRDD [10148] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10149 [id="node_10149" labelType="html" label="*(1) Generate explode(prodPlantResults#175298), false, [prodPlantResults#175305]\n+- *(1) Project [prodPlantResults#175298]\n +- *(1) Filter ((size(prodPlantResults#175298, true) > 0) AND isnotnull(prodPlantResults#175298))\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,StringType,... [10149] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10150 [id="node_10150" labelType="html" label="MapPartitionsRDD [10150] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10151 [id="node_10151" labelType="html" label="MapPartitionsRDD [10151] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10152 [id="node_10152" labelType="html" label="MapPartitionsRDD [10152] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27375 { id="cluster_27375"; isCluster="true"; label="Project"; 10153 [id="node_10153" labelType="html" label="MapPartitionsRDD [10153] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27390 { id="cluster_27390"; isCluster="true"; label="InMemoryTableScan"; 10154 [id="node_10154" labelType="html" label="MapPartitionsRDD [10154] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10155 [id="node_10155" labelType="html" label="MapPartitionsRDD [10155] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10156 [id="node_10156" labelType="html" label="MapPartitionsRDD [10156] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27385 { id="cluster_27385"; isCluster="true"; label="WholeStageCodegen (1)"; 10157 [id="node_10157" labelType="html" label="MapPartitionsRDD [10157] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27384 { id="cluster_27384"; isCluster="true"; label="Project"; 10158 [id="node_10158" labelType="html" label="MapPartitionsRDD [10158] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27397 { id="cluster_27397"; isCluster="true"; label="InMemoryTableScan"; 10159 [id="node_10159" labelType="html" label="MapPartitionsRDD [10159] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10160 [id="node_10160" labelType="html" label="MapPartitionsRDD [10160] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10161 [id="node_10161" labelType="html" label="MapPartitionsRDD [10161] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27392 { id="cluster_27392"; isCluster="true"; label="WholeStageCodegen (2)"; 10162 [id="node_10162" labelType="html" label="MapPartitionsRDD [10162] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27391 { id="cluster_27391"; isCluster="true"; label="Project"; 10163 [id="node_10163" labelType="html" label="MapPartitionsRDD [10163] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27374 { id="cluster_27374"; isCluster="true"; label="Union"; 10164 [id="node_10164" labelType="html" label="UnionRDD [10164] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27359 { id="cluster_27359"; isCluster="true"; label="WholeStageCodegen (4)"; 10165 [id="node_10165" labelType="html" label="MapPartitionsRDD [10165] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27358 { id="cluster_27358"; isCluster="true"; label="SortAggregate"; 10166 [id="node_10166" labelType="html" label="MapPartitionsRDD [10166] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27357 { id="cluster_27357"; isCluster="true"; label="Exchange"; 10167 [id="node_10167" labelType="html" label="MapPartitionsRDD [10167] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 10130->10131; 10131->10132; 10132->10133; 10133->10134; 10134->10135; 10135->10136; 10136->10137; 10137->10138; 10138->10139; 10139->10140; 10140->10146; 10146->10147; 10147->10148; 10148->10149; 10149->10150; 10150->10151; 10151->10152; 10152->10153; 10149->10154; 10154->10155; 10155->10156; 10156->10157; 10157->10158; 10149->10159; 10159->10160; 10160->10161; 10161->10162; 10162->10163; 10153->10164; 10158->10164; 10163->10164; 10164->10165; 10165->10166; 10166->10167; }

10129,10130

10140

10149

digraph G { id="graph_3962"; subgraph graph_stage_3962 { id="graph_stage_3962"; isCluster="true"; label="Stage 3962"; subgraph cluster_27357 { id="cluster_27357"; isCluster="true"; label="Exchange"; 10168 [id="node_10168" labelType="html" label="ShuffledRowRDD [10168] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27352 { id="cluster_27352"; isCluster="true"; label="WholeStageCodegen (5)"; 10169 [id="node_10169" labelType="html" label="MapPartitionsRDD [10169] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27351 { id="cluster_27351"; isCluster="true"; label="SortAggregate"; 10170 [id="node_10170" labelType="html" label="MapPartitionsRDD [10170] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27350 { id="cluster_27350"; isCluster="true"; label="InMemoryTableScan"; 10171 [id="node_10171" labelType="html" label="MapPartitionsRDD [10171] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10172 [id="node_10172" labelType="html" label="SortAggregate(key=[demandChannel#175331, shardId#142281, qty#175351, worklistShardItemId#142282L, demandStream#175332], functions=[first(kpis#175360, false)], output=[shardId#142281, worklistShardItemId#142282L, qty#175351, demandChannel#175331, demandStream#175332, kpis#175473])\n+- *(5) Sort [demandChannel#175331 ASC NULLS FIRST, shardId#142281 ASC NULLS FIRST, qty#175351 ASC NULLS FIRST, worklistShardItemId#142282L ASC NULLS FIRST, demandStream#175332 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#175331, shardId#142281, qty#175351, worklistShardItemId#142282L, demandStream#175332, 20), ENSURE_REQUIREMENTS, [plan_id=316242]\n +- SortAggregate(key=[demandChannel#175331, shardId#142281, knownfloatingpointnormalized(normalizenanandzero(qty#175351)) AS qty#175351, worklistShardItemId#142282L, demandStream#175332], functions=[partial_first(kpis#175360, false)], output=[demandChannel#175331, shardId#142281, qty#175351, worklistShardItemId#142282L, demandStream#175332, first#175539... [10172] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27462 { id="cluster_27462"; isCluster="true"; label="InMemoryTableScan"; 10187 [id="node_10187" labelType="html" label="MapPartitionsRDD [10187] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10188 [id="node_10188" labelType="html" label="MapPartitionsRDD [10188] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10189 [id="node_10189" labelType="html" label="MapPartitionsRDD [10189] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27437 { id="cluster_27437"; isCluster="true"; label="WholeStageCodegen (3)"; 10190 [id="node_10190" labelType="html" label="MapPartitionsRDD [10190] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27436 { id="cluster_27436"; isCluster="true"; label="InMemoryTableScan"; 10191 [id="node_10191" labelType="html" label="MapPartitionsRDD [10191] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10192 [id="node_10192" labelType="html" label="*(3) Project [shardId#142281, worklistShardItemId#142282L, version#175822, qty#175351, demandChannel#175331, demandStream#175332, kpis#175360]\n+- *(3) BroadcastHashJoin [shardId#142281, worklistShardItemId#142282L], [shardId#175827, worklistShardItemId#175828L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#142281) AND isnotnull(worklistShardItemId#142282L))\n : +- InMemoryTableScan [shardId#142281, worklistShardItemId#142282L, qty#175351, demandChannel#175331, demandStream#175332, kpis#175360], [isnotnull(shardId#142281), isnotnull(worklistShardItemId#142282L)]\n : +- InMemoryRelation [shardId#142281, worklistShardItemId#142282L, qty#175351, demandChannel#175331, demandStream#175332, kpis#175360], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#175331, shardId#142281, qty#175351, worklistShardItemId#142282L, demandStream#175332], functions=[first(kpis#175360, false)], output=[shardId#142281, worklistShardItemId#142282L, qty#175351, dem... [10192] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10193 [id="node_10193" labelType="html" label="MapPartitionsRDD [10193] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10194 [id="node_10194" labelType="html" label="MapPartitionsRDD [10194] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10195 [id="node_10195" labelType="html" label="MapPartitionsRDD [10195] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27435 { id="cluster_27435"; isCluster="true"; label="CollectLimit"; 10196 [id="node_10196" labelType="html" label="MapPartitionsRDD [10196] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10197 [id="node_10197" labelType="html" label="MapPartitionsRDD [10197] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 10168->10169; 10169->10170; 10170->10171; 10171->10172; 10172->10187; 10187->10188; 10188->10189; 10189->10190; 10190->10191; 10191->10192; 10192->10193; 10193->10194; 10194->10195; 10195->10196; 10196->10197; }

10167,10168

10172

10192

digraph G { id="graph_3963"; subgraph graph_stage_3963 { id="graph_stage_3963"; isCluster="true"; label="Stage 3963"; subgraph cluster_27435 { id="cluster_27435"; isCluster="true"; label="CollectLimit"; 10198 [id="node_10198" labelType="html" label="ShuffledRowRDD [10198] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10199 [id="node_10199" labelType="html" label="MapPartitionsRDD [10199] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27463 { id="cluster_27463"; isCluster="true"; label="mapPartitionsInternal"; 10200 [id="node_10200" labelType="html" label="MapPartitionsRDD [10200] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 10198->10199; 10199->10200; }

10197,10198

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
3963	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 6 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/08/10 09:41:35	7 ms	1/1
3962	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 6 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/08/10 09:41:34	0.4 s	20/20	20.0 KiB			1240.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

3963

tenants-pool-286

stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 6 start at FileStorageAdapterImpl.java:177 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44)
io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23)
io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88)
io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
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/08/10 09:41:35

7 ms

1/1

3962

tenants-pool-286

stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 6 start at FileStorageAdapterImpl.java:177 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44)
io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23)
io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88)
io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
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/08/10 09:41:34

0.4 s

20/20

20.0 KiB

1240.0 B

Page:

Skipped Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
3961	default	start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/60
3960	default	start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/20
3959	default	start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/20
3958	default	start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/20
3957	default	start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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
3956	default	start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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: