|
@@ -72,6 +72,7 @@ import org.apache.hadoop.hdfs.server.protocol.KeyUpdateCommand;
|
|
|
import org.apache.hadoop.hdfs.server.protocol.ReceivedDeletedBlockInfo;
|
|
|
import org.apache.hadoop.hdfs.util.LightWeightLinkedSet;
|
|
|
import org.apache.hadoop.net.Node;
|
|
|
+import org.apache.hadoop.security.UserGroupInformation;
|
|
|
import org.apache.hadoop.util.Daemon;
|
|
|
import org.apache.hadoop.util.Time;
|
|
|
|
|
@@ -322,6 +323,12 @@ public class BlockManager {
|
|
|
LOG.info(DFSConfigKeys.DFS_BLOCK_ACCESS_TOKEN_ENABLE_KEY + "=" + isEnabled);
|
|
|
|
|
|
if (!isEnabled) {
|
|
|
+ if (UserGroupInformation.isSecurityEnabled()) {
|
|
|
+ LOG.error("Security is enabled but block access tokens " +
|
|
|
+ "(via " + DFSConfigKeys.DFS_BLOCK_ACCESS_TOKEN_ENABLE_KEY + ") " +
|
|
|
+ "aren't enabled. This may cause issues " +
|
|
|
+ "when clients attempt to talk to a DataNode.");
|
|
|
+ }
|
|
|
return null;
|
|
|
}
|
|
|
|