diff --git a/pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go b/pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go index 2c228cb3838..ee5e7a400f9 100644 --- a/pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go +++ b/pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go @@ -2493,7 +2493,7 @@ func setup(t *testing.T, args *config.DynamicResourcesArgs, nodes []*v1.Node, cl // is synced, we need to wait until HasSynced of the handler returns // true, this ensures that the assume cache is in sync with the informer's // store which has been informed by at least one full LIST of the underlying storage. - cache.WaitForCacheSync(tc.ctx.Done(), registeredHandler.HasSynced) + cache.WaitForCacheSync(tc.ctx.Done(), registeredHandler.HasSynced, resourceSliceTracker.HasSynced) for _, node := range nodes { nodeInfo := framework.NewNodeInfo() diff --git a/staging/src/k8s.io/dynamic-resource-allocation/structured/internal/experimental/allocator_experimental.go b/staging/src/k8s.io/dynamic-resource-allocation/structured/internal/experimental/allocator_experimental.go index c6d701748c9..bacd669ff29 100644 --- a/staging/src/k8s.io/dynamic-resource-allocation/structured/internal/experimental/allocator_experimental.go +++ b/staging/src/k8s.io/dynamic-resource-allocation/structured/internal/experimental/allocator_experimental.go @@ -145,7 +145,7 @@ func (a *Allocator) Allocate(ctx context.Context, node *v1.Node, claims []*resou result: make([]internalAllocationResult, len(claims)), allocatingCapacity: NewConsumedCapacityCollection(), } - alloc.logger.V(5).Info("Starting allocation", "numClaims", len(alloc.claimsToAllocate)) + alloc.logger.V(5).Info("Starting allocation", "numClaims", len(alloc.claimsToAllocate), "numSlices", len(alloc.slices)) defer func() { alloc.logger.V(5).Info("Done with allocation", "success", len(finalResult) == len(alloc.claimsToAllocate), "err", finalErr) }() diff --git a/staging/src/k8s.io/dynamic-resource-allocation/structured/internal/incubating/allocator_incubating.go b/staging/src/k8s.io/dynamic-resource-allocation/structured/internal/incubating/allocator_incubating.go index 9b1bac3e33a..c49d7ebd5ec 100644 --- a/staging/src/k8s.io/dynamic-resource-allocation/structured/internal/incubating/allocator_incubating.go +++ b/staging/src/k8s.io/dynamic-resource-allocation/structured/internal/incubating/allocator_incubating.go @@ -116,7 +116,7 @@ func (a *Allocator) Allocate(ctx context.Context, node *v1.Node, claims []*resou requestData: make(map[requestIndices]requestData), result: make([]internalAllocationResult, len(claims)), } - alloc.logger.V(5).Info("Starting allocation", "numClaims", len(alloc.claimsToAllocate)) + alloc.logger.V(5).Info("Starting allocation", "numClaims", len(alloc.claimsToAllocate), "numSlices", len(alloc.slices)) defer func() { alloc.logger.V(5).Info("Done with allocation", "success", len(finalResult) == len(alloc.claimsToAllocate), "err", finalErr) }()