|
@@ -32,7 +32,9 @@ import org.apache.hadoop.fs.FileSystem;
|
|
|
import org.apache.hadoop.fs.Path;
|
|
|
import org.apache.hadoop.fs.PathIOException;
|
|
|
import org.apache.hadoop.fs.FileStatus;
|
|
|
+import org.apache.hadoop.fs.azurebfs.constants.FSOperationType;
|
|
|
import org.apache.hadoop.fs.azurebfs.utils.AclTestHelpers;
|
|
|
+import org.apache.hadoop.fs.azurebfs.utils.TracingHeaderValidator;
|
|
|
import org.apache.hadoop.fs.permission.AclEntry;
|
|
|
import org.apache.hadoop.fs.permission.AclStatus;
|
|
|
import org.apache.hadoop.fs.permission.FsAction;
|
|
@@ -88,7 +90,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testModifyAclEntries() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
fs.mkdirs(path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
|
|
@@ -121,7 +123,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testModifyAclEntriesOnlyAccess() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
fs.create(path).close();
|
|
|
fs.setPermission(path, FsPermission.createImmutable((short) RW_R));
|
|
@@ -145,7 +147,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testModifyAclEntriesOnlyDefault() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -168,7 +170,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testModifyAclEntriesMinimal() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
fs.create(path).close();
|
|
|
fs.setPermission(path, FsPermission.createImmutable((short) RW_R));
|
|
@@ -186,7 +188,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testModifyAclEntriesMinimalDefault() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -206,7 +208,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testModifyAclEntriesCustomMask() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
fs.create(path).close();
|
|
|
fs.setPermission(path, FsPermission.createImmutable((short) RW_R));
|
|
@@ -225,7 +227,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testModifyAclEntriesStickyBit() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) 01750));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -255,7 +257,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test(expected=FileNotFoundException.class)
|
|
|
public void testModifyAclEntriesPathNotFound() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
// Path has not been created.
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -269,7 +271,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test (expected=Exception.class)
|
|
|
public void testModifyAclEntriesDefaultOnFile() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
fs.create(path).close();
|
|
|
fs.setPermission(path, FsPermission.createImmutable((short) RW_R));
|
|
@@ -281,7 +283,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testModifyAclEntriesWithDefaultMask() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -305,7 +307,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testModifyAclEntriesWithAccessMask() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -326,7 +328,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test(expected=PathIOException.class)
|
|
|
public void testModifyAclEntriesWithDuplicateEntries() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -342,7 +344,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testRemoveAclEntries() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -370,7 +372,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testRemoveAclEntriesOnlyAccess() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
fs.create(path).close();
|
|
|
fs.setPermission(path, FsPermission.createImmutable((short) RW_R));
|
|
@@ -395,7 +397,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testRemoveAclEntriesOnlyDefault() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -422,7 +424,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testRemoveAclEntriesMinimal() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
fs.create(path).close();
|
|
|
fs.setPermission(path, FsPermission.createImmutable((short) RWX_RW));
|
|
@@ -445,7 +447,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testRemoveAclEntriesMinimalDefault() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -473,7 +475,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testRemoveAclEntriesStickyBit() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) 01750));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -501,7 +503,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test(expected=FileNotFoundException.class)
|
|
|
public void testRemoveAclEntriesPathNotFound() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
// Path has not been created.
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -512,7 +514,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test(expected=PathIOException.class)
|
|
|
public void testRemoveAclEntriesAccessMask() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -526,7 +528,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test(expected=PathIOException.class)
|
|
|
public void testRemoveAclEntriesDefaultMask() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -540,7 +542,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test(expected=PathIOException.class)
|
|
|
public void testRemoveAclEntriesWithDuplicateEntries() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -556,7 +558,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testRemoveDefaultAcl() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -578,7 +580,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testRemoveDefaultAclOnlyAccess() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
fs.create(path).close();
|
|
|
fs.setPermission(path, FsPermission.createImmutable((short) RW_R));
|
|
@@ -600,7 +602,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testRemoveDefaultAclOnlyDefault() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -616,7 +618,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testRemoveDefaultAclMinimal() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
fs.removeDefaultAcl(path);
|
|
@@ -629,7 +631,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testRemoveDefaultAclStickyBit() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) 01750));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -651,7 +653,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test(expected=FileNotFoundException.class)
|
|
|
public void testRemoveDefaultAclPathNotFound() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
// Path has not been created.
|
|
|
fs.removeDefaultAcl(path);
|
|
@@ -660,7 +662,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testRemoveAcl() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -682,7 +684,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testRemoveAclMinimalAcl() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
fs.create(path).close();
|
|
|
fs.setPermission(path, FsPermission.createImmutable((short) RW_R));
|
|
@@ -696,7 +698,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testRemoveAclStickyBit() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) 01750));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -716,7 +718,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testRemoveAclOnlyDefault() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -735,7 +737,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test(expected=FileNotFoundException.class)
|
|
|
public void testRemoveAclPathNotFound() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
// Path has not been created.
|
|
|
fs.removeAcl(path);
|
|
@@ -744,7 +746,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testSetAcl() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -770,7 +772,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testSetAclOnlyAccess() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
fs.create(path).close();
|
|
|
fs.setPermission(path, FsPermission.createImmutable((short) RW_R));
|
|
@@ -791,7 +793,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testSetAclOnlyDefault() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -811,7 +813,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testSetAclMinimal() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
fs.create(path).close();
|
|
|
fs.setPermission(path, FsPermission.createImmutable((short) RW_R_R));
|
|
@@ -835,7 +837,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testSetAclMinimalDefault() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -855,7 +857,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testSetAclCustomMask() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
fs.create(path).close();
|
|
|
fs.setPermission(path, FsPermission.createImmutable((short) RW_R));
|
|
@@ -877,7 +879,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testSetAclStickyBit() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) 01750));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -903,7 +905,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test(expected=FileNotFoundException.class)
|
|
|
public void testSetAclPathNotFound() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
// Path has not been created.
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -917,7 +919,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test(expected=Exception.class)
|
|
|
public void testSetAclDefaultOnFile() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
fs.create(path).close();
|
|
|
fs.setPermission(path, FsPermission.createImmutable((short) RW_R));
|
|
@@ -929,7 +931,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testSetAclDoesNotChangeDefaultMask() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -953,7 +955,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test(expected=PathIOException.class)
|
|
|
public void testSetAclWithDuplicateEntries() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -965,7 +967,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testSetPermission() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -992,7 +994,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testSetPermissionOnlyAccess() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
fs.create(path).close();
|
|
|
fs.setPermission(path, FsPermission.createImmutable((short) RW_R));
|
|
@@ -1014,7 +1016,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testSetPermissionOnlyDefault() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -1038,7 +1040,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testDefaultAclNewFile() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -1058,7 +1060,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Ignore // wait umask fix to be deployed
|
|
|
public void testOnlyAccessAclNewFile() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -1075,7 +1077,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testDefaultMinimalAclNewFile() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -1094,7 +1096,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testDefaultAclNewDir() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -1120,7 +1122,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testOnlyAccessAclNewDir() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -1137,7 +1139,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testDefaultMinimalAclNewDir() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -1159,7 +1161,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testDefaultAclNewFileWithMode() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -1181,7 +1183,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testDefaultAclNewDirWithMode() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short) RWX_RX_RX));
|
|
|
List<AclEntry> aclSpec = Lists.newArrayList(
|
|
@@ -1205,7 +1207,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testDefaultAclRenamedFile() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
Path dirPath = new Path(path, "dir");
|
|
|
FileSystem.mkdirs(fs, dirPath, FsPermission.createImmutable((short) RWX_RX));
|
|
@@ -1216,7 +1218,12 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
fs.create(filePath).close();
|
|
|
fs.setPermission(filePath, FsPermission.createImmutable((short) RW_R));
|
|
|
Path renamedFilePath = new Path(dirPath, "file1");
|
|
|
+
|
|
|
+ fs.registerListener(new TracingHeaderValidator(
|
|
|
+ fs.getAbfsStore().getAbfsConfiguration().getClientCorrelationId(),
|
|
|
+ fs.getFileSystemId(), FSOperationType.RENAME, true, 0));
|
|
|
fs.rename(filePath, renamedFilePath);
|
|
|
+ fs.registerListener(null);
|
|
|
AclEntry[] expected = new AclEntry[] { };
|
|
|
AclStatus s = fs.getAclStatus(renamedFilePath);
|
|
|
AclEntry[] returned = s.getEntries().toArray(new AclEntry[0]);
|
|
@@ -1227,7 +1234,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testDefaultAclRenamedDir() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
path = new Path(testRoot, UUID.randomUUID().toString());
|
|
|
Path dirPath = new Path(path, "dir");
|
|
|
FileSystem.mkdirs(fs, dirPath, FsPermission.createImmutable((short) RWX_RX));
|
|
@@ -1248,39 +1255,58 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testEnsureAclOperationWorksForRoot() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- assumeTrue(fs.getIsNamespaceEnabled());
|
|
|
+ assumeTrue(getIsNamespaceEnabled(fs));
|
|
|
|
|
|
Path rootPath = new Path("/");
|
|
|
|
|
|
List<AclEntry> aclSpec1 = Lists.newArrayList(
|
|
|
aclEntry(DEFAULT, GROUP, FOO, ALL),
|
|
|
aclEntry(ACCESS, GROUP, BAR, ALL));
|
|
|
+
|
|
|
+ fs.registerListener(new TracingHeaderValidator(
|
|
|
+ fs.getAbfsStore().getAbfsConfiguration().getClientCorrelationId(),
|
|
|
+ fs.getFileSystemId(), FSOperationType.SET_ACL, true, 0));
|
|
|
fs.setAcl(rootPath, aclSpec1);
|
|
|
+
|
|
|
+ fs.setListenerOperation(FSOperationType.GET_ACL_STATUS);
|
|
|
fs.getAclStatus(rootPath);
|
|
|
|
|
|
+ fs.setListenerOperation(FSOperationType.SET_OWNER);
|
|
|
fs.setOwner(rootPath, TEST_OWNER, TEST_GROUP);
|
|
|
+ fs.setListenerOperation(FSOperationType.SET_PERMISSION);
|
|
|
fs.setPermission(rootPath, new FsPermission("777"));
|
|
|
|
|
|
List<AclEntry> aclSpec2 = Lists.newArrayList(
|
|
|
aclEntry(DEFAULT, USER, FOO, ALL),
|
|
|
aclEntry(ACCESS, USER, BAR, ALL));
|
|
|
+ fs.setListenerOperation(FSOperationType.MODIFY_ACL);
|
|
|
fs.modifyAclEntries(rootPath, aclSpec2);
|
|
|
+ fs.setListenerOperation(FSOperationType.REMOVE_ACL_ENTRIES);
|
|
|
fs.removeAclEntries(rootPath, aclSpec2);
|
|
|
+ fs.setListenerOperation(FSOperationType.REMOVE_DEFAULT_ACL);
|
|
|
fs.removeDefaultAcl(rootPath);
|
|
|
+ fs.setListenerOperation(FSOperationType.REMOVE_ACL);
|
|
|
fs.removeAcl(rootPath);
|
|
|
}
|
|
|
|
|
|
@Test
|
|
|
public void testSetOwnerForNonNamespaceEnabledAccount() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- Assume.assumeTrue(!fs.getIsNamespaceEnabled());
|
|
|
+ AbfsConfiguration conf = fs.getAbfsStore().getAbfsConfiguration();
|
|
|
+ Assume.assumeTrue(!getIsNamespaceEnabled(fs));
|
|
|
final Path filePath = new Path(methodName.getMethodName());
|
|
|
fs.create(filePath);
|
|
|
|
|
|
assertTrue(fs.exists(filePath));
|
|
|
|
|
|
+ TracingHeaderValidator tracingHeaderValidator = new TracingHeaderValidator(
|
|
|
+ conf.getClientCorrelationId(), fs.getFileSystemId(),
|
|
|
+ FSOperationType.GET_FILESTATUS, false, 0);
|
|
|
+ fs.registerListener(tracingHeaderValidator);
|
|
|
FileStatus oldFileStatus = fs.getFileStatus(filePath);
|
|
|
+ tracingHeaderValidator.setOperation(FSOperationType.SET_OWNER);
|
|
|
fs.setOwner(filePath, TEST_OWNER, TEST_GROUP);
|
|
|
+ fs.registerListener(null);
|
|
|
FileStatus newFileStatus = fs.getFileStatus(filePath);
|
|
|
|
|
|
assertEquals(oldFileStatus.getOwner(), newFileStatus.getOwner());
|
|
@@ -1290,7 +1316,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testSetPermissionForNonNamespaceEnabledAccount() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- Assume.assumeTrue(!fs.getIsNamespaceEnabled());
|
|
|
+ Assume.assumeTrue(!getIsNamespaceEnabled(fs));
|
|
|
final Path filePath = new Path(methodName.getMethodName());
|
|
|
fs.create(filePath);
|
|
|
|
|
@@ -1309,7 +1335,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testModifyAclEntriesForNonNamespaceEnabledAccount() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- Assume.assumeTrue(!fs.getIsNamespaceEnabled());
|
|
|
+ Assume.assumeTrue(!getIsNamespaceEnabled(fs));
|
|
|
final Path filePath = new Path(methodName.getMethodName());
|
|
|
fs.create(filePath);
|
|
|
try {
|
|
@@ -1326,7 +1352,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testRemoveAclEntriesEntriesForNonNamespaceEnabledAccount() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- Assume.assumeTrue(!fs.getIsNamespaceEnabled());
|
|
|
+ Assume.assumeTrue(!getIsNamespaceEnabled(fs));
|
|
|
final Path filePath = new Path(methodName.getMethodName());
|
|
|
fs.create(filePath);
|
|
|
try {
|
|
@@ -1343,7 +1369,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testRemoveDefaultAclForNonNamespaceEnabledAccount() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- Assume.assumeTrue(!fs.getIsNamespaceEnabled());
|
|
|
+ Assume.assumeTrue(!getIsNamespaceEnabled(fs));
|
|
|
final Path filePath = new Path(methodName.getMethodName());
|
|
|
fs.create(filePath);
|
|
|
try {
|
|
@@ -1357,7 +1383,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testRemoveAclForNonNamespaceEnabledAccount() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- Assume.assumeTrue(!fs.getIsNamespaceEnabled());
|
|
|
+ Assume.assumeTrue(!getIsNamespaceEnabled(fs));
|
|
|
final Path filePath = new Path(methodName.getMethodName());
|
|
|
fs.create(filePath);
|
|
|
try {
|
|
@@ -1371,7 +1397,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testSetAclForNonNamespaceEnabledAccount() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- Assume.assumeTrue(!fs.getIsNamespaceEnabled());
|
|
|
+ Assume.assumeTrue(!getIsNamespaceEnabled(fs));
|
|
|
final Path filePath = new Path(methodName.getMethodName());
|
|
|
fs.create(filePath);
|
|
|
try {
|
|
@@ -1388,7 +1414,7 @@ public class ITestAzureBlobFilesystemAcl extends AbstractAbfsIntegrationTest {
|
|
|
@Test
|
|
|
public void testGetAclStatusForNonNamespaceEnabledAccount() throws Exception {
|
|
|
final AzureBlobFileSystem fs = this.getFileSystem();
|
|
|
- Assume.assumeTrue(!fs.getIsNamespaceEnabled());
|
|
|
+ Assume.assumeTrue(!getIsNamespaceEnabled(fs));
|
|
|
final Path filePath = new Path(methodName.getMethodName());
|
|
|
fs.create(filePath);
|
|
|
try {
|