Drop cronjob beta API from create command

staging/src/k8s.io/kubectl/pkg/cmd/create/create_cronjob.go

@@ -23,14 +23,12 @@ import (
 	"github.com/spf13/cobra"
 
 	batchv1 "k8s.io/api/batch/v1"
-	batchv1beta1 "k8s.io/api/batch/v1beta1"
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/cli-runtime/pkg/genericclioptions"
 	"k8s.io/cli-runtime/pkg/resource"
 	batchv1client "k8s.io/client-go/kubernetes/typed/batch/v1"
-	batchv1beta1client "k8s.io/client-go/kubernetes/typed/batch/v1beta1"
 	cmdutil "k8s.io/kubectl/pkg/cmd/util"
 	"k8s.io/kubectl/pkg/scheme"
 	"k8s.io/kubectl/pkg/util"
@@ -64,7 +62,6 @@ type CreateCronJobOptions struct {
 
 	Namespace        string
 	EnforceNamespace bool
-	ClientBeta       batchv1beta1client.BatchV1beta1Interface
 	Client           batchv1client.BatchV1Interface
 	DryRunStrategy   cmdutil.DryRunStrategy
 	DryRunVerifier   *resource.DryRunVerifier
@@ -132,34 +129,10 @@ func (o *CreateCronJobOptions) Complete(f cmdutil.Factory, cmd *cobra.Command, a
 	if err != nil {
 		return err
 	}
-
-	// TODO: drop this condition when beta disappears in 1.25
-	clientset, err := f.KubernetesClientSet()
-	if err != nil {
-		return err
-	}
-	resources, err := clientset.Discovery().ServerResourcesForGroupVersion(batchv1.SchemeGroupVersion.String())
-	if err != nil {
-		return fmt.Errorf("failed to discover supported resources: %v", err)
-	}
-	found := false
-	for _, serverResource := range resources.APIResources {
-		if serverResource.Name == "cronjobs" {
-			found = true
-			break
-		}
-	}
-	if found {
 	o.Client, err = batchv1client.NewForConfig(clientConfig)
 	if err != nil {
 		return err
 	}
-	} else {
-		o.ClientBeta, err = batchv1beta1client.NewForConfig(clientConfig)
-		if err != nil {
-			return err
-		}
-	}
 
 	o.Namespace, o.EnforceNamespace, err = f.ToRawKubeConfigLoader().Namespace()
 	if err != nil {
@@ -192,7 +165,6 @@ func (o *CreateCronJobOptions) Complete(f cmdutil.Factory, cmd *cobra.Command, a
 
 // Run performs the execution of 'create cronjob' sub command
 func (o *CreateCronJobOptions) Run() error {
-	if o.Client != nil {
 	cronJob := o.createCronJob()
 	if err := util.CreateOrUpdateAnnotation(o.CreateAnnotation, cronJob, scheme.DefaultJSONEncoder()); err != nil {
 		return err
@@ -219,69 +191,6 @@ func (o *CreateCronJobOptions) Run() error {
 	return o.PrintObj(cronJob)
 }
 
-	// TODO: drop this condition when beta disappears in 1.25
-	cronJobBeta := o.createCronJobBeta()
-	if err := util.CreateOrUpdateAnnotation(o.CreateAnnotation, cronJobBeta, scheme.DefaultJSONEncoder()); err != nil {
-		return err
-	}
-
-	if o.DryRunStrategy != cmdutil.DryRunClient {
-		createOptions := metav1.CreateOptions{}
-		if o.FieldManager != "" {
-			createOptions.FieldManager = o.FieldManager
-		}
-		if o.DryRunStrategy == cmdutil.DryRunServer {
-			if err := o.DryRunVerifier.HasSupport(cronJobBeta.GroupVersionKind()); err != nil {
-				return err
-			}
-			createOptions.DryRun = []string{metav1.DryRunAll}
-		}
-		var err error
-		cronJobBeta, err = o.ClientBeta.CronJobs(o.Namespace).Create(context.TODO(), cronJobBeta, createOptions)
-		if err != nil {
-			return fmt.Errorf("failed to create cronjob: %v", err)
-		}
-	}
-
-	return o.PrintObj(cronJobBeta)
-
-}
-
-func (o *CreateCronJobOptions) createCronJobBeta() *batchv1beta1.CronJob {
-	cronjob := &batchv1beta1.CronJob{
-		TypeMeta: metav1.TypeMeta{APIVersion: batchv1beta1.SchemeGroupVersion.String(), Kind: "CronJob"},
-		ObjectMeta: metav1.ObjectMeta{
-			Name: o.Name,
-		},
-		Spec: batchv1beta1.CronJobSpec{
-			Schedule: o.Schedule,
-			JobTemplate: batchv1beta1.JobTemplateSpec{
-				ObjectMeta: metav1.ObjectMeta{
-					Name: o.Name,
-				},
-				Spec: batchv1.JobSpec{
-					Template: corev1.PodTemplateSpec{
-						Spec: corev1.PodSpec{
-							Containers: []corev1.Container{
-								{
-									Name:    o.Name,
-									Image:   o.Image,
-									Command: o.Command,
-								},
-							},
-							RestartPolicy: corev1.RestartPolicy(o.Restart),
-						},
-					},
-				},
-			},
-		},
-	}
-	if o.EnforceNamespace {
-		cronjob.Namespace = o.Namespace
-	}
-	return cronjob
-}
-
 func (o *CreateCronJobOptions) createCronJob() *batchv1.CronJob {
 	cronjob := &batchv1.CronJob{
 		TypeMeta: metav1.TypeMeta{APIVersion: batchv1.SchemeGroupVersion.String(), Kind: "CronJob"},

staging/src/k8s.io/kubectl/pkg/cmd/create/create_job.go

@@ -23,7 +23,6 @@ import (
 	"github.com/spf13/cobra"
 
 	batchv1 "k8s.io/api/batch/v1"
-	batchv1beta1 "k8s.io/api/batch/v1beta1"
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/runtime"
@@ -194,8 +193,6 @@ func (o *CreateJobOptions) Run() error {
 		switch obj := infos[0].Object.(type) {
 		case *batchv1.CronJob:
 			job = o.createJobFromCronJob(obj)
-		case *batchv1beta1.CronJob:
-			job = o.createJobFromCronJobV1Beta1(obj)
 		default:
 			return fmt.Errorf("unknown object type %T", obj)
 		}
@@ -254,38 +251,6 @@ func (o *CreateJobOptions) createJob() *batchv1.Job {
 	return job
 }
 
-func (o *CreateJobOptions) createJobFromCronJobV1Beta1(cronJob *batchv1beta1.CronJob) *batchv1.Job {
-	annotations := make(map[string]string)
-	annotations["cronjob.kubernetes.io/instantiate"] = "manual"
-	for k, v := range cronJob.Spec.JobTemplate.Annotations {
-		annotations[k] = v
-	}
-
-	job := &batchv1.Job{
-		// this is ok because we know exactly how we want to be serialized
-		TypeMeta: metav1.TypeMeta{APIVersion: batchv1.SchemeGroupVersion.String(), Kind: "Job"},
-		ObjectMeta: metav1.ObjectMeta{
-			Name:        o.Name,
-			Annotations: annotations,
-			Labels:      cronJob.Spec.JobTemplate.Labels,
-			OwnerReferences: []metav1.OwnerReference{
-				{
-					// TODO (soltysh): switch this to v1 in v1.22, when n-1 skew will be fulfilled
-					APIVersion: batchv1beta1.SchemeGroupVersion.String(),
-					Kind:       "CronJob",
-					Name:       cronJob.GetName(),
-					UID:        cronJob.GetUID(),
-				},
-			},
-		},
-		Spec: cronJob.Spec.JobTemplate.Spec,
-	}
-	if o.EnforceNamespace {
-		job.Namespace = o.Namespace
-	}
-	return job
-}
-
 func (o *CreateJobOptions) createJobFromCronJob(cronJob *batchv1.CronJob) *batchv1.Job {
 	annotations := make(map[string]string)
 	annotations["cronjob.kubernetes.io/instantiate"] = "manual"
@@ -302,7 +267,7 @@ func (o *CreateJobOptions) createJobFromCronJob(cronJob *batchv1.CronJob) *batch
 			Labels:      cronJob.Spec.JobTemplate.Labels,
 			OwnerReferences: []metav1.OwnerReference{
 				{
-					APIVersion: batchv1beta1.SchemeGroupVersion.String(),
+					APIVersion: batchv1.SchemeGroupVersion.String(),
 					Kind:       "CronJob",
 					Name:       cronJob.GetName(),
 					UID:        cronJob.GetUID(),

staging/src/k8s.io/kubectl/pkg/cmd/create/create_job_test.go

@@ -21,7 +21,6 @@ import (
 	"testing"
 
 	batchv1 "k8s.io/api/batch/v1"
-	batchv1beta1 "k8s.io/api/batch/v1beta1"
 	corev1 "k8s.io/api/core/v1"
 	apiequality "k8s.io/apimachinery/pkg/api/equality"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -135,72 +134,6 @@ func TestCreateJob(t *testing.T) {
 	}
 }
 
-func TestCreateJobFromCronJobV1Beta1(t *testing.T) {
-	jobName := "test-job"
-	cronJob := &batchv1beta1.CronJob{
-		Spec: batchv1beta1.CronJobSpec{
-			JobTemplate: batchv1beta1.JobTemplateSpec{
-				Spec: batchv1.JobSpec{
-					Template: corev1.PodTemplateSpec{
-						Spec: corev1.PodSpec{
-							Containers: []corev1.Container{
-								{Image: "test-image"},
-							},
-							RestartPolicy: corev1.RestartPolicyNever,
-						},
-					},
-				},
-			},
-		},
-	}
-	tests := map[string]struct {
-		from     *batchv1beta1.CronJob
-		expected *batchv1.Job
-	}{
-		"from CronJob": {
-			from: cronJob,
-			expected: &batchv1.Job{
-				TypeMeta: metav1.TypeMeta{APIVersion: batchv1.SchemeGroupVersion.String(), Kind: "Job"},
-				ObjectMeta: metav1.ObjectMeta{
-					Name:        jobName,
-					Annotations: map[string]string{"cronjob.kubernetes.io/instantiate": "manual"},
-					OwnerReferences: []metav1.OwnerReference{
-						{
-							APIVersion: batchv1beta1.SchemeGroupVersion.String(),
-							Kind:       "CronJob",
-							Name:       cronJob.GetName(),
-							UID:        cronJob.GetUID(),
-						},
-					},
-				},
-				Spec: batchv1.JobSpec{
-					Template: corev1.PodTemplateSpec{
-						Spec: corev1.PodSpec{
-							Containers: []corev1.Container{
-								{Image: "test-image"},
-							},
-							RestartPolicy: corev1.RestartPolicyNever,
-						},
-					},
-				},
-			},
-		},
-	}
-
-	for name, tc := range tests {
-		t.Run(name, func(t *testing.T) {
-			o := &CreateJobOptions{
-				Name: jobName,
-			}
-			job := o.createJobFromCronJobV1Beta1(tc.from)
-
-			if !apiequality.Semantic.DeepEqual(job, tc.expected) {
-				t.Errorf("expected:\n%#v\ngot:\n%#v", tc.expected, job)
-			}
-		})
-	}
-}
-
 func TestCreateJobFromCronJob(t *testing.T) {
 	jobName := "test-job"
 	cronJob := &batchv1.CronJob{
@@ -232,7 +165,7 @@ func TestCreateJobFromCronJob(t *testing.T) {
 					Annotations: map[string]string{"cronjob.kubernetes.io/instantiate": "manual"},
 					OwnerReferences: []metav1.OwnerReference{
 						{
-							APIVersion: batchv1beta1.SchemeGroupVersion.String(),
+							APIVersion: batchv1.SchemeGroupVersion.String(),
 							Kind:       "CronJob",
 							Name:       cronJob.GetName(),
 							UID:        cronJob.GetUID(),