diff --git a/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt b/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt index 1ddf7da9a22..cc2a8337767 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt +++ b/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt @@ -1084,6 +1084,8 @@ Release 2.8.0 - UNRELEASED HDFS-8810. Correct assertions in TestDFSInotifyEventInputStream class. (Surendra Singh Lilhore via aajisaka) + HDFS-8785. TestDistributedFileSystem is failing in trunk. (Xiaoyu Yao) + Release 2.7.2 - UNRELEASED INCOMPATIBLE CHANGES diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDistributedFileSystem.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDistributedFileSystem.java index 0b77210a762..6012c5dfc6a 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDistributedFileSystem.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDistributedFileSystem.java @@ -1189,19 +1189,22 @@ public class TestDistributedFileSystem { try { cluster.waitActive(); DistributedFileSystem dfs = cluster.getFileSystem(); - // Write 1 MB to a dummy socket to ensure the write times out + // Write 10 MB to a dummy socket to ensure the write times out ServerSocket socket = new ServerSocket(0); Peer peer = dfs.getClient().newConnectedPeer( (InetSocketAddress) socket.getLocalSocketAddress(), null, null); long start = Time.now(); try { - byte[] buf = new byte[1024 * 1024]; + byte[] buf = new byte[10 * 1024 * 1024]; peer.getOutputStream().write(buf); - Assert.fail("write should timeout"); + long delta = Time.now() - start; + Assert.fail("write finish in " + delta + " ms" + "but should timedout"); } catch (SocketTimeoutException ste) { long delta = Time.now() - start; - Assert.assertTrue("write timedout too soon", delta >= timeout * 0.9); - Assert.assertTrue("write timedout too late", delta <= timeout * 1.1); + Assert.assertTrue("write timedout too soon in " + delta + " ms", + delta >= timeout * 0.9); + Assert.assertTrue("write timedout too late in " + delta + " ms", + delta <= timeout * 1.2); } catch (Throwable t) { Assert.fail("wrong exception:" + t); }