force json serializer

Signed-off-by: yue9944882 <291271447@qq.com>
kubernetes-sigs · Apr 3, 2022 · b92d8aa · b92d8aa
1 parent c4fc6d0
commit b92d8aa
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/pkg/experimental/storage/mysql/kine.go b/pkg/experimental/storage/mysql/kine.go
@@ -4,12 +4,13 @@ package mysql
 import (
 	"context"
 	"fmt"
-	"k8s.io/apimachinery/pkg/runtime"
-	"k8s.io/apimachinery/pkg/runtime/serializer"
 	"time"
 
 	"github.com/k3s-io/kine/pkg/endpoint"
+	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/runtime/schema"
+	"k8s.io/apimachinery/pkg/runtime/serializer"
+	"k8s.io/apimachinery/pkg/runtime/serializer/json"
 	"k8s.io/apiserver/pkg/registry/generic"
 	genericregistry "k8s.io/apiserver/pkg/registry/generic/registry"
 	"k8s.io/apiserver/pkg/storage/storagebackend"
@@ -60,8 +61,9 @@ func (g *kineProxiedRESTOptionsGetter) GetRESTOptions(resource schema.GroupResou
 	if err != nil {
 		return generic.RESTOptions{}, err
 	}
+	s := json.NewSerializer(json.DefaultMetaFactory, g.scheme, g.scheme, false)
 	codec := serializer.NewCodecFactory(g.scheme).
-		CodecForVersions(nil, nil, g.groupVersioner, g.groupVersioner)
+		CodecForVersions(s, s, g.groupVersioner, g.groupVersioner)
 	restOptions := generic.RESTOptions{
 		ResourcePrefix:            resource.String(),
 		Decorator:                 genericregistry.StorageWithCacher(),