fix test

ABFSDriver · Jun 18, 2024 · 513aa52 · 513aa52
1 parent 63c060b
commit 513aa52
Showing 1 changed file with 2 additions and 10 deletions.
diff --git a/...doop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/ITestAzureBlobFileSystemMkDir.java b/...doop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/ITestAzureBlobFileSystemMkDir.java
@@ -127,11 +127,7 @@ public void testCreateDirOverwrite(boolean enableConditionalCreateOverwrite)
 
     // One request to server
     AbfsClient client = fs.getAbfsStore().getClientHandler().getIngressClient();
-    if (client instanceof AbfsBlobClient) {
-      mkdirRequestCount+=2;
-    } else {
-      mkdirRequestCount++;
-    }
+    mkdirRequestCount++;
 
     assertAbfsStatistics(
         CONNECTIONS_MADE,
@@ -143,11 +139,7 @@ public void testCreateDirOverwrite(boolean enableConditionalCreateOverwrite)
     fs.mkdirs(dirPath);
 
     // One request to server
-    if (client instanceof AbfsBlobClient) {
-      mkdirRequestCount+=2;
-    } else {
-      mkdirRequestCount++;
-    }
+    mkdirRequestCount++;
 
     assertAbfsStatistics(
         CONNECTIONS_MADE,