debug: delete using foreground

apache · Nov 27, 2023 · 1cc346f · 1cc346f
1 parent 08a387a
commit 1cc346f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/computer-k8s/src/main/java/org/apache/hugegraph/computer/k8s/driver/KubernetesDriver.java b/computer-k8s/src/main/java/org/apache/hugegraph/computer/k8s/driver/KubernetesDriver.java
@@ -39,6 +39,7 @@
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ConcurrentHashMap;
 
+import io.fabric8.kubernetes.api.model.DeletionPropagation;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.io.FileUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -282,7 +283,7 @@ private void checkComputerConf(Map<String, String> computerConf,
 
     @Override
     public boolean cancelJob(String jobId, Map<String, String> params) {
-        return this.operation.withName(KubeUtil.crName(jobId)).delete();
+        return this.operation.withName(KubeUtil.crName(jobId)).withPropagationPolicy(DeletionPropagation.FOREGROUND).delete();
     }
 
     @Override

diff --git a/computer-test/src/main/java/org/apache/hugegraph/computer/k8s/MiniKubeTest.java b/computer-test/src/main/java/org/apache/hugegraph/computer/k8s/MiniKubeTest.java
@@ -243,7 +243,7 @@ public void testJobCancelled() {
                                                                   jobObserver);
 
         DefaultJobState jobState = new DefaultJobState();
-        jobState.jobStatus(JobStatus.RUNNING);
+        jobState.jobStatus(JobStatus.INITIALIZING);
         Mockito.verify(jobObserver, Mockito.timeout(15000L).atLeast(1))
                .onJobStateChanged(Mockito.eq(jobState));