|
@@ -3681,7 +3681,8 @@ public class FSNamesystem implements Namesystem, FSClusterStats,
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public boolean isPopulatingReplQueues() {
|
|
public boolean isPopulatingReplQueues() {
|
|
- if (!haContext.getState().shouldPopulateReplQueues()) {
|
|
|
|
|
|
+ if (haContext != null && // null during startup!
|
|
|
|
+ !haContext.getState().shouldPopulateReplQueues()) {
|
|
return false;
|
|
return false;
|
|
}
|
|
}
|
|
// safeMode is volatile, and may be set to null at any time
|
|
// safeMode is volatile, and may be set to null at any time
|