Added comments

apache · Jun 29, 2022 · 12ae508 · 12ae508
1 parent 6057e1f
commit 12ae508
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/...p-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/AzureBlobFileSystem.java b/...p-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/AzureBlobFileSystem.java
@@ -159,6 +159,11 @@ public class AzureBlobFileSystem extends FileSystem
   public void initialize(URI uri, Configuration configuration)
       throws IOException {
     uri = ensureAuthority(uri, configuration);
+    /*
+      If the clientCorrelationId is set, disable the cache so that
+      a new instance is created and hence incorrect correlation is not
+      recorded
+     */
     String correlationId = configuration.get(FS_AZURE_CLIENT_CORRELATIONID);
     if(correlationId != null && !correlationId.equals("")) {
       String scheme = uri.getScheme();