diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestBlockScanner.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestBlockScanner.java index fdbcb51ae4502..e1473fb7e9803 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestBlockScanner.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestBlockScanner.java @@ -1004,6 +1004,8 @@ public void testSkipRecentAccessFile() throws Exception { TestScanResultHandler.getInfo(ctx.volumes.get(0)); synchronized (info) { info.shouldRun = true; + info.sem = new Semaphore(1); + info.sem.acquire(); info.notify(); } try { @@ -1017,6 +1019,7 @@ public void testSkipRecentAccessFile() throws Exception { LOG.debug("Timeout for all files are accessed in last period."); } synchronized (info) { + info.sem.release(); info.shouldRun = false; info.notify(); }