Repository: lens Updated Branches: refs/heads/master cc1e1fced -> 4fea0c4a2
LENS-1042: TestEventService.testSesionHandleEvent fails intermittently Project: http://git-wip-us.apache.org/repos/asf/lens/repo Commit: http://git-wip-us.apache.org/repos/asf/lens/commit/4fea0c4a Tree: http://git-wip-us.apache.org/repos/asf/lens/tree/4fea0c4a Diff: http://git-wip-us.apache.org/repos/asf/lens/diff/4fea0c4a Branch: refs/heads/master Commit: 4fea0c4a2854434ad98949692e632c905705130f Parents: cc1e1fc Author: Raju Bairishetti <r...@apache.org> Authored: Thu Jun 16 15:04:08 2016 +0530 Committer: Rajat Khandelwal <rajatgupt...@gmail.com> Committed: Thu Jun 16 15:04:08 2016 +0530 ---------------------------------------------------------------------- .../lens/server/query/TestEventService.java | 19 ++++++++++++------- 1 file changed, 12 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/lens/blob/4fea0c4a/lens-server/src/test/java/org/apache/lens/server/query/TestEventService.java ---------------------------------------------------------------------- diff --git a/lens-server/src/test/java/org/apache/lens/server/query/TestEventService.java b/lens-server/src/test/java/org/apache/lens/server/query/TestEventService.java index 573d388..50baf5f 100644 --- a/lens-server/src/test/java/org/apache/lens/server/query/TestEventService.java +++ b/lens-server/src/test/java/org/apache/lens/server/query/TestEventService.java @@ -485,13 +485,8 @@ public class TestEventService { // Catch all listener just to make sure that the query accepted and // query exec stat events get through final CountDownLatch latch = new CountDownLatch(2); - service.addListenerForType(new LensEventListener<LensEvent>() { - @Override - public void onEvent(LensEvent event) throws LensException { - System.out.println("@@@@ Got Event: Type= " + event.getClass().getName() + " obj = " + event); - latch.countDown(); - } - }, LensEvent.class); + LensEventListener<LensEvent> eventListener = queryEventListener(latch); + service.addListenerForType(eventListener, LensEvent.class); QueryHandle queryHandle = new QueryHandle(UUID.randomUUID()); QueryAccepted queryAccepted = new QueryAccepted(System.currentTimeMillis(), "beforeAccept", "afterAccept", @@ -503,7 +498,17 @@ public class TestEventService { service.notifyEvent(queryExecStats); latch.await(); + service.removeListener(eventListener); + } + private LensEventListener<LensEvent> queryEventListener(final CountDownLatch latch) { + return new LensEventListener<LensEvent>() { + @Override + public void onEvent(LensEvent event) throws LensException { + System.out.println("@@@@ Got Event: Type= " + event.getClass().getName() + " obj = " + event); + latch.countDown(); + } + }; } @Test
