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

Status: SUCCEEDED
Submitted: 2026/05/22 09:32:50
Duration: 2 s
Associated SQL Query: 24786
Job Group: 65cb8160-40af-4a1d-9ef7-845fbd048abf
Completed Stages: 4

Enable zooming

digraph G { id="graph_1275541"; subgraph graph_stage_1275541 { id="graph_stage_1275541"; isCluster="true"; label="Stage 1275541"; 335720 [id="node_335720" labelType="html" label="SQLExecutionRDD [335720] start at FileStorageAdapterImpl.java:567}"]; subgraph cluster_863519 { id="cluster_863519"; isCluster="true"; label="Scan parquet "; 335717 [id="node_335717" labelType="html" label="FileScanRDD [335717] start at FileStorageAdapterImpl.java:567}"]; 335718 [id="node_335718" labelType="html" label="MapPartitionsRDD [335718] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_863516 { id="cluster_863516"; isCluster="true"; label="WholeStageCodegen (1)"; 335719 [id="node_335719" labelType="html" label="MapPartitionsRDD [335719] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_863534 { id="cluster_863534"; isCluster="true"; label="WholeStageCodegen (1)"; 335721 [id="node_335721" labelType="html" label="MapPartitionsRDD [335721] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_863533 { id="cluster_863533"; isCluster="true"; label="HashAggregate"; 335722 [id="node_335722" labelType="html" label="MapPartitionsRDD [335722] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_863532 { id="cluster_863532"; isCluster="true"; label="Exchange"; 335723 [id="node_335723" labelType="html" label="MapPartitionsRDD [335723] start at FileStorageAdapterImpl.java:567}"]; } } 335717->335718; 335718->335719; 335719->335720; 335720->335721; 335721->335722; 335722->335723; }

digraph G { id="graph_1275542"; subgraph graph_stage_1275542 { id="graph_stage_1275542"; isCluster="true"; label="Stage 1275542"; subgraph cluster_863532 { id="cluster_863532"; isCluster="true"; label="Exchange"; 335724 [id="node_335724" labelType="html" label="ShuffledRowRDD [335724] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_863529 { id="cluster_863529"; isCluster="true"; label="WholeStageCodegen (2)"; 335725 [id="node_335725" labelType="html" label="MapPartitionsRDD [335725] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_863528 { id="cluster_863528"; isCluster="true"; label="Exchange"; 335726 [id="node_335726" labelType="html" label="MapPartitionsRDD [335726] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 335724->335725; 335725->335726; }

335723,335724

digraph G { id="graph_1275543"; subgraph graph_stage_1275543 { id="graph_stage_1275543"; isCluster="true"; label="Stage 1275543"; subgraph cluster_863528 { id="cluster_863528"; isCluster="true"; label="Exchange"; 335727 [id="node_335727" labelType="html" label="ShuffledRowRDD [335727] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_863527 { id="cluster_863527"; isCluster="true"; label="InMemoryTableScan"; 335728 [id="node_335728" labelType="html" label="MapPartitionsRDD [335728] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 335729 [id="node_335729" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#5661070L, 30), REPARTITION_BY_NUM, [plan_id=2646450]\n+- *(2) HashAggregate(keys=[demandChannel#5661073, shardId#5661069, kpis#5661075, version#5661071, qty#5661072, worklistShardItemId#5661070L, demandStream#5661074], functions=[], output=[shardId#5661069, worklistShardItemId#5661070L, version#5661071, qty#5661072, demandChannel#5661073, demandStream#5661074, kpis#5661075])\n +- Exchange hashpartitioning(demandChannel#5661073, shardId#5661069, kpis#5661075, version#5661071, qty#5661072, worklistShardItemId#5661070L, demandStream#5661074, 30), ENSURE_REQUIREMENTS, [plan_id=2646446]\n +- HashAggregate(keys=[demandChannel#5661073, shardId#5661069, knownfloatingpointnormalized(transform(kpis#5661075, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#5677857)) null else named_struct(label, lambda arg#5677857.label, dateTime, lambda arg#5677857.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#5677857.value)))), lambda ... [335729] [Cached] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 335730 [id="node_335730" labelType="html" label="MapPartitionsRDD [335730] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 335731 [id="node_335731" labelType="html" label="MapPartitionsRDD [335731] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 335732 [id="node_335732" labelType="html" label="MapPartitionsRDD [335732] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_863524 { id="cluster_863524"; isCluster="true"; label="WholeStageCodegen (1)"; 335733 [id="node_335733" labelType="html" label="MapPartitionsRDD [335733] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_863523 { id="cluster_863523"; isCluster="true"; label="Exchange"; 335734 [id="node_335734" labelType="html" label="MapPartitionsRDD [335734] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 335727->335728; 335728->335729; 335729->335730; 335730->335731; 335731->335732; 335732->335733; 335733->335734; }

335726,335727

335729

digraph G { id="graph_1275544"; subgraph graph_stage_1275544 { id="graph_stage_1275544"; isCluster="true"; label="Stage 1275544"; subgraph cluster_863523 { id="cluster_863523"; isCluster="true"; label="Exchange"; 335735 [id="node_335735" labelType="html" label="ShuffledRowRDD [335735] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_863520 { id="cluster_863520"; isCluster="true"; label="WholeStageCodegen (2)"; 335736 [id="node_335736" labelType="html" label="MapPartitionsRDD [335736] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_863536 { id="cluster_863536"; isCluster="true"; label="mapPartitionsInternal"; 335737 [id="node_335737" labelType="html" label="MapPartitionsRDD [335737] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 335735->335736; 335736->335737; }

335734,335735

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1275544	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 1 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:32:52	0.1 s	30/30	672.0 B
1275543	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 1 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:32:51	0.7 s	30/30	24.3 KiB	672.0 B
1275542	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 1 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:32:51	0.2 s	30/30	26.2 KiB	24.3 KiB
1275541	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 1 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:32:50	0.9 s	27/27		26.2 KiB

Page: