From 6f55338b9b343819d67df1a71c7e6cb0708a01a7 Mon Sep 17 00:00:00 2001 From: Olivier Guennec Date: Thu, 20 Nov 2014 07:38:46 -0800 Subject: [PATCH] Enabling cancellation of PENDING jobs in controller JobManager.java --- job/src/main/java/com/kylinolap/job/JobManager.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/job/src/main/java/com/kylinolap/job/JobManager.java b/job/src/main/java/com/kylinolap/job/JobManager.java index ce1bc58..2f1107f 100644 --- a/job/src/main/java/com/kylinolap/job/JobManager.java +++ b/job/src/main/java/com/kylinolap/job/JobManager.java @@ -149,6 +149,13 @@ public void discardJob(String uuid) throws IOException, CubeIntegrityException, CubeManager.getInstance(config).updateSegmentOnJobDiscard(cube, jobInstance.getRelatedSegment()); } break; + case PENDING: + try { + killRunningJob(jobInstance); + } finally { + CubeManager.getInstance(config).updateSegmentOnJobDiscard(cube, jobInstance.getRelatedSegment()); + } + break; case ERROR: try { for (JobStep jobStep : jobInstance.getSteps()) {