@@ -36,6 +36,7 @@ import (
36
36
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
37
37
"k8s.io/apimachinery/pkg/runtime"
38
38
"k8s.io/apimachinery/pkg/runtime/schema"
39
+ "k8s.io/client-go/discovery"
39
40
"k8s.io/client-go/dynamic"
40
41
"k8s.io/client-go/kubernetes"
41
42
"k8s.io/client-go/rest"
@@ -120,8 +121,12 @@ func (gr *GenericResources) Cleanup(aw *arbv1.AppWrapper, awr *arbv1.AppWrapperG
120
121
121
122
_ , apiresourcelist , err := dd .ServerGroupsAndResources ()
122
123
if err != nil {
123
- klog .Errorf ("Error getting supported groups and resources, err=%#v" , err )
124
- return name , gvk , err
124
+ if derr , ok := err .(* discovery.ErrGroupDiscoveryFailed ); ok {
125
+ klog .Warning ("Discovery failed for some groups, %d failing: %v" , len (derr .Groups ), err )
126
+ } else {
127
+ klog .Errorf ("Error getting supported groups and resources, err=%#v" , err )
128
+ return name , gvk , err
129
+ }
125
130
}
126
131
rsrc := mapping .Resource
127
132
for _ , apiresourcegroup := range apiresourcelist {
@@ -233,8 +238,12 @@ func (gr *GenericResources) SyncQueueJob(aw *arbv1.AppWrapper, awr *arbv1.AppWra
233
238
234
239
_ , apiresourcelist , err := dd .ServerGroupsAndResources ()
235
240
if err != nil {
236
- klog .Errorf ("Error getting supported groups and resources, err=%#v" , err )
237
- return []* v1.Pod {}, err
241
+ if derr , ok := err .(* discovery.ErrGroupDiscoveryFailed ); ok {
242
+ klog .Warning ("Discovery failed for some groups, %d failing: %v" , len (derr .Groups ), err )
243
+ } else {
244
+ klog .Errorf ("Error getting supported groups and resources, err=%#v" , err )
245
+ return []* v1.Pod {}, err
246
+ }
238
247
}
239
248
240
249
rsrc := mapping .Resource
0 commit comments