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

Status: SUCCEEDED
Submitted: 2026/05/22 09:09:17
Duration: 2 s
Associated SQL Query: 24549
Job Group: 10d36e12-5b96-4752-9e6b-ca062fdd8807
Completed Stages: 4

Enable zooming

digraph G { id="graph_1268403"; subgraph graph_stage_1268403 { id="graph_stage_1268403"; isCluster="true"; label="Stage 1268403"; 332776 [id="node_332776" labelType="html" label="SQLExecutionRDD [332776] start at FileStorageAdapterImpl.java:567}"]; subgraph cluster_855995 { id="cluster_855995"; isCluster="true"; label="Scan parquet "; 332773 [id="node_332773" labelType="html" label="FileScanRDD [332773] start at FileStorageAdapterImpl.java:567}"]; 332774 [id="node_332774" labelType="html" label="MapPartitionsRDD [332774] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_855992 { id="cluster_855992"; isCluster="true"; label="WholeStageCodegen (1)"; 332775 [id="node_332775" labelType="html" label="MapPartitionsRDD [332775] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_856010 { id="cluster_856010"; isCluster="true"; label="WholeStageCodegen (1)"; 332777 [id="node_332777" labelType="html" label="MapPartitionsRDD [332777] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_856009 { id="cluster_856009"; isCluster="true"; label="HashAggregate"; 332778 [id="node_332778" labelType="html" label="MapPartitionsRDD [332778] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_856008 { id="cluster_856008"; isCluster="true"; label="Exchange"; 332779 [id="node_332779" labelType="html" label="MapPartitionsRDD [332779] start at FileStorageAdapterImpl.java:567}"]; } } 332773->332774; 332774->332775; 332775->332776; 332776->332777; 332777->332778; 332778->332779; }

digraph G { id="graph_1268404"; subgraph graph_stage_1268404 { id="graph_stage_1268404"; isCluster="true"; label="Stage 1268404"; subgraph cluster_856008 { id="cluster_856008"; isCluster="true"; label="Exchange"; 332780 [id="node_332780" labelType="html" label="ShuffledRowRDD [332780] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_856005 { id="cluster_856005"; isCluster="true"; label="WholeStageCodegen (2)"; 332781 [id="node_332781" labelType="html" label="MapPartitionsRDD [332781] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_856004 { id="cluster_856004"; isCluster="true"; label="Exchange"; 332782 [id="node_332782" labelType="html" label="MapPartitionsRDD [332782] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 332780->332781; 332781->332782; }

332779,332780

digraph G { id="graph_1268405"; subgraph graph_stage_1268405 { id="graph_stage_1268405"; isCluster="true"; label="Stage 1268405"; subgraph cluster_856004 { id="cluster_856004"; isCluster="true"; label="Exchange"; 332783 [id="node_332783" labelType="html" label="ShuffledRowRDD [332783] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_856003 { id="cluster_856003"; isCluster="true"; label="InMemoryTableScan"; 332784 [id="node_332784" labelType="html" label="MapPartitionsRDD [332784] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 332785 [id="node_332785" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#5176552L, 30), REPARTITION_BY_NUM, [plan_id=2621347]\n+- *(2) HashAggregate(keys=[demandChannel#5176555, shardId#5176551, kpis#5176557, version#5176553, qty#5176554, worklistShardItemId#5176552L, demandStream#5176556], functions=[], output=[shardId#5176551, worklistShardItemId#5176552L, version#5176553, qty#5176554, demandChannel#5176555, demandStream#5176556, kpis#5176557])\n +- Exchange hashpartitioning(demandChannel#5176555, shardId#5176551, kpis#5176557, version#5176553, qty#5176554, worklistShardItemId#5176552L, demandStream#5176556, 30), ENSURE_REQUIREMENTS, [plan_id=2621343]\n +- HashAggregate(keys=[demandChannel#5176555, shardId#5176551, knownfloatingpointnormalized(transform(kpis#5176557, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#5619265)) null else named_struct(label, lambda arg#5619265.label, dateTime, lambda arg#5619265.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#5619265.value)))), lambda ... [332785] [Cached] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 332786 [id="node_332786" labelType="html" label="MapPartitionsRDD [332786] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 332787 [id="node_332787" labelType="html" label="MapPartitionsRDD [332787] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 332788 [id="node_332788" labelType="html" label="MapPartitionsRDD [332788] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_856000 { id="cluster_856000"; isCluster="true"; label="WholeStageCodegen (1)"; 332789 [id="node_332789" labelType="html" label="MapPartitionsRDD [332789] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_855999 { id="cluster_855999"; isCluster="true"; label="Exchange"; 332790 [id="node_332790" labelType="html" label="MapPartitionsRDD [332790] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 332783->332784; 332784->332785; 332785->332786; 332786->332787; 332787->332788; 332788->332789; 332789->332790; }

332782,332783

332785

digraph G { id="graph_1268406"; subgraph graph_stage_1268406 { id="graph_stage_1268406"; isCluster="true"; label="Stage 1268406"; subgraph cluster_855999 { id="cluster_855999"; isCluster="true"; label="Exchange"; 332791 [id="node_332791" labelType="html" label="ShuffledRowRDD [332791] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_855996 { id="cluster_855996"; isCluster="true"; label="WholeStageCodegen (2)"; 332792 [id="node_332792" labelType="html" label="MapPartitionsRDD [332792] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_856012 { id="cluster_856012"; isCluster="true"; label="mapPartitionsInternal"; 332793 [id="node_332793" labelType="html" label="MapPartitionsRDD [332793] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 332791->332792; 332792->332793; }

332790,332791

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1268406	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 40 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/05/22 09:09:18	0.1 s	30/30	576.0 B
1268405	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 40 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/05/22 09:09:17	0.5 s	30/30	17.7 KiB	576.0 B
1268404	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 40 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/05/22 09:09:17	0.2 s	30/30	19.7 KiB	17.7 KiB
1268403	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 40 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/05/22 09:09:17	0.7 s	23/23		19.7 KiB

Page: