No DAG visualization information to display for job 127263
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 3727537 | tenants-pool-169 | stream-10000001452-1
id = d8095b92-94ab-46e0-9c45-70c2545e39e1
runId = f82340b3-4413-4826-9fdb-37fdaa6940fe
batch = 69 start at FileStorageAdapterImpl.java:598 org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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/07/22 20:37:10 | 8 ms |
1/1
| 2.1 KiB | |||
| 3727536 | tenants-pool-169 | stream-10000001452-1
id = d8095b92-94ab-46e0-9c45-70c2545e39e1
runId = f82340b3-4413-4826-9fdb-37fdaa6940fe
batch = 69 start at FileStorageAdapterImpl.java:598
RDD: ObjectHashAggregate(keys=[shardId#15070782, resultSeparationId#15074661L], functions=[collect_list(orderProposal#15072925, 0, 0)], output=[shardId#15070782, resultSeparationId#15074661L, orderProposals#15074665])
+- Exchange hashpartitioning(shardId#15070782, resultSeparationId#15074661L, 30), ENSURE_REQUIREMENTS, [plan_id=7843912]
+- ObjectHashAggregate(keys=[shardId#15070782, resultSeparationId#15074661L], functions=[partial_collect_list(orderProposal#15072925, 0, 0)], output=[shardId#15070782, resultSeparationId#15074661L, buf#15074701])
+- Project [shardId#15070782, orderProposal#15072925, CASE WHEN (size(orderProposal#15072925.parentItems, true) > 2000) THEN xxhash64(orderProposal#15072925.orderProposalId, 42) ELSE xxhash64(pmod(cast(orderProposal#15072925.orderProposalId as decimal(20,0)), 0), 42) END AS resultSeparationId#15074661L]
+- InMemoryTableScan [orderProposal#15072925, shardId#15070782]
+- InMemoryRelation [shardId#15070782, orderProposal#15072925], StorageL...
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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/07/22 20:37:10 | 72 ms |
30/30
| 2.1 KiB | |||
| 3727535 | tenants-pool-169 | stream-10000001452-1
id = d8095b92-94ab-46e0-9c45-70c2545e39e1
runId = f82340b3-4413-4826-9fdb-37fdaa6940fe
batch = 69 start at FileStorageAdapterImpl.java:598
RDD: Project [shardId#15070782, named_struct(orderProposalId, _extract_orderProposalId#15073573L, originalReplenishmentRunId, _extract_originalReplenishmentRunId#15073565L, supplierGroup, _extract_supplierGroup#15073566, optimizationGroups, coalesce(optimizationGroups#15072818, []), supplier, _extract_supplier#15073567, supplyingPlant, _extract_supplyingPlant#15073568, orderDateTime, _extract_orderDateTime#15073569, itemGroups, _extract_itemGroups#15073570, previousOrderProposals, _extract_previousOrderProposals#15073571, parentItems, _extract_parentItems#15073572) AS orderProposal#15072925]
+- BroadcastHashJoin [coalesce(shardId#15070782, ), isnull(shardId#15070782), coalesce(_extract_orderProposalId#15073573L, 0), isnull(_extract_orderProposalId#15073573L)], [coalesce(shardId#15072821, ), isnull(shardId#15072821), coalesce(orderProposalId#15072822L, 0), isnull(orderProposalId#15072822L)], LeftOuter, BuildRight, false
:- Project [shardId#15070782, orderProposal#15072808.orderProposalId AS _extract_orderProp...
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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/07/22 20:37:09 | 0.3 s |
30/30
| 630.0 B |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 3727534 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727533 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727532 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727531 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727530 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727529 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727528 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727527 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727526 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727525 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727524 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727523 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727522 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727521 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727520 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727519 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727518 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727517 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727516 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727515 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727514 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727513 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727512 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727511 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727510 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727509 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727508 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727507 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727506 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727505 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727504 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727503 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727502 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727501 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727500 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727499 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727498 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727497 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727496 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727495 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727494 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727493 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727492 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727491 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727490 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727489 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727488 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727487 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727486 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727485 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727484 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727483 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727482 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727481 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727480 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727479 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727478 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727477 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727476 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727475 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727474 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727473 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727472 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727471 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727470 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727469 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727468 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727467 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727466 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727465 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727464 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727463 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727462 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727461 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727460 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727459 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727458 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727457 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727456 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727455 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727454 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727453 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727452 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727451 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727450 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727449 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727448 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727447 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727446 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727445 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727444 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727443 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727442 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727441 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727440 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727439 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727438 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727437 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727436 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3727435 | Unknown Unknown | Unknown | Unknown |
0/0
|