Add debug logs to monitor retry in waitForEmptyEsNode

Author: Hoosein Safdari

operator/es_client.go

@@ -365,8 +365,13 @@ func (c *ESClient) waitForEmptyEsNode(ctx context.Context, pod *v1.Pod) error {
 				default:
 					// Process response as normal if context is not done.
 					var shards []ESShard
-					err := json.Unmarshal(r.Body(), &shards)
+					body := r.Body()
+					c.logger().Debugf("Request to %s/_cat/shards?h=index,ip&format=json status code %d - %s  on %s/%s (%s)",
+						c.Endpoint.String(), r.StatusCode(), string(body[:]), pod.Namespace, pod.Name, podIP)
+					err := json.Unmarshal(body, &shards)
 					if err != nil {
+						c.logger().Debugf("Error unmarshalling ES shards on %s/%s (%s) - %v",
+							pod.Namespace, pod.Name, podIP, err)
 						return true, err
 					}
 					// shardIP := make(map[string]bool)
@@ -382,6 +387,8 @@ func (c *ESClient) waitForEmptyEsNode(ctx context.Context, pod *v1.Pod) error {
 					if remainingShards > 0 {
 						err = c.excludePodIP(pod)
 						if err != nil {
+							c.logger().Debugf("Error with excluding pod ip on %s/%s (%s) - %v",
+								pod.Namespace, pod.Name, podIP, err)
 							return true, err
 						}
 					}