Repository: hadoop Updated Branches: refs/heads/branch-2 f7e597b56 -> bacfd1baa
HADOOP-14472. Azure: TestReadAndSeekPageBlobAfterWrite fails intermittently. Contributed by Mingliang Liu (cherry picked from commit 6b5285bbcb439944ba6c4701571ffbb00258d5a1) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/bacfd1ba Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/bacfd1ba Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/bacfd1ba Branch: refs/heads/branch-2 Commit: bacfd1baae092adecc3c4206415436d1a566d927 Parents: f7e597b Author: Mingliang Liu <[email protected]> Authored: Tue Jun 6 11:06:49 2017 -0700 Committer: Mingliang Liu <[email protected]> Committed: Tue Jun 6 11:07:42 2017 -0700 ---------------------------------------------------------------------- .../fs/azure/TestReadAndSeekPageBlobAfterWrite.java | 10 ---------- 1 file changed, 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/bacfd1ba/hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azure/TestReadAndSeekPageBlobAfterWrite.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azure/TestReadAndSeekPageBlobAfterWrite.java b/hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azure/TestReadAndSeekPageBlobAfterWrite.java index e6219df..41b8386 100644 --- a/hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azure/TestReadAndSeekPageBlobAfterWrite.java +++ b/hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azure/TestReadAndSeekPageBlobAfterWrite.java @@ -275,18 +275,8 @@ public class TestReadAndSeekPageBlobAfterWrite { writesSinceHFlush++; output.flush(); if ((i % SYNC_INTERVAL) == 0) { - long start = Time.monotonicNow(); output.hflush(); writesSinceHFlush = 0; - long end = Time.monotonicNow(); - - // A true, round-trip synchronous flush to Azure must take - // a significant amount of time or we are not syncing to storage correctly. - LOG.debug("hflush duration = " + (end - start) + " msec."); - assertTrue(String.format( - "hflush duration of %d, less than minimum expected of %d", - end - start, MINIMUM_EXPECTED_TIME), - end - start >= MINIMUM_EXPECTED_TIME); } } } finally { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
