No DAG visualization information to display for job 18484
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 331630 | tenants-pool-506 | replenishmentRunId = 10000000532 tenantId = 8793759653749352888 activityType = TriggerOptimize activityId = 816a962c-9701-3546-9a27-a794a6fe9034 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = f3b2bce7-ec80-32a1-a2d1-e9d18d4ce5c9 attempt = 1 cornerstoneTenantId = 8445 marketUnit = 10000_OP_PERF scenario = STANDARD $anonfun$withThreadLocalCaptured$2 at <unknown>:0 org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) 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:07 | 9 ms |
1/1
| ||||
| 331629 | tenants-pool-506 | replenishmentRunId = 10000000532 tenantId = 8793759653749352888 activityType = TriggerOptimize activityId = 816a962c-9701-3546-9a27-a794a6fe9034 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = f3b2bce7-ec80-32a1-a2d1-e9d18d4ce5c9 attempt = 1 cornerstoneTenantId = 8445 marketUnit = 10000_OP_PERF scenario = STANDARD $anonfun$withThreadLocalCaptured$2 at <unknown>:0
RDD: AdaptiveSparkPlan isFinalPlan=false
+- Project [shardId#3185444, worklistShardItemId#3185445L, product#3185459, plant#3185460, availabilityDateTime#3185466 AS periodStart#3188653, nextAvailabilityDateTime#3185467 AS periodEnd#3188654, 0 AS version#3188652, null AS qty#3188655]
+- InMemoryTableScan [availabilityDateTime#3185466, nextAvailabilityDateTime#3185467, plant#3185460, product#3185459, shardId#3185444, worklistShardItemId#3185445L]
+- InMemoryRelation [shardId#3185444, worklistShardItemId#3185445L, orderProposalId#3185446L, orderProposalItemId#3185447, orderProposalItemGroupId#3185448, originalReplenishmentRunId#3185449L, orderProposalHorizonGroupingId#3185450L, splitIndicator#3185451L, previousOrderProposal#3185452L, clusterId#3185453L, sequenceId#3185454L, sourceOfSupplyUuid#3185455, supplierGroup#3185456, supplier#3185457, subrange#3185458, product#3185459, plant#3185460, purchasingOrg#3185461, purchasingGroup#3185462, mrpController#3185463, orderDateTime#3185464, deliveryDateTime#318...
org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) 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:07 | 0.2 s |
37/37
| 3.6 MiB | 2.2 KiB |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 331628 | Unknown Unknown | Unknown | Unknown |
0/0
|