PR Checks

Author: anujmodi2021

hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services/AbfsBlobClient.java

@@ -1925,6 +1925,7 @@ private List<AbfsHttpHeader> getMetadataHeadersList(final Hashtable<String, Stri
    * @param listResultSchema List of entries returned by Blob Endpoint.
    * @param uri URI to be used for path conversion.
    * @return List of entries after removing duplicates.
+   * @throws IOException if path conversion fails.
    */
   @VisibleForTesting
   public ListResponseData filterDuplicateEntriesAndRenamePendingFiles(

hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services/AbfsHttpOperation.java

@@ -226,18 +226,6 @@ public final byte[] getListResultData() {
     return listResultData;
   }
 
-  @VisibleForTesting
-  public byte[] readDataFromStream(InputStream stream) throws IOException{
-    try (ByteArrayOutputStream buffer = new ByteArrayOutputStream()) {
-      byte[] tempBuffer = new byte[CLEAN_UP_BUFFER_SIZE];
-      int bytesRead;
-      while ((bytesRead = stream.read(tempBuffer, 0, CLEAN_UP_BUFFER_SIZE)) != -1) {
-        buffer.write(tempBuffer, 0, bytesRead);
-      }
-      return buffer.toByteArray();
-    }
-  }
-
   /**
    * Get response header value for the given headerKey.
    *
@@ -526,7 +514,14 @@ private void parseListPathResponse(final InputStream stream) throws IOException
     if (stream == null || listResultData != null) {
       return;
     }
-    listResultData = readDataFromStream(stream);
+    try (ByteArrayOutputStream buffer = new ByteArrayOutputStream()) {
+      byte[] tempBuffer = new byte[CLEAN_UP_BUFFER_SIZE];
+      int bytesRead;
+      while ((bytesRead = stream.read(tempBuffer, 0, CLEAN_UP_BUFFER_SIZE)) != -1) {
+        buffer.write(tempBuffer, 0, bytesRead);
+      }
+      listResultData = buffer.toByteArray();
+    }
   }
 
   public List<String> getBlockIdList() {