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

Status: SUCCEEDED
Submitted: 2026/08/31 14:17:16
Duration: 5 s
Associated SQL Query: 13338
Job Group: 1a176cce-65e1-41cf-a934-767a2c6b038c
Completed Stages: 4

Enable zooming

digraph G { id="graph_332809"; subgraph graph_stage_332809 { id="graph_stage_332809"; isCluster="true"; label="Stage 332809"; 151937 [id="node_151937" labelType="html" label="SQLExecutionRDD [151937] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_379938 { id="cluster_379938"; isCluster="true"; label="Scan parquet "; 151934 [id="node_151934" labelType="html" label="FileScanRDD [151934] start at FileStorageAdapterImpl.java:596}"]; 151935 [id="node_151935" labelType="html" label="MapPartitionsRDD [151935] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379935 { id="cluster_379935"; isCluster="true"; label="WholeStageCodegen (1)"; 151936 [id="node_151936" labelType="html" label="MapPartitionsRDD [151936] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379953 { id="cluster_379953"; isCluster="true"; label="WholeStageCodegen (1)"; 151938 [id="node_151938" labelType="html" label="MapPartitionsRDD [151938] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379952 { id="cluster_379952"; isCluster="true"; label="HashAggregate"; 151939 [id="node_151939" labelType="html" label="MapPartitionsRDD [151939] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379951 { id="cluster_379951"; isCluster="true"; label="Exchange"; 151940 [id="node_151940" labelType="html" label="MapPartitionsRDD [151940] start at FileStorageAdapterImpl.java:596}"]; } } 151934->151935; 151935->151936; 151936->151937; 151937->151938; 151938->151939; 151939->151940; }

digraph G { id="graph_332810"; subgraph graph_stage_332810 { id="graph_stage_332810"; isCluster="true"; label="Stage 332810"; subgraph cluster_379951 { id="cluster_379951"; isCluster="true"; label="Exchange"; 151941 [id="node_151941" labelType="html" label="ShuffledRowRDD [151941] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379948 { id="cluster_379948"; isCluster="true"; label="WholeStageCodegen (2)"; 151942 [id="node_151942" labelType="html" label="MapPartitionsRDD [151942] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379947 { id="cluster_379947"; isCluster="true"; label="Exchange"; 151943 [id="node_151943" labelType="html" label="MapPartitionsRDD [151943] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 151941->151942; 151942->151943; }

151940,151941

digraph G { id="graph_332811"; subgraph graph_stage_332811 { id="graph_stage_332811"; isCluster="true"; label="Stage 332811"; subgraph cluster_379947 { id="cluster_379947"; isCluster="true"; label="Exchange"; 151944 [id="node_151944" labelType="html" label="ShuffledRowRDD [151944] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379946 { id="cluster_379946"; isCluster="true"; label="InMemoryTableScan"; 151945 [id="node_151945" labelType="html" label="MapPartitionsRDD [151945] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151946 [id="node_151946" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3572038L, 30), REPARTITION_BY_NUM, [plan_id=1022926]\n+- *(2) HashAggregate(keys=[demandChannel#3572041, shardId#3572037, kpis#3572043, version#3572039, qty#3572040, worklistShardItemId#3572038L, demandStream#3572042], functions=[], output=[shardId#3572037, worklistShardItemId#3572038L, version#3572039, qty#3572040, demandChannel#3572041, demandStream#3572042, kpis#3572043])\n +- Exchange hashpartitioning(demandChannel#3572041, shardId#3572037, kpis#3572043, version#3572039, qty#3572040, worklistShardItemId#3572038L, demandStream#3572042, 30), ENSURE_REQUIREMENTS, [plan_id=1022922]\n +- HashAggregate(keys=[demandChannel#3572041, shardId#3572037, knownfloatingpointnormalized(transform(kpis#3572043, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3575089)) null else named_struct(label, lambda arg#3575089.label, dateTime, lambda arg#3575089.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3575089.value)))), lambda ... [151946] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151947 [id="node_151947" labelType="html" label="MapPartitionsRDD [151947] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151948 [id="node_151948" labelType="html" label="MapPartitionsRDD [151948] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151949 [id="node_151949" labelType="html" label="MapPartitionsRDD [151949] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379943 { id="cluster_379943"; isCluster="true"; label="WholeStageCodegen (1)"; 151950 [id="node_151950" labelType="html" label="MapPartitionsRDD [151950] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379942 { id="cluster_379942"; isCluster="true"; label="Exchange"; 151951 [id="node_151951" labelType="html" label="MapPartitionsRDD [151951] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 151944->151945; 151945->151946; 151946->151947; 151947->151948; 151948->151949; 151949->151950; 151950->151951; }

151943,151944

151946

digraph G { id="graph_332812"; subgraph graph_stage_332812 { id="graph_stage_332812"; isCluster="true"; label="Stage 332812"; subgraph cluster_379942 { id="cluster_379942"; isCluster="true"; label="Exchange"; 151952 [id="node_151952" labelType="html" label="ShuffledRowRDD [151952] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379939 { id="cluster_379939"; isCluster="true"; label="WholeStageCodegen (2)"; 151953 [id="node_151953" labelType="html" label="MapPartitionsRDD [151953] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379955 { id="cluster_379955"; isCluster="true"; label="mapPartitionsInternal"; 151954 [id="node_151954" labelType="html" label="MapPartitionsRDD [151954] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 151952->151953; 151953->151954; }

151951,151952

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
332812	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 1a176cce-65e1-41cf-a934-767a2c6b038c 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:17:20	1 s	30/30	2.8 KiB
332811	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 1a176cce-65e1-41cf-a934-767a2c6b038c 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:17:18	2 s	30/30	16.2 MiB	2.8 KiB
332810	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 1a176cce-65e1-41cf-a934-767a2c6b038c 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:17:17	0.4 s	30/30	15.8 MiB	16.2 MiB
332809	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 1a176cce-65e1-41cf-a934-767a2c6b038c 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:17:16	1 s	30/30		15.8 MiB

Page: