diff --git a/cmd/experimental/kjobctl/pkg/cmd/util/client_getter.go b/cmd/experimental/kjobctl/pkg/cmd/util/client_getter.go index 6b484fc562..6df61a73dd 100644 --- a/cmd/experimental/kjobctl/pkg/cmd/util/client_getter.go +++ b/cmd/experimental/kjobctl/pkg/cmd/util/client_getter.go @@ -18,6 +18,7 @@ package util import ( rayversioned "github.com/ray-project/kuberay/ray-operator/pkg/client/clientset/versioned" + "k8s.io/apimachinery/pkg/runtime" "k8s.io/cli-runtime/pkg/genericclioptions" "k8s.io/cli-runtime/pkg/resource" "k8s.io/client-go/dynamic" @@ -57,6 +58,7 @@ func (cg *clientGetterImpl) K8sClientset() (k8s.Interface, error) { return nil, err } + config.ContentType = runtime.ContentTypeProtobuf clientset, err := k8s.NewForConfig(config) if err != nil { return nil, err diff --git a/cmd/kueuectl/app/util/client_getter.go b/cmd/kueuectl/app/util/client_getter.go index 7e98b1fed1..63f092da93 100644 --- a/cmd/kueuectl/app/util/client_getter.go +++ b/cmd/kueuectl/app/util/client_getter.go @@ -17,6 +17,7 @@ limitations under the License. package util import ( + "k8s.io/apimachinery/pkg/runtime" "k8s.io/cli-runtime/pkg/genericclioptions" "k8s.io/cli-runtime/pkg/resource" k8s "k8s.io/client-go/kubernetes" @@ -65,6 +66,7 @@ func (cg *clientGetterImpl) K8sClientSet() (k8s.Interface, error) { return nil, err } + config.ContentType = runtime.ContentTypeProtobuf clientset, err := k8s.NewForConfig(config) if err != nil { return nil, err