summaryrefslogtreecommitdiff
path: root/cloud/pkg/edgecontroller/controller/upstream.go
diff options
context:
space:
mode:
Diffstat (limited to 'cloud/pkg/edgecontroller/controller/upstream.go')
-rw-r--r--cloud/pkg/edgecontroller/controller/upstream.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/cloud/pkg/edgecontroller/controller/upstream.go b/cloud/pkg/edgecontroller/controller/upstream.go
index 4fea9b162..c276cf458 100644
--- a/cloud/pkg/edgecontroller/controller/upstream.go
+++ b/cloud/pkg/edgecontroller/controller/upstream.go
@@ -297,7 +297,7 @@ func (uc *UpstreamController) updatePodStatus() {
case model.UpdateOperation:
for _, podStatus := range podStatuses {
getPod, err := uc.kubeClient.CoreV1().Pods(namespace).Get(context.Background(), podStatus.Name, metaV1.GetOptions{})
- if errors.IsNotFound(err) {
+ if (err == nil && getPod.UID != podStatus.UID) || errors.IsNotFound(err) {
klog.Warningf("message: %s, pod not found, namespace: %s, name: %s", msg.GetID(), namespace, podStatus.Name)
// Send request to delete this pod on edge side