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 2017/09/16 00:11:46 UTC
kylin git commit: minor,
try to make DefaultSchedulerTest.testDiscard() more stable
Repository: kylin
Updated Branches:
refs/heads/ranger 108e93c60 -> 87ccbc3a6
minor, try to make DefaultSchedulerTest.testDiscard() more stable
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/87ccbc3a
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/87ccbc3a
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/87ccbc3a
Branch: refs/heads/ranger
Commit: 87ccbc3a6edfa9282c4f801d80f66089d7375c4a
Parents: 108e93c
Author: Li Yang <li...@apache.org>
Authored: Sat Sep 16 08:11:27 2017 +0800
Committer: Li Yang <li...@apache.org>
Committed: Sat Sep 16 08:11:27 2017 +0800
----------------------------------------------------------------------
.../org/apache/kylin/job/impl/threadpool/DefaultSchedulerTest.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/87ccbc3a/core-job/src/test/java/org/apache/kylin/job/impl/threadpool/DefaultSchedulerTest.java
----------------------------------------------------------------------
diff --git a/core-job/src/test/java/org/apache/kylin/job/impl/threadpool/DefaultSchedulerTest.java b/core-job/src/test/java/org/apache/kylin/job/impl/threadpool/DefaultSchedulerTest.java
index 1aa2f4f..6a14a04 100644
--- a/core-job/src/test/java/org/apache/kylin/job/impl/threadpool/DefaultSchedulerTest.java
+++ b/core-job/src/test/java/org/apache/kylin/job/impl/threadpool/DefaultSchedulerTest.java
@@ -109,6 +109,7 @@ public class DefaultSchedulerTest extends BaseSchedulerTest {
SelfStopExecutable task1 = new SelfStopExecutable();
job.addTask(task1);
jobService.addJob(job);
+ Thread.sleep(1100);
waitForJobStatus(job.getId(), ExecutableState.RUNNING, 500);
jobService.discardJob(job.getId());
waitForJobFinish(job.getId());