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

Status: SUCCEEDED
Submitted: 2026/05/22 09:53:10
Duration: 3 s
Associated SQL Query: 73035
Job Group: 326fbe20-7556-41a9-9fce-e25b8059f480
Completed Stages: 6

Enable zooming

digraph G { id="graph_319148"; subgraph graph_stage_319148 { id="graph_stage_319148"; isCluster="true"; label="Stage 319148"; subgraph cluster_2314531 { id="cluster_2314531"; isCluster="true"; label="Scan parquet "; 893075 [id="node_893075" labelType="html" label="FileScanRDD [893075] start at FileStorageAdapterImpl.java:174}"]; 893076 [id="node_893076" labelType="html" label="MapPartitionsRDD [893076] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314527 { id="cluster_2314527"; isCluster="true"; label="WholeStageCodegen (1)"; 893077 [id="node_893077" labelType="html" label="MapPartitionsRDD [893077] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314526 { id="cluster_2314526"; isCluster="true"; label="Exchange"; 893078 [id="node_893078" labelType="html" label="MapPartitionsRDD [893078] start at FileStorageAdapterImpl.java:174}"]; } } 893075->893076; 893076->893077; 893077->893078; }

digraph G { id="graph_319149"; subgraph graph_stage_319149 { id="graph_stage_319149"; isCluster="true"; label="Stage 319149"; subgraph cluster_2314557 { id="cluster_2314557"; isCluster="true"; label="Scan parquet "; 893086 [id="node_893086" labelType="html" label="FileScanRDD [893086] start at FileStorageAdapterImpl.java:174}"]; 893087 [id="node_893087" labelType="html" label="MapPartitionsRDD [893087] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314553 { id="cluster_2314553"; isCluster="true"; label="WholeStageCodegen (7)"; 893088 [id="node_893088" labelType="html" label="MapPartitionsRDD [893088] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314552 { id="cluster_2314552"; isCluster="true"; label="Exchange"; 893089 [id="node_893089" labelType="html" label="MapPartitionsRDD [893089] start at FileStorageAdapterImpl.java:174}"]; } } 893086->893087; 893087->893088; 893088->893089; }

digraph G { id="graph_319150"; subgraph graph_stage_319150 { id="graph_stage_319150"; isCluster="true"; label="Stage 319150"; subgraph cluster_2314552 { id="cluster_2314552"; isCluster="true"; label="Exchange"; 893090 [id="node_893090" labelType="html" label="ShuffledRowRDD [893090] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314537 { id="cluster_2314537"; isCluster="true"; label="WholeStageCodegen (11)"; 893091 [id="node_893091" labelType="html" label="MapPartitionsRDD [893091] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314536 { id="cluster_2314536"; isCluster="true"; label="Exchange"; 893092 [id="node_893092" labelType="html" label="MapPartitionsRDD [893092] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 893090->893091; 893091->893092; }

893089,893090

digraph G { id="graph_319151"; subgraph graph_stage_319151 { id="graph_stage_319151"; isCluster="true"; label="Stage 319151"; subgraph cluster_2314526 { id="cluster_2314526"; isCluster="true"; label="Exchange"; 893079 [id="node_893079" labelType="html" label="ShuffledRowRDD [893079] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314514 { id="cluster_2314514"; isCluster="true"; label="WholeStageCodegen (5)"; 893080 [id="node_893080" labelType="html" label="MapPartitionsRDD [893080] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314513 { id="cluster_2314513"; isCluster="true"; label="Exchange"; 893081 [id="node_893081" labelType="html" label="MapPartitionsRDD [893081] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 893079->893080; 893080->893081; }

893078,893079

digraph G { id="graph_319152"; subgraph graph_stage_319152 { id="graph_stage_319152"; isCluster="true"; label="Stage 319152"; subgraph cluster_2314513 { id="cluster_2314513"; isCluster="true"; label="Exchange"; 893082 [id="node_893082" labelType="html" label="ShuffledRowRDD [893082] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314510 { id="cluster_2314510"; isCluster="true"; label="WholeStageCodegen (6)"; 893083 [id="node_893083" labelType="html" label="MapPartitionsRDD [893083] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314536 { id="cluster_2314536"; isCluster="true"; label="Exchange"; 893093 [id="node_893093" labelType="html" label="ShuffledRowRDD [893093] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314533 { id="cluster_2314533"; isCluster="true"; label="WholeStageCodegen (12)"; 893094 [id="node_893094" labelType="html" label="MapPartitionsRDD [893094] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314506 { id="cluster_2314506"; isCluster="true"; label="WholeStageCodegen (13)"; 893095 [id="node_893095" labelType="html" label="ZippedPartitionsRDD2 [893095] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 893096 [id="node_893096" labelType="html" label="MapPartitionsRDD [893096] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314505 { id="cluster_2314505"; isCluster="true"; label="ObjectHashAggregate"; 893097 [id="node_893097" labelType="html" label="MapPartitionsRDD [893097] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314504 { id="cluster_2314504"; isCluster="true"; label="Exchange"; 893098 [id="node_893098" labelType="html" label="MapPartitionsRDD [893098] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 893082->893083; 893093->893094; 893083->893095; 893094->893095; 893095->893096; 893096->893097; 893097->893098; }

893081,893082

893092,893093

digraph G { id="graph_319153"; subgraph graph_stage_319153 { id="graph_stage_319153"; isCluster="true"; label="Stage 319153"; 893107 [id="node_893107" labelType="html" label="SQLExecutionRDD [893107] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_2314504 { id="cluster_2314504"; isCluster="true"; label="Exchange"; 893099 [id="node_893099" labelType="html" label="ShuffledRowRDD [893099] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314503 { id="cluster_2314503"; isCluster="true"; label="ObjectHashAggregate"; 893100 [id="node_893100" labelType="html" label="MapPartitionsRDD [893100] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314502 { id="cluster_2314502"; isCluster="true"; label="Project"; 893101 [id="node_893101" labelType="html" label="MapPartitionsRDD [893101] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314474 { id="cluster_2314474"; isCluster="true"; label="WholeStageCodegen (16)"; 893102 [id="node_893102" labelType="html" label="MapPartitionsRDD [893102] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314473 { id="cluster_2314473"; isCluster="true"; label="DeserializeToObject"; 893103 [id="node_893103" labelType="html" label="MapPartitionsRDD [893103] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314472 { id="cluster_2314472"; isCluster="true"; label="MapPartitions"; 893104 [id="node_893104" labelType="html" label="MapPartitionsRDD [893104] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314409 { id="cluster_2314409"; isCluster="true"; label="WholeStageCodegen (19)"; 893105 [id="node_893105" labelType="html" label="MapPartitionsRDD [893105] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314388 { id="cluster_2314388"; isCluster="true"; label="DeserializeToObject"; 893106 [id="node_893106" labelType="html" label="MapPartitionsRDD [893106] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314565 { id="cluster_2314565"; isCluster="true"; label="mapPartitions"; 893108 [id="node_893108" labelType="html" label="MapPartitionsRDD [893108] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2314566 { id="cluster_2314566"; isCluster="true"; label="mapPartitions"; 893109 [id="node_893109" labelType="html" label="MapPartitionsRDD [893109] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 893099->893100; 893100->893101; 893101->893102; 893102->893103; 893103->893104; 893104->893105; 893105->893106; 893106->893107; 893107->893108; 893108->893109; }

893098,893099

893109

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
319153	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 36 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/05/22 09:53:12	1 s	30/30	13.5 KiB
319152	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 36 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/05/22 09:53:11	0.8 s	30/30	29.4 KiB	13.5 KiB
319151	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 36 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/05/22 09:53:11	0.4 s	30/30	5.3 KiB	26.3 KiB
319150	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 36 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/05/22 09:53:11	0.4 s	30/30	2.3 KiB	3.1 KiB
319149	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 36 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/05/22 09:53:10	0.2 s	1/1		2.3 KiB
319148	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 36 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor724.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/05/22 09:53:10	0.2 s	1/1		5.3 KiB

Page: