|
@@ -52,8 +52,6 @@ import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_SAFEMODE_THRESHO
|
|
|
import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_HA_STANDBY_CHECKPOINTS_DEFAULT;
|
|
|
import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_HA_STANDBY_CHECKPOINTS_KEY;
|
|
|
import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_SHARED_EDITS_DIR_KEY;
|
|
|
-import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_UPGRADE_PERMISSION_DEFAULT;
|
|
|
-import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_UPGRADE_PERMISSION_KEY;
|
|
|
import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_PERMISSIONS_ENABLED_DEFAULT;
|
|
|
import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_PERMISSIONS_ENABLED_KEY;
|
|
|
import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_PERSIST_BLOCKS_KEY;
|
|
@@ -118,7 +116,6 @@ import org.apache.hadoop.fs.permission.FsAction;
|
|
|
import org.apache.hadoop.fs.permission.FsPermission;
|
|
|
import org.apache.hadoop.fs.permission.PermissionStatus;
|
|
|
import org.apache.hadoop.ha.ServiceFailedException;
|
|
|
-import org.apache.hadoop.ha.HAServiceProtocol.HAServiceState;
|
|
|
import org.apache.hadoop.hdfs.DFSUtil;
|
|
|
import org.apache.hadoop.hdfs.HAUtil;
|
|
|
import org.apache.hadoop.hdfs.HdfsConfiguration;
|
|
@@ -267,7 +264,6 @@ public class FSNamesystem implements Namesystem, FSClusterStats,
|
|
|
private boolean persistBlocks;
|
|
|
private UserGroupInformation fsOwner;
|
|
|
private String supergroup;
|
|
|
- private PermissionStatus defaultPermission;
|
|
|
private boolean standbyShouldCheckpoint;
|
|
|
|
|
|
// Scan interval is not configurable.
|
|
@@ -845,11 +841,6 @@ public class FSNamesystem implements Namesystem, FSClusterStats,
|
|
|
"must not be specified if HA is not enabled.");
|
|
|
}
|
|
|
|
|
|
- short filePermission = (short)conf.getInt(DFS_NAMENODE_UPGRADE_PERMISSION_KEY,
|
|
|
- DFS_NAMENODE_UPGRADE_PERMISSION_DEFAULT);
|
|
|
- this.defaultPermission = PermissionStatus.createImmutable(
|
|
|
- fsOwner.getShortUserName(), supergroup, new FsPermission(filePermission));
|
|
|
-
|
|
|
this.serverDefaults = new FsServerDefaults(
|
|
|
conf.getLongBytes(DFS_BLOCK_SIZE_KEY, DFS_BLOCK_SIZE_DEFAULT),
|
|
|
conf.getInt(DFS_BYTES_PER_CHECKSUM_KEY, DFS_BYTES_PER_CHECKSUM_DEFAULT),
|