|
|
@@ -766,7 +766,7 @@ def test_fs_configuration(fs_config):
|
|
|
# Access root
|
|
|
try:
|
|
|
statbuf = fs.stats('/')
|
|
|
- if statbuf.user != 'hdfs':
|
|
|
+ if statbuf.user != DEFAULT_HDFS_SUPERUSER:
|
|
|
return [(fs_config.WEBHDFS_URL, _("Filesystem root '/' should be owned by 'hdfs'"))]
|
|
|
except Exception, ex:
|
|
|
LOG.info("%s -- Validation error: %s" % (fs, ex))
|