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

Status: SUCCEEDED
Submitted: 2026/08/31 14:22:03
Duration: 5 s
Associated SQL Query: 13517
Job Group: 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d
Completed Stages: 4

Enable zooming

digraph G { id="graph_341138"; subgraph graph_stage_341138 { id="graph_stage_341138"; isCluster="true"; label="Stage 341138"; 154082 [id="node_154082" labelType="html" label="SQLExecutionRDD [154082] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_385389 { id="cluster_385389"; isCluster="true"; label="Scan parquet "; 154079 [id="node_154079" labelType="html" label="FileScanRDD [154079] start at FileStorageAdapterImpl.java:596}"]; 154080 [id="node_154080" labelType="html" label="MapPartitionsRDD [154080] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385386 { id="cluster_385386"; isCluster="true"; label="WholeStageCodegen (1)"; 154081 [id="node_154081" labelType="html" label="MapPartitionsRDD [154081] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385404 { id="cluster_385404"; isCluster="true"; label="WholeStageCodegen (1)"; 154083 [id="node_154083" labelType="html" label="MapPartitionsRDD [154083] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385403 { id="cluster_385403"; isCluster="true"; label="HashAggregate"; 154084 [id="node_154084" labelType="html" label="MapPartitionsRDD [154084] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385402 { id="cluster_385402"; isCluster="true"; label="Exchange"; 154085 [id="node_154085" labelType="html" label="MapPartitionsRDD [154085] start at FileStorageAdapterImpl.java:596}"]; } } 154079->154080; 154080->154081; 154081->154082; 154082->154083; 154083->154084; 154084->154085; }

digraph G { id="graph_341139"; subgraph graph_stage_341139 { id="graph_stage_341139"; isCluster="true"; label="Stage 341139"; subgraph cluster_385402 { id="cluster_385402"; isCluster="true"; label="Exchange"; 154086 [id="node_154086" labelType="html" label="ShuffledRowRDD [154086] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385399 { id="cluster_385399"; isCluster="true"; label="WholeStageCodegen (2)"; 154087 [id="node_154087" labelType="html" label="MapPartitionsRDD [154087] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385398 { id="cluster_385398"; isCluster="true"; label="Exchange"; 154088 [id="node_154088" labelType="html" label="MapPartitionsRDD [154088] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154086->154087; 154087->154088; }

154085,154086

digraph G { id="graph_341140"; subgraph graph_stage_341140 { id="graph_stage_341140"; isCluster="true"; label="Stage 341140"; subgraph cluster_385398 { id="cluster_385398"; isCluster="true"; label="Exchange"; 154089 [id="node_154089" labelType="html" label="ShuffledRowRDD [154089] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385397 { id="cluster_385397"; isCluster="true"; label="InMemoryTableScan"; 154090 [id="node_154090" labelType="html" label="MapPartitionsRDD [154090] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154091 [id="node_154091" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3614461L, 30), REPARTITION_BY_NUM, [plan_id=1034705]\n+- *(2) HashAggregate(keys=[demandChannel#3614464, shardId#3614460, kpis#3614466, version#3614462, qty#3614463, worklistShardItemId#3614461L, demandStream#3614465], functions=[], output=[shardId#3614460, worklistShardItemId#3614461L, version#3614462, qty#3614463, demandChannel#3614464, demandStream#3614465, kpis#3614466])\n +- Exchange hashpartitioning(demandChannel#3614464, shardId#3614460, kpis#3614466, version#3614462, qty#3614463, worklistShardItemId#3614461L, demandStream#3614465, 30), ENSURE_REQUIREMENTS, [plan_id=1034701]\n +- HashAggregate(keys=[demandChannel#3614464, shardId#3614460, knownfloatingpointnormalized(transform(kpis#3614466, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3614876)) null else named_struct(label, lambda arg#3614876.label, dateTime, lambda arg#3614876.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3614876.value)))), lambda ... [154091] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154092 [id="node_154092" labelType="html" label="MapPartitionsRDD [154092] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154093 [id="node_154093" labelType="html" label="MapPartitionsRDD [154093] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154094 [id="node_154094" labelType="html" label="MapPartitionsRDD [154094] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385394 { id="cluster_385394"; isCluster="true"; label="WholeStageCodegen (1)"; 154095 [id="node_154095" labelType="html" label="MapPartitionsRDD [154095] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385393 { id="cluster_385393"; isCluster="true"; label="Exchange"; 154096 [id="node_154096" labelType="html" label="MapPartitionsRDD [154096] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154089->154090; 154090->154091; 154091->154092; 154092->154093; 154093->154094; 154094->154095; 154095->154096; }

154088,154089

154091

digraph G { id="graph_341141"; subgraph graph_stage_341141 { id="graph_stage_341141"; isCluster="true"; label="Stage 341141"; subgraph cluster_385393 { id="cluster_385393"; isCluster="true"; label="Exchange"; 154097 [id="node_154097" labelType="html" label="ShuffledRowRDD [154097] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385390 { id="cluster_385390"; isCluster="true"; label="WholeStageCodegen (2)"; 154098 [id="node_154098" labelType="html" label="MapPartitionsRDD [154098] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385406 { id="cluster_385406"; isCluster="true"; label="mapPartitionsInternal"; 154099 [id="node_154099" labelType="html" label="MapPartitionsRDD [154099] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154097->154098; 154098->154099; }

154096,154097

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
341141	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d batch = 17 start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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/31 14:22:08	0.1 s	30/30	2.8 KiB
341140	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d batch = 17 start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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/31 14:22:06	1 s	30/30	16.2 MiB	2.8 KiB
341139	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d batch = 17 start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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/31 14:22:06	0.6 s	30/30	15.8 MiB	16.2 MiB
341138	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d batch = 17 start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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/31 14:22:03	2 s	30/30		15.8 MiB

Page: