diff --git a/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azure/AzureNativeFileSystemStore.java b/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azure/AzureNativeFileSystemStore.java index 3fa1a62512..d0262208cb 100644 --- a/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azure/AzureNativeFileSystemStore.java +++ b/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azure/AzureNativeFileSystemStore.java @@ -852,7 +852,6 @@ public class AzureNativeFileSystemStore implements NativeFileSystemStore { rootDirectory = container.getDirectoryReference(""); canCreateOrModifyContainer = true; - tolerateOobAppends = false; } /** @@ -1911,8 +1910,7 @@ public class AzureNativeFileSystemStore implements NativeFileSystemStore { // If reads concurrent to OOB writes are allowed, the interception will reset // the conditional header on all Azure blob storage read requests. if (bindConcurrentOOBIo) { - SendRequestIntercept.bind(storageInteractionLayer.getCredentials(), - operationContext, true); + SendRequestIntercept.bind(operationContext); } if (testHookOperationContext != null) { diff --git a/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azure/SendRequestIntercept.java b/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azure/SendRequestIntercept.java index 25c9eb42ea..924ecd30b3 100644 --- a/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azure/SendRequestIntercept.java +++ b/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azure/SendRequestIntercept.java @@ -35,7 +35,7 @@ import com.microsoft.azure.storage.StorageException; /** * Manages the lifetime of binding on the operation contexts to intercept send - * request events to Azure storage. + * request events to Azure storage and allow concurrent OOB I/Os. */ @InterfaceAudience.Private public final class SendRequestIntercept extends StorageEvent { @@ -43,70 +43,22 @@ public final class SendRequestIntercept extends StorageEvent