Repository: kylin Updated Branches: refs/heads/2.1.x 61041d746 -> e87da70e5
minor, fix flaky test ITDistributedSchedulerBaseTest Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/e87da70e Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/e87da70e Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/e87da70e Branch: refs/heads/2.1.x Commit: e87da70e5ae1c185bb2f5f0f9238dfa4f54b3a6c Parents: 61041d7 Author: Hongbin Ma <mahong...@apache.org> Authored: Thu Aug 31 10:57:51 2017 +0800 Committer: Hongbin Ma <mahong...@apache.org> Committed: Thu Aug 31 10:57:51 2017 +0800 ---------------------------------------------------------------------- .../java/org/apache/kylin/job/ITDistributedSchedulerBaseTest.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/e87da70e/kylin-it/src/test/java/org/apache/kylin/job/ITDistributedSchedulerBaseTest.java ---------------------------------------------------------------------- diff --git a/kylin-it/src/test/java/org/apache/kylin/job/ITDistributedSchedulerBaseTest.java b/kylin-it/src/test/java/org/apache/kylin/job/ITDistributedSchedulerBaseTest.java index 1960e32..8eb6675 100644 --- a/kylin-it/src/test/java/org/apache/kylin/job/ITDistributedSchedulerBaseTest.java +++ b/kylin-it/src/test/java/org/apache/kylin/job/ITDistributedSchedulerBaseTest.java @@ -52,6 +52,9 @@ public class ITDistributedSchedulerBaseTest extends BaseTestDistributedScheduler Assert.assertEquals(ExecutableState.SUCCEED, execMgr.getOutput(task2.getId()).getState()); Assert.assertEquals(ExecutableState.SUCCEED, execMgr.getOutput(task3.getId()).getState()); Assert.assertEquals(ExecutableState.SUCCEED, execMgr.getOutput(job.getId()).getState()); + + //wait to make sure lock is release + Thread.sleep(5000); Assert.assertEquals(null, getServerName(segmentId1)); }
