crp-order-qty-opt-service - Fair Scheduler Pool: tenants-pool-286

Fair Scheduler Pool: tenants-pool-286

Summary

Pool Name	Minimum Share	Pool Weight	Active Stages	Running Tasks	SchedulingMode
tenants-pool-286	1	1	5	10	FAIR

Active Stages (5)

Page:

1

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
61653	tenants-pool-286	replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD (kill) $anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details 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/10 09:36:42	Unknown	0/25
61651	tenants-pool-286	replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD (kill) $anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details 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/10 09:36:42	0.1 s	0/22 (1 running)
61650	tenants-pool-286	replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD (kill) $anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details RDD: AdaptiveSparkPlan isFinalPlan=false +- Project [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, ... 19 more fields] +- BroadcastHashJoin [coalesce(supplierGroup#732275, ), isnull(supplierGroup#732275), coalesce(supplier#732276, ), isnull(supplier#732276), coalesce(subrange#732279, ), isnull(subrange#732279), coalesce(plant#732277, ), isnull(plant#732277), coalesce(deliveryDateTime#732278, 1970-01-01 00:00:00), isnull(deliveryDateTime#732278)], [coalesc... 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/10 09:36:42	0.1 s	0/25 (3 running)
61649	tenants-pool-286	replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD (kill) $anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details RDD: AdaptiveSparkPlan isFinalPlan=false +- Project [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, ... 19 more fields] +- BroadcastHashJoin [coalesce(supplierGroup#732275, ), isnull(supplierGroup#732275), coalesce(supplier#732276, ), isnull(supplier#732276), coalesce(subrange#732279, ), isnull(subrange#732279), coalesce(plant#732277, ), isnull(plant#732277), coalesce(deliveryDateTime#732278, 1970-01-01 00:00:00), isnull(deliveryDateTime#732278)], [coalesc... 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/10 09:36:42	0.1 s	0/25 (1 running)
61648	tenants-pool-286	replenishmentRunId = 10000002108 tenantId = 6944346648028224943 activityType = BufferDataSnapShot activityId = eacc6933-3b5e-3a0b-bef3-b3c7a44b3467 workflowType = PrepareDataSnapshotWorkflow workflowId = 5d942c00-d91a-3f58-a025-9a4d3f256810 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD (kill) $anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details 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/10 09:36:42	0.1 s	0/1 (1 running)

Page:

1