From 9f19fca45fdb91b9b62bc0d7e01c8ca9107c95aa Mon Sep 17 00:00:00 2001
From: Tomas Nozicka <tomas.nozicka@scylladb.com>
Date: Wed, 28 Jul 2021 11:46:04 +0200
Subject: [PATCH] Temporarily force deletion of pods

Until https://github.com/kubernetes/kubernetes/issues/103970 get fixed
---
 pkg/controller/scyllacluster/sync_services.go | 14 +++++---------
 1 file changed, 5 insertions(+), 9 deletions(-)

diff --git a/pkg/controller/scyllacluster/sync_services.go b/pkg/controller/scyllacluster/sync_services.go
index ecdb884d236..3802071efd0 100644
--- a/pkg/controller/scyllacluster/sync_services.go
+++ b/pkg/controller/scyllacluster/sync_services.go
@@ -14,7 +14,6 @@ import (
 	"github.com/scylladb/scylla-operator/pkg/resourceapply"
 	appsv1 "k8s.io/api/apps/v1"
 	corev1 "k8s.io/api/core/v1"
-	policyv1beta1 "k8s.io/api/policy/v1beta1"
 	apierrors "k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	utilerrors "k8s.io/apimachinery/pkg/util/errors"
@@ -244,18 +243,15 @@ func (scc *Controller) syncServices(
 					Name:      svc.Name,
 				},
 			}
-			klog.V(2).InfoS("Evicting the Pod to replace member",
+			klog.V(2).InfoS("Deleting the Pod to replace member",
 				"ScyllaCluster", klog.KObj(sc),
 				"Service", klog.KObj(svc),
 				"Pod", klog.KObj(podMeta),
 			)
-			err = scc.kubeClient.CoreV1().Pods(podMeta.Namespace).Evict(ctx, &policyv1beta1.Eviction{
-				ObjectMeta: metav1.ObjectMeta{
-					Name: podMeta.Name,
-				},
-				DeleteOptions: &metav1.DeleteOptions{
-					PropagationPolicy: &backgroundPropagationPolicy,
-				},
+			// TODO: Revert back to eviction when it's fixed in kubernetes 1.19.z (#732)
+			//       (https://github.com/kubernetes/kubernetes/issues/103970)
+			err = scc.kubeClient.CoreV1().Pods(podMeta.Namespace).Delete(ctx, podMeta.Name, metav1.DeleteOptions{
+				PropagationPolicy: &backgroundPropagationPolicy,
 			})
 			if err != nil {
 				if apierrors.IsNotFound(err) {