crp-order-qty-opt-service - Details for Job 56536

Status: SUCCEEDED
Submitted: 2026/07/22 02:22:05
Duration: 1 s
Associated SQL Query: 41314
Job Group: 8fdff9a8-5e79-4dc5-83bf-49d519329d02
Completed Stages: 4

Enable zooming

digraph G { id="graph_1573809"; subgraph graph_stage_1573809 { id="graph_stage_1573809"; isCluster="true"; label="Stage 1573809"; 467645 [id="node_467645" labelType="html" label="SQLExecutionRDD [467645] start at FileStorageAdapterImpl.java:598}"]; subgraph cluster_1232429 { id="cluster_1232429"; isCluster="true"; label="Scan parquet "; 467642 [id="node_467642" labelType="html" label="FileScanRDD [467642] start at FileStorageAdapterImpl.java:598}"]; 467643 [id="node_467643" labelType="html" label="MapPartitionsRDD [467643] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232426 { id="cluster_1232426"; isCluster="true"; label="WholeStageCodegen (1)"; 467644 [id="node_467644" labelType="html" label="MapPartitionsRDD [467644] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232444 { id="cluster_1232444"; isCluster="true"; label="WholeStageCodegen (1)"; 467646 [id="node_467646" labelType="html" label="MapPartitionsRDD [467646] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232443 { id="cluster_1232443"; isCluster="true"; label="HashAggregate"; 467647 [id="node_467647" labelType="html" label="MapPartitionsRDD [467647] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232442 { id="cluster_1232442"; isCluster="true"; label="Exchange"; 467648 [id="node_467648" labelType="html" label="MapPartitionsRDD [467648] start at FileStorageAdapterImpl.java:598}"]; } } 467642->467643; 467643->467644; 467644->467645; 467645->467646; 467646->467647; 467647->467648; }

digraph G { id="graph_1573810"; subgraph graph_stage_1573810 { id="graph_stage_1573810"; isCluster="true"; label="Stage 1573810"; subgraph cluster_1232442 { id="cluster_1232442"; isCluster="true"; label="Exchange"; 467649 [id="node_467649" labelType="html" label="ShuffledRowRDD [467649] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232439 { id="cluster_1232439"; isCluster="true"; label="WholeStageCodegen (2)"; 467650 [id="node_467650" labelType="html" label="MapPartitionsRDD [467650] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232438 { id="cluster_1232438"; isCluster="true"; label="Exchange"; 467651 [id="node_467651" labelType="html" label="MapPartitionsRDD [467651] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 467649->467650; 467650->467651; }

467648,467649

digraph G { id="graph_1573811"; subgraph graph_stage_1573811 { id="graph_stage_1573811"; isCluster="true"; label="Stage 1573811"; subgraph cluster_1232438 { id="cluster_1232438"; isCluster="true"; label="Exchange"; 467652 [id="node_467652" labelType="html" label="ShuffledRowRDD [467652] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232437 { id="cluster_1232437"; isCluster="true"; label="InMemoryTableScan"; 467653 [id="node_467653" labelType="html" label="MapPartitionsRDD [467653] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 467654 [id="node_467654" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#6420878L, 30), REPARTITION_BY_NUM, [plan_id=3472027]\n+- *(2) HashAggregate(keys=[demandChannel#6420881, shardId#6420877, kpis#6420883, version#6420879, qty#6420880, worklistShardItemId#6420878L, demandStream#6420882], functions=[], output=[shardId#6420877, worklistShardItemId#6420878L, version#6420879, qty#6420880, demandChannel#6420881, demandStream#6420882, kpis#6420883])\n +- Exchange hashpartitioning(demandChannel#6420881, shardId#6420877, kpis#6420883, version#6420879, qty#6420880, worklistShardItemId#6420878L, demandStream#6420882, 30), ENSURE_REQUIREMENTS, [plan_id=3472023]\n +- HashAggregate(keys=[demandChannel#6420881, shardId#6420877, knownfloatingpointnormalized(transform(kpis#6420883, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#6606992)) null else named_struct(label, lambda arg#6606992.label, dateTime, lambda arg#6606992.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#6606992.value)))), lambda ... [467654] [Cached] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 467655 [id="node_467655" labelType="html" label="MapPartitionsRDD [467655] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 467656 [id="node_467656" labelType="html" label="MapPartitionsRDD [467656] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 467657 [id="node_467657" labelType="html" label="MapPartitionsRDD [467657] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232434 { id="cluster_1232434"; isCluster="true"; label="WholeStageCodegen (1)"; 467658 [id="node_467658" labelType="html" label="MapPartitionsRDD [467658] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232433 { id="cluster_1232433"; isCluster="true"; label="Exchange"; 467659 [id="node_467659" labelType="html" label="MapPartitionsRDD [467659] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 467652->467653; 467653->467654; 467654->467655; 467655->467656; 467656->467657; 467657->467658; 467658->467659; }

467651,467652

467654

digraph G { id="graph_1573812"; subgraph graph_stage_1573812 { id="graph_stage_1573812"; isCluster="true"; label="Stage 1573812"; subgraph cluster_1232433 { id="cluster_1232433"; isCluster="true"; label="Exchange"; 467660 [id="node_467660" labelType="html" label="ShuffledRowRDD [467660] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232430 { id="cluster_1232430"; isCluster="true"; label="WholeStageCodegen (2)"; 467661 [id="node_467661" labelType="html" label="MapPartitionsRDD [467661] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1232446 { id="cluster_1232446"; isCluster="true"; label="mapPartitionsInternal"; 467662 [id="node_467662" labelType="html" label="MapPartitionsRDD [467662] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 467660->467661; 467661->467662; }

467659,467660

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1573812	tenants-pool-679	stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 50 start at FileStorageAdapterImpl.java:598 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/07/22 02:22:06	0.1 s	30/30	95.0 B
1573811	tenants-pool-679	stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 50 start at FileStorageAdapterImpl.java:598 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/07/22 02:22:06	0.4 s	30/30	1309.0 B	95.0 B
1573810	tenants-pool-679	stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 50 start at FileStorageAdapterImpl.java:598 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/07/22 02:22:06	0.1 s	30/30	1708.0 B	1309.0 B
1573809	tenants-pool-679	stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 50 start at FileStorageAdapterImpl.java:598 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/07/22 02:22:05	0.4 s	4/4		1708.0 B

Page: