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

Status: SUCCEEDED
Submitted: 2026/03/21 01:08:28
Duration: 1 s
Associated SQL Query: 3517
Job Group: 81faa882-918e-4a51-b5e3-3a01a5c048df
Completed Stages: 2

Enable zooming

digraph G { id="graph_115423"; subgraph graph_stage_115423 { id="graph_stage_115423"; isCluster="true"; label="Stage 115423"; subgraph cluster_144091 { id="cluster_144091"; isCluster="true"; label="Scan json "; 55372 [id="node_55372" labelType="html" label="FileScanRDD [55372] start at FileStorageAdapterImpl.java:171}"]; 55373 [id="node_55373" labelType="html" label="MapPartitionsRDD [55373] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144088 { id="cluster_144088"; isCluster="true"; label="WholeStageCodegen (1)"; 55374 [id="node_55374" labelType="html" label="MapPartitionsRDD [55374] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144087 { id="cluster_144087"; isCluster="true"; label="Exchange"; 55375 [id="node_55375" labelType="html" label="MapPartitionsRDD [55375] start at FileStorageAdapterImpl.java:171}"]; } } 55372->55373; 55373->55374; 55374->55375; }

digraph G { id="graph_115424"; subgraph graph_stage_115424 { id="graph_stage_115424"; isCluster="true"; label="Stage 115424"; 55381 [id="node_55381" labelType="html" label="SQLExecutionRDD [55381] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 55385 [id="node_55385" labelType="html" label="SQLExecutionRDD [55385] [Unordered] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_144087 { id="cluster_144087"; isCluster="true"; label="Exchange"; 55376 [id="node_55376" labelType="html" label="ShuffledRowRDD [55376] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144083 { id="cluster_144083"; isCluster="true"; label="WholeStageCodegen (2)"; 55377 [id="node_55377" labelType="html" label="MapPartitionsRDD [55377] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144082 { id="cluster_144082"; isCluster="true"; label="DeserializeToObject"; 55378 [id="node_55378" labelType="html" label="MapPartitionsRDD [55378] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144081 { id="cluster_144081"; isCluster="true"; label="MapPartitions"; 55379 [id="node_55379" labelType="html" label="MapPartitionsRDD [55379] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144078 { id="cluster_144078"; isCluster="true"; label="WholeStageCodegen (3)"; 55380 [id="node_55380" labelType="html" label="MapPartitionsRDD [55380] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144092 { id="cluster_144092"; isCluster="true"; label="map"; 55382 [id="node_55382" labelType="html" label="Delta Table State #0 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000350/0_1_10000000350/_delta_log [55382] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144094 { id="cluster_144094"; isCluster="true"; label="WholeStageCodegen (1)"; 55383 [id="node_55383" labelType="html" label="MapPartitionsRDD [55383] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144093 { id="cluster_144093"; isCluster="true"; label="Project"; 55384 [id="node_55384" labelType="html" label="MapPartitionsRDD [55384] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144097 { id="cluster_144097"; isCluster="true"; label="map"; 55386 [id="node_55386" labelType="html" label="Delta Table State with Stats #0 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000350/0_1_10000000350/_delta_log [55386] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144098 { id="cluster_144098"; isCluster="true"; label="WholeStageCodegen (1)"; 55387 [id="node_55387" labelType="html" label="MapPartitionsRDD [55387] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144102 { id="cluster_144102"; isCluster="true"; label="mapPartitionsInternal"; 55388 [id="node_55388" labelType="html" label="MapPartitionsRDD [55388] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 55376->55377; 55377->55378; 55378->55379; 55379->55380; 55380->55381; 55381->55382; 55382->55383; 55383->55384; 55384->55385; 55385->55386; 55386->55387; 55387->55388; }

55375,55376

55382

55386

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
115424	tenants-pool-780	Delta: stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 1: Filtering files for query start at FileStorageAdapterImpl.java:171 +details RDD: Delta Table State #0 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000350/0_1_10000000350/_delta_log Delta Table State with Stats #0 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000350/0_1_10000000350/_delta_log org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) jdk.internal.reflect.GeneratedMethodAccessor1635.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/03/21 01:08:28	1 s	50/50			7.2 KiB
115423	tenants-pool-780	Delta: stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 1: Filtering files for query start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) jdk.internal.reflect.GeneratedMethodAccessor1635.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/03/21 01:08:28	0.2 s	1/1				7.2 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

115424

tenants-pool-780

Delta: stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 1: Filtering files for query start at FileStorageAdapterImpl.java:171 +details

RDD: Delta Table State #0 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000350/0_1_10000000350/_delta_log Delta Table State with Stats #0 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000350/0_1_10000000350/_delta_log

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63)
jdk.internal.reflect.GeneratedMethodAccessor1635.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/03/21 01:08:28

1 s

50/50

7.2 KiB

115423

tenants-pool-780

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63)
jdk.internal.reflect.GeneratedMethodAccessor1635.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/03/21 01:08:28

0.2 s

1/1

7.2 KiB

Page: