diff --git a/hadoop-common-project/hadoop-common/CHANGES.txt b/hadoop-common-project/hadoop-common/CHANGES.txt index cd9e1fb609d..cd6576c2475 100644 --- a/hadoop-common-project/hadoop-common/CHANGES.txt +++ b/hadoop-common-project/hadoop-common/CHANGES.txt @@ -967,6 +967,9 @@ Release 2.7.3 - UNRELEASED HADOOP-12107. long running apps may have a huge number of StatisticsData instances under FileSystem (Sangjin Lee via Ming Ma) + HADOOP-12706. TestLocalFsFCStatistics#testStatisticsThreadLocalDataCleanUp + times out occasionally (Sangjin Lee and Colin Patrick McCabe via jlowe) + Release 2.7.2 - UNRELEASED INCOMPATIBLE CHANGES @@ -1791,6 +1794,9 @@ Release 2.6.4 - UNRELEASED HADOOP-12107. long running apps may have a huge number of StatisticsData instances under FileSystem (Sangjin Lee via Ming Ma) + HADOOP-12706. TestLocalFsFCStatistics#testStatisticsThreadLocalDataCleanUp + times out occasionally (Sangjin Lee and Colin Patrick McCabe via jlowe) + Release 2.6.3 - 2015-12-17 INCOMPATIBLE CHANGES diff --git a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/FCStatisticsBaseTest.java b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/FCStatisticsBaseTest.java index 3e33362be21..2e208d21762 100644 --- a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/FCStatisticsBaseTest.java +++ b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/FCStatisticsBaseTest.java @@ -32,6 +32,8 @@ import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; import org.apache.hadoop.fs.FileSystem.Statistics; import org.apache.hadoop.test.GenericTestUtils; import org.junit.Assert; @@ -46,6 +48,8 @@ import com.google.common.util.concurrent.Uninterruptibles; *
*/ public abstract class FCStatisticsBaseTest { + private static final Log LOG = LogFactory.getLog(FCStatisticsBaseTest.class); + static protected int blockSize = 512; static protected int numBlocks = 1; @@ -110,7 +114,7 @@ public abstract class FCStatisticsBaseTest { fc.delete(filePath, true); } - @Test(timeout=60000) + @Test(timeout=70000) public void testStatisticsThreadLocalDataCleanUp() throws Exception { final Statistics stats = new Statistics("test"); // create a small thread pool to test the statistics @@ -137,17 +141,24 @@ public abstract class FCStatisticsBaseTest { es.shutdownNow(); es.awaitTermination(1, TimeUnit.MINUTES); es = null; - System.gc(); + System.gc(); // force GC to garbage collect threads - // wait for up to 10 seconds + // wait for up to 60 seconds GenericTestUtils.waitFor(new Supplier