diff --git a/pkg/k8shandler/status.go b/pkg/k8shandler/status.go
index f7abb300a..29cf3fae9 100644
--- a/pkg/k8shandler/status.go
+++ b/pkg/k8shandler/status.go
@@ -172,7 +172,9 @@ func updateNodeConditions(clusterName, namespace string, status *api.Elasticsear
 
 			isUnschedulable := false
 			for _, podCondition := range nodePod.Status.Conditions {
-				if podCondition.Type == v1.PodReasonUnschedulable {
+				if podCondition.Type == v1.PodScheduled && podCondition.Status == v1.ConditionFalse {
+					podCondition.Type = v1.PodReasonUnschedulable
+					podCondition.Status = v1.ConditionTrue
 					updatePodUnschedulableCondition(node, podCondition)
 					isUnschedulable = true
 				}