diff --git a/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt b/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt index eeff967e96e..eb2b21e6517 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt +++ b/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt @@ -1015,6 +1015,9 @@ Release 2.9.0 - UNRELEASED HDFS-9621. getListing wrongly associates Erasure Coding policy to pre-existing replicated files under an EC directory. (jing9) + HDFS-9691. TestBlockManagerSafeMode#testCheckSafeMode fails intermittently. + (Mingliang Liu via aajisaka) + Release 2.8.0 - UNRELEASED NEW FEATURES diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/TestBlockManagerSafeMode.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/TestBlockManagerSafeMode.java index ade55748fb4..d9da2c159fa 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/TestBlockManagerSafeMode.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/TestBlockManagerSafeMode.java @@ -137,30 +137,30 @@ public class TestBlockManagerSafeMode { } // PENDING_THRESHOLD -> EXTENSION + Whitebox.setInternalState(bmSafeMode, "extension", Integer.MAX_VALUE); setSafeModeStatus(BMSafeModeStatus.PENDING_THRESHOLD); setBlockSafe(BLOCK_THRESHOLD); bmSafeMode.checkSafeMode(); assertEquals(BMSafeModeStatus.EXTENSION, getSafeModeStatus()); - Whitebox.setInternalState(bmSafeMode, "smmthread", null); // PENDING_THRESHOLD -> OFF + Whitebox.setInternalState(bmSafeMode, "extension", 0); setSafeModeStatus(BMSafeModeStatus.PENDING_THRESHOLD); setBlockSafe(BLOCK_THRESHOLD); - Whitebox.setInternalState(bmSafeMode, "extension", 0); bmSafeMode.checkSafeMode(); assertEquals(BMSafeModeStatus.OFF, getSafeModeStatus()); // stays in EXTENSION - setSafeModeStatus(BMSafeModeStatus.EXTENSION); setBlockSafe(0); + setSafeModeStatus(BMSafeModeStatus.EXTENSION); Whitebox.setInternalState(bmSafeMode, "extension", 0); bmSafeMode.checkSafeMode(); assertEquals(BMSafeModeStatus.EXTENSION, getSafeModeStatus()); // stays in EXTENSION: pending extension period + Whitebox.setInternalState(bmSafeMode, "extension", Integer.MAX_VALUE); setSafeModeStatus(BMSafeModeStatus.EXTENSION); setBlockSafe(BLOCK_THRESHOLD); - Whitebox.setInternalState(bmSafeMode, "extension", Integer.MAX_VALUE); bmSafeMode.checkSafeMode(); assertEquals(BMSafeModeStatus.EXTENSION, getSafeModeStatus()); }