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

Status: SUCCEEDED
Submitted: 2026/08/31 14:16:42
Duration: 4 s
Associated SQL Query: 13316
Job Group: 3bab42a5-b044-4db1-bce4-9536b8a66679
Completed Stages: 4

Enable zooming

digraph G { id="graph_331978"; subgraph graph_stage_331978 { id="graph_stage_331978"; isCluster="true"; label="Stage 331978"; 151684 [id="node_151684" labelType="html" label="SQLExecutionRDD [151684] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_379426 { id="cluster_379426"; isCluster="true"; label="Scan parquet "; 151681 [id="node_151681" labelType="html" label="FileScanRDD [151681] start at FileStorageAdapterImpl.java:596}"]; 151682 [id="node_151682" labelType="html" label="MapPartitionsRDD [151682] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379423 { id="cluster_379423"; isCluster="true"; label="WholeStageCodegen (1)"; 151683 [id="node_151683" labelType="html" label="MapPartitionsRDD [151683] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379441 { id="cluster_379441"; isCluster="true"; label="WholeStageCodegen (1)"; 151685 [id="node_151685" labelType="html" label="MapPartitionsRDD [151685] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379440 { id="cluster_379440"; isCluster="true"; label="HashAggregate"; 151686 [id="node_151686" labelType="html" label="MapPartitionsRDD [151686] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379439 { id="cluster_379439"; isCluster="true"; label="Exchange"; 151687 [id="node_151687" labelType="html" label="MapPartitionsRDD [151687] start at FileStorageAdapterImpl.java:596}"]; } } 151681->151682; 151682->151683; 151683->151684; 151684->151685; 151685->151686; 151686->151687; }

digraph G { id="graph_331979"; subgraph graph_stage_331979 { id="graph_stage_331979"; isCluster="true"; label="Stage 331979"; subgraph cluster_379439 { id="cluster_379439"; isCluster="true"; label="Exchange"; 151688 [id="node_151688" labelType="html" label="ShuffledRowRDD [151688] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379436 { id="cluster_379436"; isCluster="true"; label="WholeStageCodegen (2)"; 151689 [id="node_151689" labelType="html" label="MapPartitionsRDD [151689] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379435 { id="cluster_379435"; isCluster="true"; label="Exchange"; 151690 [id="node_151690" labelType="html" label="MapPartitionsRDD [151690] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 151688->151689; 151689->151690; }

151687,151688

digraph G { id="graph_331980"; subgraph graph_stage_331980 { id="graph_stage_331980"; isCluster="true"; label="Stage 331980"; subgraph cluster_379435 { id="cluster_379435"; isCluster="true"; label="Exchange"; 151691 [id="node_151691" labelType="html" label="ShuffledRowRDD [151691] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379434 { id="cluster_379434"; isCluster="true"; label="InMemoryTableScan"; 151692 [id="node_151692" labelType="html" label="MapPartitionsRDD [151692] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151693 [id="node_151693" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3571715L, 30), REPARTITION_BY_NUM, [plan_id=1021857]\n+- *(2) HashAggregate(keys=[demandChannel#3571718, shardId#3571714, kpis#3571720, version#3571716, qty#3571717, worklistShardItemId#3571715L, demandStream#3571719], functions=[], output=[shardId#3571714, worklistShardItemId#3571715L, version#3571716, qty#3571717, demandChannel#3571718, demandStream#3571719, kpis#3571720])\n +- Exchange hashpartitioning(demandChannel#3571718, shardId#3571714, kpis#3571720, version#3571716, qty#3571717, worklistShardItemId#3571715L, demandStream#3571719, 30), ENSURE_REQUIREMENTS, [plan_id=1021853]\n +- HashAggregate(keys=[demandChannel#3571718, shardId#3571714, knownfloatingpointnormalized(transform(kpis#3571720, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3572123)) null else named_struct(label, lambda arg#3572123.label, dateTime, lambda arg#3572123.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3572123.value)))), lambda ... [151693] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151694 [id="node_151694" labelType="html" label="MapPartitionsRDD [151694] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151695 [id="node_151695" labelType="html" label="MapPartitionsRDD [151695] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151696 [id="node_151696" labelType="html" label="MapPartitionsRDD [151696] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379431 { id="cluster_379431"; isCluster="true"; label="WholeStageCodegen (1)"; 151697 [id="node_151697" labelType="html" label="MapPartitionsRDD [151697] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379430 { id="cluster_379430"; isCluster="true"; label="Exchange"; 151698 [id="node_151698" labelType="html" label="MapPartitionsRDD [151698] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 151691->151692; 151692->151693; 151693->151694; 151694->151695; 151695->151696; 151696->151697; 151697->151698; }

151690,151691

151693

digraph G { id="graph_331981"; subgraph graph_stage_331981 { id="graph_stage_331981"; isCluster="true"; label="Stage 331981"; subgraph cluster_379430 { id="cluster_379430"; isCluster="true"; label="Exchange"; 151699 [id="node_151699" labelType="html" label="ShuffledRowRDD [151699] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379427 { id="cluster_379427"; isCluster="true"; label="WholeStageCodegen (2)"; 151700 [id="node_151700" labelType="html" label="MapPartitionsRDD [151700] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379443 { id="cluster_379443"; isCluster="true"; label="mapPartitionsInternal"; 151701 [id="node_151701" labelType="html" label="MapPartitionsRDD [151701] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 151699->151700; 151700->151701; }

151698,151699

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
331981	tenants-pool-506	stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 3bab42a5-b044-4db1-bce4-9536b8a66679 batch = 20 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:46	0.1 s	30/30	2.8 KiB
331980	tenants-pool-506	stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 3bab42a5-b044-4db1-bce4-9536b8a66679 batch = 20 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	1 s	30/30	16.2 MiB	2.8 KiB
331979	tenants-pool-506	stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 3bab42a5-b044-4db1-bce4-9536b8a66679 batch = 20 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:44	0.4 s	30/30	15.9 MiB	16.2 MiB
331978	tenants-pool-506	stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 3bab42a5-b044-4db1-bce4-9536b8a66679 batch = 20 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:42	2 s	30/30		15.9 MiB

Page: