From 390e11e8bf27b37126c24597c46c1ec6b7dd7943 Mon Sep 17 00:00:00 2001 From: "Robert (Bobby) Evans" Date: Mon, 4 Jan 2016 18:08:55 +0000 Subject: [PATCH] STORM-1429: LocalizerTest fix --- .../test/jvm/backtype/storm/localizer/LocalizerTest.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/storm-core/test/jvm/backtype/storm/localizer/LocalizerTest.java b/storm-core/test/jvm/backtype/storm/localizer/LocalizerTest.java index 2b84f2382d0..339ac76a4a3 100644 --- a/storm-core/test/jvm/backtype/storm/localizer/LocalizerTest.java +++ b/storm-core/test/jvm/backtype/storm/localizer/LocalizerTest.java @@ -476,6 +476,10 @@ public void testMultipleKeysOneUser() throws Exception { lrsrcSet = localizer.getUserResources().get(user1); assertEquals("local resource set size wrong", 2, lrsrcSet.getSize()); + long end = System.currentTimeMillis() + 100; + while ((end - System.currentTimeMillis()) >= 0 && keyFile2.exists()) { + Thread.sleep(1); + } assertFalse("blob not deleted", keyFile2.exists()); assertTrue("blob deleted", keyFile.exists()); assertTrue("blob deleted", keyFile3.exists());