This is an automated email from the ASF dual-hosted git repository. pingsutw pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/submarine.git
The following commit(s) were added to refs/heads/master by this push: new 46a6f07 SUBMARINE-1236. Fix patch strategy 46a6f07 is described below commit 46a6f079e79fac188a990dbda4f2449673d9f439 Author: KUAN-HSUN-LI <b06209...@ntu.edu.tw> AuthorDate: Tue Mar 29 01:08:02 2022 +0800 SUBMARINE-1236. Fix patch strategy ### What is this PR for? There are four patch strategies in the k8s generic API. Replace the `PATCH_FORMAT_JSON_PATCH` with `PATCH_FORMAT_APPLY_YAML`. ### What type of PR is it? [Bug Fix] ### Todos * [x] - Task ### What is the Jira issue? https://issues.apache.org/jira/browse/SUBMARINE-1236 ### How should this be tested? ### Screenshots (if appropriate) ### Questions: * Do the license files need updating? No * Are there breaking changes for older versions? No * Does this need new documentation? No Author: KUAN-HSUN-LI <b06209...@ntu.edu.tw> Signed-off-by: Kevin Su <pings...@apache.org> Closes #915 from KUAN-HSUN-LI/SUBMARINE-1236 and squashes the following commits: 506a6440 [KUAN-HSUN-LI] SUBMARINE-1236. fix patch strategy --- .../apache/submarine/server/submitter/k8s/K8sSubmitter.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/submarine-server/server-submitter/submitter-k8s/src/main/java/org/apache/submarine/server/submitter/k8s/K8sSubmitter.java b/submarine-server/server-submitter/submitter-k8s/src/main/java/org/apache/submarine/server/submitter/k8s/K8sSubmitter.java index 81a34bc..d9e8680 100644 --- a/submarine-server/server-submitter/submitter-k8s/src/main/java/org/apache/submarine/server/submitter/k8s/K8sSubmitter.java +++ b/submarine-server/server-submitter/submitter-k8s/src/main/java/org/apache/submarine/server/submitter/k8s/K8sSubmitter.java @@ -320,10 +320,10 @@ public class K8sSubmitter implements Submitter { mlJob.getMetadata().setNamespace(getServerNamespace()); Object object = mlJob.getPlural().equals(TFJob.CRD_TF_PLURAL_V1) ? tfJobClient.patch(getServerNamespace(), mlJob.getMetadata().getName(), - V1Patch.PATCH_FORMAT_JSON_PATCH, + V1Patch.PATCH_FORMAT_APPLY_YAML, new V1Patch(new Gson().toJson(((TFJob) mlJob).getSpec()))).throwsApiException().getObject() : pyTorchJobClient.patch(getServerNamespace(), mlJob.getMetadata().getName(), - V1Patch.PATCH_FORMAT_JSON_PATCH, + V1Patch.PATCH_FORMAT_APPLY_YAML, new V1Patch(new Gson().toJson(((PyTorchJob) mlJob).getSpec()))).throwsApiException().getObject() ; experiment = parseExperimentResponseObject(object, ParseOp.PARSE_OP_RESULT); @@ -341,12 +341,12 @@ public class K8sSubmitter implements Submitter { try { MLJob mlJob = ExperimentSpecParser.parseJob(spec); mlJob.getMetadata().setNamespace(getServerNamespace()); - + AgentPod agentPod = new AgentPod(getServerNamespace(), spec.getMeta().getName(), mlJob.getPlural().equals(TFJob.CRD_TF_PLURAL_V1) ? CustomResourceType.TFJob : CustomResourceType.PyTorchJob, spec.getMeta().getExperimentId()); - + Object object = mlJob.getPlural().equals(TFJob.CRD_TF_PLURAL_V1) ? tfJobClient.delete(getServerNamespace(), mlJob.getMetadata().getName(), MLJobConverter.toDeleteOptionsFromMLJob(mlJob)) @@ -354,7 +354,7 @@ public class K8sSubmitter implements Submitter { : pyTorchJobClient.delete(getServerNamespace(), mlJob.getMetadata().getName(), MLJobConverter.toDeleteOptionsFromMLJob(mlJob)) .throwsApiException().getStatus(); - + LOG.info(String.format("Experiment:%s had been deleted, start to delete agent pod:%s", spec.getMeta().getName(), agentPod.getMetadata().getName())); podClient.delete(agentPod.getMetadata().getNamespace(), agentPod.getMetadata().getName()); --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscr...@submarine.apache.org For additional commands, e-mail: dev-h...@submarine.apache.org