Skip to content

Commit

Permalink
nn enterSafeMode
Browse files Browse the repository at this point in the history
  • Loading branch information
yuyanlei-8130 committed Jul 26, 2023
1 parent ecd493d commit 7222fe5
Showing 1 changed file with 4 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,8 @@
import org.apache.hadoop.hdfs.protocol.BlockListAsLongs;
import org.apache.hadoop.hdfs.server.datanode.DataNode;
import org.apache.hadoop.hdfs.server.namenode.FSNamesystem;
import org.apache.hadoop.hdfs.server.namenode.NameNode;
import org.apache.hadoop.hdfs.server.namenode.NameNodeAdapter;
import org.apache.hadoop.hdfs.server.protocol.BlockReportContext;
import org.apache.hadoop.hdfs.server.protocol.DatanodeCommand;
import org.apache.hadoop.hdfs.server.protocol.DatanodeRegistration;
Expand Down Expand Up @@ -282,8 +284,9 @@ public void testFirstIncompleteBlockReport() throws Exception {

FSNamesystem fsn = cluster.getNamesystem();

NameNode nameNode = cluster.getNameNode();
// pretend to be in safemode
doReturn(true).when(fsn).isInStartupSafeMode();
NameNodeAdapter.enterSafeMode(nameNode, false);

BlockManager blockManager = fsn.getBlockManager();
BlockManager spyBlockManager = spy(blockManager);
Expand Down

0 comments on commit 7222fe5

Please sign in to comment.