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

Status: SUCCEEDED
Submitted: 2026/08/10 09:41:33
Duration: 1.0 s
Associated SQL Query: 830
Job Group: 3653a010-ae51-4869-9921-1deae7ee7835
Completed Stages: 2
Skipped Stages: 5

Enable zooming

digraph G { id="graph_3946"; subgraph graph_stage_3946 { id="graph_stage_3946"; isCluster="true"; label="Stage 3946 (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_3947"; subgraph graph_stage_3947 { id="graph_stage_3947"; isCluster="true"; label="Stage 3947 (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_3948"; subgraph graph_stage_3948 { id="graph_stage_3948"; isCluster="true"; label="Stage 3948 (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_3949"; subgraph graph_stage_3949 { id="graph_stage_3949"; isCluster="true"; label="Stage 3949 (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_3950"; subgraph graph_stage_3950 { id="graph_stage_3950"; isCluster="true"; label="Stage 3950 (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_3951"; subgraph graph_stage_3951 { id="graph_stage_3951"; isCluster="true"; label="Stage 3951"; 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_3952"; subgraph graph_stage_3952 { id="graph_stage_3952"; isCluster="true"; label="Stage 3952"; 10177 [id="node_10177" labelType="html" label="SQLExecutionRDD [10177] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 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}"]; 10173 [id="node_10173" labelType="html" label="MapPartitionsRDD [10173] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10174 [id="node_10174" labelType="html" label="MapPartitionsRDD [10174] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10175 [id="node_10175" labelType="html" label="MapPartitionsRDD [10175] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27349 { id="cluster_27349"; isCluster="true"; label="DeserializeToObject"; 10176 [id="node_10176" labelType="html" label="MapPartitionsRDD [10176] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27398 { id="cluster_27398"; isCluster="true"; label="mapPartitions"; 10178 [id="node_10178" labelType="html" label="MapPartitionsRDD [10178] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 10168->10169; 10169->10170; 10170->10171; 10171->10172; 10172->10173; 10173->10174; 10174->10175; 10175->10176; 10176->10177; 10177->10178; }

10167,10168

10172

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
3952	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.2 s	20/20			73.8 KiB
3951	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:33	0.8 s	60/60	156.3 KiB			73.8 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

3952

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.2 s

20/20

73.8 KiB

3951

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:33

0.8 s

60/60

156.3 KiB

73.8 KiB

Page:

Skipped Stages (5)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
3950	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
3949	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
3948	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
3947	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
3946	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: