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 2018/02/04 01:44:21 UTC
kylin git commit: minor,
fix DefaultSchedulerTest.testMetaStoreRecover()
Repository: kylin
Updated Branches:
refs/heads/sync 04b322073 -> 76dc04971
minor, fix DefaultSchedulerTest.testMetaStoreRecover()
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/76dc0497
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/76dc0497
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/76dc0497
Branch: refs/heads/sync
Commit: 76dc049717632eaf1f4c80e58ce61fa6081ae24f
Parents: 04b3220
Author: Li Yang <li...@apache.org>
Authored: Sun Feb 4 09:43:53 2018 +0800
Committer: Li Yang <li...@apache.org>
Committed: Sun Feb 4 09:43:53 2018 +0800
----------------------------------------------------------------------
.../apache/kylin/job/impl/threadpool/DefaultSchedulerTest.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/76dc0497/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 d1b7d96..c7c69cd 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
@@ -175,15 +175,15 @@ public class DefaultSchedulerTest extends BaseSchedulerTest {
}
@Test
- public void tesMetaStoreRecover() throws Exception {
+ public void testMetaStoreRecover() throws Exception {
logger.info("tesMetaStoreRecover");
NoErrorStatusExecutable job = new NoErrorStatusExecutable();
ErrorTestExecutable task = new ErrorTestExecutable();
job.addTask(task);
execMgr.addJob(job);
- Thread.sleep(2000);
+ Thread.sleep(2500);
runningJobToError(job.getId());
- Thread.sleep(2000);
+ Thread.sleep(2500);
Assert.assertEquals(ExecutableState.ERROR, execMgr.getOutput(job.getId()).getState());
}