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

Status: SUCCEEDED
Submitted: 2026/08/10 09:37:59
Duration: 0.7 s
Associated SQL Query: 751
Job Group: 3653a010-ae51-4869-9921-1deae7ee7835
Completed Stages: 2

Enable zooming

digraph G { id="graph_3555"; subgraph graph_stage_3555 { id="graph_stage_3555"; isCluster="true"; label="Stage 3555"; subgraph cluster_24486 { id="cluster_24486"; isCluster="true"; label="Scan json "; 8964 [id="node_8964" labelType="html" label="FileScanRDD [8964] start at FileStorageAdapterImpl.java:177}"]; 8965 [id="node_8965" labelType="html" label="MapPartitionsRDD [8965] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24483 { id="cluster_24483"; isCluster="true"; label="WholeStageCodegen (1)"; 8966 [id="node_8966" labelType="html" label="MapPartitionsRDD [8966] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24482 { id="cluster_24482"; isCluster="true"; label="Exchange"; 8967 [id="node_8967" labelType="html" label="MapPartitionsRDD [8967] start at FileStorageAdapterImpl.java:177}"]; } } 8964->8965; 8965->8966; 8966->8967; }

digraph G { id="graph_3556"; subgraph graph_stage_3556 { id="graph_stage_3556"; isCluster="true"; label="Stage 3556"; 8973 [id="node_8973" labelType="html" label="SQLExecutionRDD [8973] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 8977 [id="node_8977" labelType="html" label="SQLExecutionRDD [8977] [Unordered] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_24482 { id="cluster_24482"; isCluster="true"; label="Exchange"; 8968 [id="node_8968" labelType="html" label="ShuffledRowRDD [8968] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24478 { id="cluster_24478"; isCluster="true"; label="WholeStageCodegen (2)"; 8969 [id="node_8969" labelType="html" label="MapPartitionsRDD [8969] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24477 { id="cluster_24477"; isCluster="true"; label="DeserializeToObject"; 8970 [id="node_8970" labelType="html" label="MapPartitionsRDD [8970] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24476 { id="cluster_24476"; isCluster="true"; label="MapPartitions"; 8971 [id="node_8971" labelType="html" label="MapPartitionsRDD [8971] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24473 { id="cluster_24473"; isCluster="true"; label="WholeStageCodegen (3)"; 8972 [id="node_8972" labelType="html" label="MapPartitionsRDD [8972] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24487 { id="cluster_24487"; isCluster="true"; label="map"; 8974 [id="node_8974" labelType="html" label="Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000002108/0_1_10000002108/_delta_log [8974] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24489 { id="cluster_24489"; isCluster="true"; label="WholeStageCodegen (1)"; 8975 [id="node_8975" labelType="html" label="MapPartitionsRDD [8975] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24488 { id="cluster_24488"; isCluster="true"; label="Project"; 8976 [id="node_8976" labelType="html" label="MapPartitionsRDD [8976] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24492 { id="cluster_24492"; isCluster="true"; label="map"; 8978 [id="node_8978" labelType="html" label="Delta Table State with Stats #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000002108/0_1_10000002108/_delta_log [8978] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24493 { id="cluster_24493"; isCluster="true"; label="WholeStageCodegen (1)"; 8979 [id="node_8979" labelType="html" label="MapPartitionsRDD [8979] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24497 { id="cluster_24497"; isCluster="true"; label="mapPartitionsInternal"; 8980 [id="node_8980" labelType="html" label="MapPartitionsRDD [8980] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 8968->8969; 8969->8970; 8970->8971; 8971->8972; 8972->8973; 8973->8974; 8974->8975; 8975->8976; 8976->8977; 8977->8978; 8978->8979; 8979->8980; }

8967,8968

8974

8978

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
3556	tenants-pool-286	Delta: stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 1: Filtering files for query start at FileStorageAdapterImpl.java:177 +details RDD: Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000002108/0_1_10000002108/_delta_log Delta Table State with Stats #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000002108/0_1_10000002108/_delta_log 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:37:59	0.6 s	50/50			2.0 KiB
3555	tenants-pool-286	Delta: stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 1: Filtering files for query 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:37:59	98 ms	1/1				2.0 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

3556

tenants-pool-286

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

RDD: Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000002108/0_1_10000002108/_delta_log Delta Table State with Stats #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000002108/0_1_10000002108/_delta_log

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:37:59

0.6 s

50/50

2.0 KiB

3555

tenants-pool-286

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:37:59

98 ms

1/1

2.0 KiB

Page: