mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-06 02:34:03 +00:00
Handle DeletedFinalStateUnknown in NodeController
This commit is contained in:
parent
4a223efd27
commit
8b7e9d303c
@ -294,7 +294,20 @@ func NewNodeController(
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
node := obj.(*api.Node)
|
node, isNode := obj.(*api.Node)
|
||||||
|
// We can get DeletedFinalStateUnknown instead of *api.Node here and we need to handle that correctly. #34692
|
||||||
|
if !isNode {
|
||||||
|
deletedState, ok := obj.(cache.DeletedFinalStateUnknown)
|
||||||
|
if !ok {
|
||||||
|
glog.Errorf("Received unexpected object: %v", obj)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
node, ok = deletedState.Obj.(*api.Node)
|
||||||
|
if !ok {
|
||||||
|
glog.Errorf("DeletedFinalStateUnknown contained non-Node object: %v", deletedState.Obj)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
}
|
||||||
if err := nc.cidrAllocator.ReleaseCIDR(node); err != nil {
|
if err := nc.cidrAllocator.ReleaseCIDR(node); err != nil {
|
||||||
glog.Errorf("Error releasing CIDR: %v", err)
|
glog.Errorf("Error releasing CIDR: %v", err)
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user