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

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

Enable zooming

digraph G { id="graph_332009"; subgraph graph_stage_332009 { id="graph_stage_332009"; isCluster="true"; label="Stage 332009"; 151719 [id="node_151719" labelType="html" label="SQLExecutionRDD [151719] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_379477 { id="cluster_379477"; isCluster="true"; label="Scan parquet "; 151716 [id="node_151716" labelType="html" label="FileScanRDD [151716] start at FileStorageAdapterImpl.java:596}"]; 151717 [id="node_151717" labelType="html" label="MapPartitionsRDD [151717] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379474 { id="cluster_379474"; isCluster="true"; label="WholeStageCodegen (1)"; 151718 [id="node_151718" labelType="html" label="MapPartitionsRDD [151718] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379492 { id="cluster_379492"; isCluster="true"; label="WholeStageCodegen (1)"; 151720 [id="node_151720" labelType="html" label="MapPartitionsRDD [151720] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379491 { id="cluster_379491"; isCluster="true"; label="HashAggregate"; 151721 [id="node_151721" labelType="html" label="MapPartitionsRDD [151721] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379490 { id="cluster_379490"; isCluster="true"; label="Exchange"; 151722 [id="node_151722" labelType="html" label="MapPartitionsRDD [151722] start at FileStorageAdapterImpl.java:596}"]; } } 151716->151717; 151717->151718; 151718->151719; 151719->151720; 151720->151721; 151721->151722; }

digraph G { id="graph_332010"; subgraph graph_stage_332010 { id="graph_stage_332010"; isCluster="true"; label="Stage 332010"; subgraph cluster_379490 { id="cluster_379490"; isCluster="true"; label="Exchange"; 151723 [id="node_151723" labelType="html" label="ShuffledRowRDD [151723] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379487 { id="cluster_379487"; isCluster="true"; label="WholeStageCodegen (2)"; 151724 [id="node_151724" labelType="html" label="MapPartitionsRDD [151724] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379486 { id="cluster_379486"; isCluster="true"; label="Exchange"; 151725 [id="node_151725" labelType="html" label="MapPartitionsRDD [151725] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 151723->151724; 151724->151725; }

151722,151723

digraph G { id="graph_332011"; subgraph graph_stage_332011 { id="graph_stage_332011"; isCluster="true"; label="Stage 332011"; subgraph cluster_379486 { id="cluster_379486"; isCluster="true"; label="Exchange"; 151726 [id="node_151726" labelType="html" label="ShuffledRowRDD [151726] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379485 { id="cluster_379485"; isCluster="true"; label="InMemoryTableScan"; 151727 [id="node_151727" labelType="html" label="MapPartitionsRDD [151727] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151728 [id="node_151728" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3572038L, 30), REPARTITION_BY_NUM, [plan_id=1021944]\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=1021940]\n +- HashAggregate(keys=[demandChannel#3572041, shardId#3572037, knownfloatingpointnormalized(transform(kpis#3572043, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3572584)) null else named_struct(label, lambda arg#3572584.label, dateTime, lambda arg#3572584.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3572584.value)))), lambda ... [151728] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151729 [id="node_151729" labelType="html" label="MapPartitionsRDD [151729] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151730 [id="node_151730" labelType="html" label="MapPartitionsRDD [151730] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151731 [id="node_151731" labelType="html" label="MapPartitionsRDD [151731] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379482 { id="cluster_379482"; isCluster="true"; label="WholeStageCodegen (1)"; 151732 [id="node_151732" labelType="html" label="MapPartitionsRDD [151732] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379481 { id="cluster_379481"; isCluster="true"; label="Exchange"; 151733 [id="node_151733" labelType="html" label="MapPartitionsRDD [151733] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 151726->151727; 151727->151728; 151728->151729; 151729->151730; 151730->151731; 151731->151732; 151732->151733; }

151725,151726

151728

digraph G { id="graph_332012"; subgraph graph_stage_332012 { id="graph_stage_332012"; isCluster="true"; label="Stage 332012"; subgraph cluster_379481 { id="cluster_379481"; isCluster="true"; label="Exchange"; 151734 [id="node_151734" labelType="html" label="ShuffledRowRDD [151734] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379478 { id="cluster_379478"; isCluster="true"; label="WholeStageCodegen (2)"; 151735 [id="node_151735" labelType="html" label="MapPartitionsRDD [151735] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379494 { id="cluster_379494"; isCluster="true"; label="mapPartitionsInternal"; 151736 [id="node_151736" labelType="html" label="MapPartitionsRDD [151736] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 151734->151735; 151735->151736; }

151733,151734

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
332012	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 1a176cce-65e1-41cf-a934-767a2c6b038c batch = 16 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:16:49	82 ms	30/30	2.8 KiB
332011	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 1a176cce-65e1-41cf-a934-767a2c6b038c batch = 16 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:16:48	0.6 s	30/30	16.3 MiB	2.8 KiB
332010	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 1a176cce-65e1-41cf-a934-767a2c6b038c batch = 16 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:16:47	0.4 s	30/30	16.0 MiB	16.3 MiB
332009	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 1a176cce-65e1-41cf-a934-767a2c6b038c batch = 16 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:16:45	2 s	30/30		16.0 MiB

Page: