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

Status: SUCCEEDED
Submitted: 2026/05/22 09:47:04
Duration: 2 s
Associated SQL Query: 72871
Job Group: 326fbe20-7556-41a9-9fce-e25b8059f480
Completed Stages: 6

Enable zooming

digraph G { id="graph_318459"; subgraph graph_stage_318459 { id="graph_stage_318459"; isCluster="true"; label="Stage 318459"; subgraph cluster_2309599 { id="cluster_2309599"; isCluster="true"; label="Scan parquet "; 891065 [id="node_891065" labelType="html" label="FileScanRDD [891065] start at FileStorageAdapterImpl.java:174}"]; 891066 [id="node_891066" labelType="html" label="MapPartitionsRDD [891066] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309595 { id="cluster_2309595"; isCluster="true"; label="WholeStageCodegen (1)"; 891067 [id="node_891067" labelType="html" label="MapPartitionsRDD [891067] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309594 { id="cluster_2309594"; isCluster="true"; label="Exchange"; 891068 [id="node_891068" labelType="html" label="MapPartitionsRDD [891068] start at FileStorageAdapterImpl.java:174}"]; } } 891065->891066; 891066->891067; 891067->891068; }

digraph G { id="graph_318460"; subgraph graph_stage_318460 { id="graph_stage_318460"; isCluster="true"; label="Stage 318460"; subgraph cluster_2309632 { id="cluster_2309632"; isCluster="true"; label="Scan parquet "; 891076 [id="node_891076" labelType="html" label="FileScanRDD [891076] start at FileStorageAdapterImpl.java:174}"]; 891077 [id="node_891077" labelType="html" label="MapPartitionsRDD [891077] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309628 { id="cluster_2309628"; isCluster="true"; label="WholeStageCodegen (7)"; 891078 [id="node_891078" labelType="html" label="MapPartitionsRDD [891078] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309627 { id="cluster_2309627"; isCluster="true"; label="Exchange"; 891079 [id="node_891079" labelType="html" label="MapPartitionsRDD [891079] start at FileStorageAdapterImpl.java:174}"]; } } 891076->891077; 891077->891078; 891078->891079; }

digraph G { id="graph_318461"; subgraph graph_stage_318461 { id="graph_stage_318461"; isCluster="true"; label="Stage 318461"; subgraph cluster_2309627 { id="cluster_2309627"; isCluster="true"; label="Exchange"; 891080 [id="node_891080" labelType="html" label="ShuffledRowRDD [891080] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309605 { id="cluster_2309605"; isCluster="true"; label="WholeStageCodegen (11)"; 891081 [id="node_891081" labelType="html" label="MapPartitionsRDD [891081] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309604 { id="cluster_2309604"; isCluster="true"; label="Exchange"; 891082 [id="node_891082" labelType="html" label="MapPartitionsRDD [891082] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 891080->891081; 891081->891082; }

891079,891080

digraph G { id="graph_318462"; subgraph graph_stage_318462 { id="graph_stage_318462"; isCluster="true"; label="Stage 318462"; subgraph cluster_2309594 { id="cluster_2309594"; isCluster="true"; label="Exchange"; 891069 [id="node_891069" labelType="html" label="ShuffledRowRDD [891069] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309582 { id="cluster_2309582"; isCluster="true"; label="WholeStageCodegen (5)"; 891070 [id="node_891070" labelType="html" label="MapPartitionsRDD [891070] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309581 { id="cluster_2309581"; isCluster="true"; label="Exchange"; 891071 [id="node_891071" labelType="html" label="MapPartitionsRDD [891071] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 891069->891070; 891070->891071; }

891068,891069

digraph G { id="graph_318463"; subgraph graph_stage_318463 { id="graph_stage_318463"; isCluster="true"; label="Stage 318463"; subgraph cluster_2309581 { id="cluster_2309581"; isCluster="true"; label="Exchange"; 891072 [id="node_891072" labelType="html" label="ShuffledRowRDD [891072] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309578 { id="cluster_2309578"; isCluster="true"; label="WholeStageCodegen (6)"; 891073 [id="node_891073" labelType="html" label="MapPartitionsRDD [891073] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309604 { id="cluster_2309604"; isCluster="true"; label="Exchange"; 891083 [id="node_891083" labelType="html" label="ShuffledRowRDD [891083] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309601 { id="cluster_2309601"; isCluster="true"; label="WholeStageCodegen (12)"; 891084 [id="node_891084" labelType="html" label="MapPartitionsRDD [891084] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309574 { id="cluster_2309574"; isCluster="true"; label="WholeStageCodegen (13)"; 891085 [id="node_891085" labelType="html" label="ZippedPartitionsRDD2 [891085] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 891086 [id="node_891086" labelType="html" label="MapPartitionsRDD [891086] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309573 { id="cluster_2309573"; isCluster="true"; label="ObjectHashAggregate"; 891087 [id="node_891087" labelType="html" label="MapPartitionsRDD [891087] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309572 { id="cluster_2309572"; isCluster="true"; label="Exchange"; 891088 [id="node_891088" labelType="html" label="MapPartitionsRDD [891088] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 891072->891073; 891083->891084; 891073->891085; 891084->891085; 891085->891086; 891086->891087; 891087->891088; }

891071,891072

891082,891083

digraph G { id="graph_318464"; subgraph graph_stage_318464 { id="graph_stage_318464"; isCluster="true"; label="Stage 318464"; 891097 [id="node_891097" labelType="html" label="SQLExecutionRDD [891097] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_2309572 { id="cluster_2309572"; isCluster="true"; label="Exchange"; 891089 [id="node_891089" labelType="html" label="ShuffledRowRDD [891089] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309571 { id="cluster_2309571"; isCluster="true"; label="ObjectHashAggregate"; 891090 [id="node_891090" labelType="html" label="MapPartitionsRDD [891090] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309570 { id="cluster_2309570"; isCluster="true"; label="Project"; 891091 [id="node_891091" labelType="html" label="MapPartitionsRDD [891091] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309563 { id="cluster_2309563"; isCluster="true"; label="WholeStageCodegen (16)"; 891092 [id="node_891092" labelType="html" label="MapPartitionsRDD [891092] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309562 { id="cluster_2309562"; isCluster="true"; label="DeserializeToObject"; 891093 [id="node_891093" labelType="html" label="MapPartitionsRDD [891093] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309561 { id="cluster_2309561"; isCluster="true"; label="MapPartitions"; 891094 [id="node_891094" labelType="html" label="MapPartitionsRDD [891094] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309484 { id="cluster_2309484"; isCluster="true"; label="WholeStageCodegen (19)"; 891095 [id="node_891095" labelType="html" label="MapPartitionsRDD [891095] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309463 { id="cluster_2309463"; isCluster="true"; label="DeserializeToObject"; 891096 [id="node_891096" labelType="html" label="MapPartitionsRDD [891096] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309640 { id="cluster_2309640"; isCluster="true"; label="mapPartitions"; 891098 [id="node_891098" labelType="html" label="MapPartitionsRDD [891098] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_2309641 { id="cluster_2309641"; isCluster="true"; label="mapPartitions"; 891099 [id="node_891099" labelType="html" label="MapPartitionsRDD [891099] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 891089->891090; 891090->891091; 891091->891092; 891092->891093; 891093->891094; 891094->891095; 891095->891096; 891096->891097; 891097->891098; 891098->891099; }

891088,891089

891099

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
318464	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 27 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:47:06	0.7 s	30/30	3.1 KiB
318463	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 27 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:47:05	0.8 s	30/30	3.9 KiB	3.1 KiB
318462	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 27 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:47:04	0.3 s	30/30	5.3 KiB	3.1 KiB
318461	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 27 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:47:04	0.4 s	30/30	2.3 KiB	784.0 B
318460	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 27 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:47:04	0.3 s	1/1		2.3 KiB
318459	tenants-pool-169	stream-10000000246-1 id = 7f8172c3-32d1-4cb3-83ea-2c017a4bcd82 runId = 326fbe20-7556-41a9-9fce-e25b8059f480 batch = 27 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:47:04	0.2 s	1/1		5.3 KiB

Page: