You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2015/03/03 11:28:59 UTC

[45/50] incubator-kylin git commit: only delete related type job when run buildWithEngineTest

only delete related type job when run buildWithEngineTest


Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/1a9556f1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/1a9556f1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/1a9556f1

Branch: refs/heads/master
Commit: 1a9556f1e0f6b882c8d085be803fdbb3d63d2249
Parents: d804e60
Author: jiazhong <ji...@ebay.com>
Authored: Mon Mar 2 17:48:52 2015 +0800
Committer: jiazhong <ji...@ebay.com>
Committed: Mon Mar 2 17:48:52 2015 +0800

----------------------------------------------------------------------
 .../test/java/org/apache/kylin/job/BuildCubeWithEngineTest.java  | 4 +++-
 .../test/java/org/apache/kylin/job/BuildIIWithEngineTest.java    | 4 +++-
 2 files changed, 6 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/1a9556f1/job/src/test/java/org/apache/kylin/job/BuildCubeWithEngineTest.java
----------------------------------------------------------------------
diff --git a/job/src/test/java/org/apache/kylin/job/BuildCubeWithEngineTest.java b/job/src/test/java/org/apache/kylin/job/BuildCubeWithEngineTest.java
index 5e5b191..2a5bacb 100644
--- a/job/src/test/java/org/apache/kylin/job/BuildCubeWithEngineTest.java
+++ b/job/src/test/java/org/apache/kylin/job/BuildCubeWithEngineTest.java
@@ -103,7 +103,9 @@ public class BuildCubeWithEngineTest {
         cubeManager = CubeManager.getInstance(kylinConfig);
         jobEngineConfig = new JobEngineConfig(kylinConfig);
         for (String jobId : jobService.getAllJobIds()) {
-            jobService.deleteJob(jobId);
+            if(jobService.getJob(jobId) instanceof CubingJob){
+                jobService.deleteJob(jobId);
+            }
         }
 
     }

http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/1a9556f1/job/src/test/java/org/apache/kylin/job/BuildIIWithEngineTest.java
----------------------------------------------------------------------
diff --git a/job/src/test/java/org/apache/kylin/job/BuildIIWithEngineTest.java b/job/src/test/java/org/apache/kylin/job/BuildIIWithEngineTest.java
index 01e1d62..840c5db 100644
--- a/job/src/test/java/org/apache/kylin/job/BuildIIWithEngineTest.java
+++ b/job/src/test/java/org/apache/kylin/job/BuildIIWithEngineTest.java
@@ -115,7 +115,9 @@ public class BuildIIWithEngineTest {
         iiManager = IIManager.getInstance(kylinConfig);
         jobEngineConfig = new JobEngineConfig(kylinConfig);
         for (String jobId : jobService.getAllJobIds()) {
-            jobService.deleteJob(jobId);
+            if(jobService.getJob(jobId) instanceof IIJob){
+                jobService.deleteJob(jobId);
+            }
         }
 
         IIInstance ii = iiManager.getII(TEST_II_NAME);