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

Status: SUCCEEDED
Submitted: 2026/08/31 14:16:41
Duration: 3 s
Associated SQL Query: 13313
Job Group: 9672435e-271f-4f72-bc82-76031aa42a7a
Completed Stages: 4

Enable zooming

digraph G { id="graph_331974"; subgraph graph_stage_331974 { id="graph_stage_331974"; isCluster="true"; label="Stage 331974"; 151663 [id="node_151663" labelType="html" label="SQLExecutionRDD [151663] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_379404 { id="cluster_379404"; isCluster="true"; label="Scan parquet "; 151660 [id="node_151660" labelType="html" label="FileScanRDD [151660] start at FileStorageAdapterImpl.java:596}"]; 151661 [id="node_151661" labelType="html" label="MapPartitionsRDD [151661] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379401 { id="cluster_379401"; isCluster="true"; label="WholeStageCodegen (1)"; 151662 [id="node_151662" labelType="html" label="MapPartitionsRDD [151662] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379419 { id="cluster_379419"; isCluster="true"; label="WholeStageCodegen (1)"; 151664 [id="node_151664" labelType="html" label="MapPartitionsRDD [151664] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379418 { id="cluster_379418"; isCluster="true"; label="HashAggregate"; 151665 [id="node_151665" labelType="html" label="MapPartitionsRDD [151665] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379417 { id="cluster_379417"; isCluster="true"; label="Exchange"; 151666 [id="node_151666" labelType="html" label="MapPartitionsRDD [151666] start at FileStorageAdapterImpl.java:596}"]; } } 151660->151661; 151661->151662; 151662->151663; 151663->151664; 151664->151665; 151665->151666; }

digraph G { id="graph_331975"; subgraph graph_stage_331975 { id="graph_stage_331975"; isCluster="true"; label="Stage 331975"; subgraph cluster_379417 { id="cluster_379417"; isCluster="true"; label="Exchange"; 151667 [id="node_151667" labelType="html" label="ShuffledRowRDD [151667] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379414 { id="cluster_379414"; isCluster="true"; label="WholeStageCodegen (2)"; 151668 [id="node_151668" labelType="html" label="MapPartitionsRDD [151668] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379413 { id="cluster_379413"; isCluster="true"; label="Exchange"; 151669 [id="node_151669" labelType="html" label="MapPartitionsRDD [151669] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 151667->151668; 151668->151669; }

151666,151667

digraph G { id="graph_331976"; subgraph graph_stage_331976 { id="graph_stage_331976"; isCluster="true"; label="Stage 331976"; subgraph cluster_379413 { id="cluster_379413"; isCluster="true"; label="Exchange"; 151670 [id="node_151670" labelType="html" label="ShuffledRowRDD [151670] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379412 { id="cluster_379412"; isCluster="true"; label="InMemoryTableScan"; 151671 [id="node_151671" labelType="html" label="MapPartitionsRDD [151671] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151672 [id="node_151672" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3571687L, 30), REPARTITION_BY_NUM, [plan_id=1021777]\n+- *(2) HashAggregate(keys=[demandChannel#3571690, shardId#3571686, kpis#3571692, version#3571688, qty#3571689, worklistShardItemId#3571687L, demandStream#3571691], functions=[], output=[shardId#3571686, worklistShardItemId#3571687L, version#3571688, qty#3571689, demandChannel#3571690, demandStream#3571691, kpis#3571692])\n +- Exchange hashpartitioning(demandChannel#3571690, shardId#3571686, kpis#3571692, version#3571688, qty#3571689, worklistShardItemId#3571687L, demandStream#3571691, 30), ENSURE_REQUIREMENTS, [plan_id=1021773]\n +- HashAggregate(keys=[demandChannel#3571690, shardId#3571686, knownfloatingpointnormalized(transform(kpis#3571692, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3571800)) null else named_struct(label, lambda arg#3571800.label, dateTime, lambda arg#3571800.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3571800.value)))), lambda ... [151672] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151673 [id="node_151673" labelType="html" label="MapPartitionsRDD [151673] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151674 [id="node_151674" labelType="html" label="MapPartitionsRDD [151674] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151675 [id="node_151675" labelType="html" label="MapPartitionsRDD [151675] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379409 { id="cluster_379409"; isCluster="true"; label="WholeStageCodegen (1)"; 151676 [id="node_151676" labelType="html" label="MapPartitionsRDD [151676] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379408 { id="cluster_379408"; isCluster="true"; label="Exchange"; 151677 [id="node_151677" labelType="html" label="MapPartitionsRDD [151677] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 151670->151671; 151671->151672; 151672->151673; 151673->151674; 151674->151675; 151675->151676; 151676->151677; }

151669,151670

151672

digraph G { id="graph_331977"; subgraph graph_stage_331977 { id="graph_stage_331977"; isCluster="true"; label="Stage 331977"; subgraph cluster_379408 { id="cluster_379408"; isCluster="true"; label="Exchange"; 151678 [id="node_151678" labelType="html" label="ShuffledRowRDD [151678] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379405 { id="cluster_379405"; isCluster="true"; label="WholeStageCodegen (2)"; 151679 [id="node_151679" labelType="html" label="MapPartitionsRDD [151679] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379421 { id="cluster_379421"; isCluster="true"; label="mapPartitionsInternal"; 151680 [id="node_151680" labelType="html" label="MapPartitionsRDD [151680] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 151678->151679; 151679->151680; }

151677,151678

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
331977	tenants-pool-506	stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 9672435e-271f-4f72-bc82-76031aa42a7a batch = 19 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	80 ms	30/30	2.8 KiB
331976	tenants-pool-506	stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 9672435e-271f-4f72-bc82-76031aa42a7a batch = 19 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.6 s	30/30	15.2 MiB	2.8 KiB
331975	tenants-pool-506	stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 9672435e-271f-4f72-bc82-76031aa42a7a batch = 19 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	0.4 s	30/30	14.9 MiB	15.2 MiB
331974	tenants-pool-506	stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 9672435e-271f-4f72-bc82-76031aa42a7a batch = 19 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:41	1 s	30/30		14.9 MiB

Page: