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

Status: SUCCEEDED
Submitted: 2026/08/31 14:17:19
Duration: 5 s
Associated SQL Query: 13344
Job Group: 3bab42a5-b044-4db1-bce4-9536b8a66679
Completed Stages: 4

Enable zooming

digraph G { id="graph_333014"; subgraph graph_stage_333014 { id="graph_stage_333014"; isCluster="true"; label="Stage 333014"; 152007 [id="node_152007" labelType="html" label="SQLExecutionRDD [152007] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_380086 { id="cluster_380086"; isCluster="true"; label="Scan parquet "; 152004 [id="node_152004" labelType="html" label="FileScanRDD [152004] start at FileStorageAdapterImpl.java:596}"]; 152005 [id="node_152005" labelType="html" label="MapPartitionsRDD [152005] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380083 { id="cluster_380083"; isCluster="true"; label="WholeStageCodegen (1)"; 152006 [id="node_152006" labelType="html" label="MapPartitionsRDD [152006] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380101 { id="cluster_380101"; isCluster="true"; label="WholeStageCodegen (1)"; 152008 [id="node_152008" labelType="html" label="MapPartitionsRDD [152008] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380100 { id="cluster_380100"; isCluster="true"; label="HashAggregate"; 152009 [id="node_152009" labelType="html" label="MapPartitionsRDD [152009] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380099 { id="cluster_380099"; isCluster="true"; label="Exchange"; 152010 [id="node_152010" labelType="html" label="MapPartitionsRDD [152010] start at FileStorageAdapterImpl.java:596}"]; } } 152004->152005; 152005->152006; 152006->152007; 152007->152008; 152008->152009; 152009->152010; }

digraph G { id="graph_333015"; subgraph graph_stage_333015 { id="graph_stage_333015"; isCluster="true"; label="Stage 333015"; subgraph cluster_380099 { id="cluster_380099"; isCluster="true"; label="Exchange"; 152011 [id="node_152011" labelType="html" label="ShuffledRowRDD [152011] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380096 { id="cluster_380096"; isCluster="true"; label="WholeStageCodegen (2)"; 152012 [id="node_152012" labelType="html" label="MapPartitionsRDD [152012] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380095 { id="cluster_380095"; isCluster="true"; label="Exchange"; 152013 [id="node_152013" labelType="html" label="MapPartitionsRDD [152013] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 152011->152012; 152012->152013; }

152010,152011

digraph G { id="graph_333016"; subgraph graph_stage_333016 { id="graph_stage_333016"; isCluster="true"; label="Stage 333016"; subgraph cluster_380095 { id="cluster_380095"; isCluster="true"; label="Exchange"; 152014 [id="node_152014" labelType="html" label="ShuffledRowRDD [152014] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380094 { id="cluster_380094"; isCluster="true"; label="InMemoryTableScan"; 152015 [id="node_152015" labelType="html" label="MapPartitionsRDD [152015] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 152016 [id="node_152016" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3571715L, 30), REPARTITION_BY_NUM, [plan_id=1023373]\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=1023369]\n +- HashAggregate(keys=[demandChannel#3571718, shardId#3571714, knownfloatingpointnormalized(transform(kpis#3571720, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3575998)) null else named_struct(label, lambda arg#3575998.label, dateTime, lambda arg#3575998.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3575998.value)))), lambda ... [152016] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 152017 [id="node_152017" labelType="html" label="MapPartitionsRDD [152017] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 152018 [id="node_152018" labelType="html" label="MapPartitionsRDD [152018] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 152019 [id="node_152019" labelType="html" label="MapPartitionsRDD [152019] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380091 { id="cluster_380091"; isCluster="true"; label="WholeStageCodegen (1)"; 152020 [id="node_152020" labelType="html" label="MapPartitionsRDD [152020] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380090 { id="cluster_380090"; isCluster="true"; label="Exchange"; 152021 [id="node_152021" labelType="html" label="MapPartitionsRDD [152021] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 152014->152015; 152015->152016; 152016->152017; 152017->152018; 152018->152019; 152019->152020; 152020->152021; }

152013,152014

152016

digraph G { id="graph_333017"; subgraph graph_stage_333017 { id="graph_stage_333017"; isCluster="true"; label="Stage 333017"; subgraph cluster_380090 { id="cluster_380090"; isCluster="true"; label="Exchange"; 152022 [id="node_152022" labelType="html" label="ShuffledRowRDD [152022] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380087 { id="cluster_380087"; isCluster="true"; label="WholeStageCodegen (2)"; 152023 [id="node_152023" labelType="html" label="MapPartitionsRDD [152023] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380103 { id="cluster_380103"; isCluster="true"; label="mapPartitionsInternal"; 152024 [id="node_152024" labelType="html" label="MapPartitionsRDD [152024] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 152022->152023; 152023->152024; }

152021,152022

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
333017	tenants-pool-506	stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 3bab42a5-b044-4db1-bce4-9536b8a66679 batch = 21 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:23	0.2 s	30/30	2.8 KiB
333016	tenants-pool-506	stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 3bab42a5-b044-4db1-bce4-9536b8a66679 batch = 21 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:22	0.5 s	30/30	12.0 MiB	2.8 KiB
333015	tenants-pool-506	stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 3bab42a5-b044-4db1-bce4-9536b8a66679 batch = 21 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:21	0.7 s	30/30	11.9 MiB	12.0 MiB
333014	tenants-pool-506	stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 3bab42a5-b044-4db1-bce4-9536b8a66679 batch = 21 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:19	2 s	30/30		11.9 MiB

Page: