fix bug

tomscut · tomscut · commit 0b1946bd7012 · 2022-04-13T14:55:58.000+08:00
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java
@@ -1940,7 +1940,7 @@ public boolean isInStandbyState() {
 
   public boolean isInObserverState() {
     if (haContext == null || haContext.getState() == null) {
-      return haEnabled;
+      return false;
     }
 
     return HAServiceState.OBSERVER == haContext.getState().getServiceState();

Original file line number	Diff line number	Diff line change
`@@ -1940,7 +1940,7 @@ public boolean isInStandbyState() {`
`1940`	`1940`
`1941`	`1941`	`public boolean isInObserverState() {`
`1942`	`1942`	`if (haContext == null \|\| haContext.getState() == null) {`
`1943`		`- return haEnabled;`
	`1943`	`+ return false;`
`1944`	`1944`	`}`
`1945`	`1945`
`1946`	`1946`	`return HAServiceState.OBSERVER == haContext.getState().getServiceState();`