diff --git a/extended/src/main/java/io/kubernetes/client/extended/kubectl/KubectlPatch.java b/extended/src/main/java/io/kubernetes/client/extended/kubectl/KubectlPatch.java index bce15d4204..283fa3233f 100644 --- a/extended/src/main/java/io/kubernetes/client/extended/kubectl/KubectlPatch.java +++ b/extended/src/main/java/io/kubernetes/client/extended/kubectl/KubectlPatch.java @@ -15,6 +15,7 @@ import io.kubernetes.client.common.KubernetesObject; import io.kubernetes.client.custom.V1Patch; import io.kubernetes.client.extended.kubectl.exception.KubectlException; +import io.kubernetes.client.openapi.ApiException; import io.kubernetes.client.util.ModelMapper; import io.kubernetes.client.util.generic.GenericKubernetesApi; @@ -44,10 +45,22 @@ public ApiType execute() throws KubectlException { refreshDiscovery(); GenericKubernetesApi genericKubernetesApi = getGenericApi(); - if (ModelMapper.isNamespaced(apiTypeClass)) { - return (ApiType) genericKubernetesApi.patch(namespace, name, patchType, patchContent); - } else { - return (ApiType) genericKubernetesApi.patch(name, patchType, patchContent); + try { + if (ModelMapper.isNamespaced(apiTypeClass)) { + return (ApiType) + genericKubernetesApi + .patch(namespace, name, patchType, patchContent) + .throwsApiException() + .getObject(); + } else { + return (ApiType) + genericKubernetesApi + .patch(name, patchType, patchContent) + .throwsApiException() + .getObject(); + } + } catch (ApiException e) { + throw new KubectlException(e); } } }