From d09dbcc8fb6889e51d4d4c914eb6159e40845e9f Mon Sep 17 00:00:00 2001 From: Da Zhou Date: Mon, 17 Dec 2018 11:08:17 +0000 Subject: [PATCH] HADOOP-15972 ABFS: reduce list page size to to 500. Contributed by Da Zhou. --- .../org/apache/hadoop/fs/azurebfs/AzureBlobFileSystemStore.java | 2 +- .../java/org/apache/hadoop/fs/azurebfs/ITestAbfsClient.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/AzureBlobFileSystemStore.java b/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/AzureBlobFileSystemStore.java index 5d70b77de60..b2bd64f3c6c 100644 --- a/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/AzureBlobFileSystemStore.java +++ b/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/AzureBlobFileSystemStore.java @@ -107,7 +107,7 @@ public class AzureBlobFileSystemStore { private String primaryUserGroup; private static final String DATE_TIME_PATTERN = "E, dd MMM yyyy HH:mm:ss 'GMT'"; private static final String XMS_PROPERTIES_ENCODING = "ISO-8859-1"; - private static final int LIST_MAX_RESULTS = 5000; + private static final int LIST_MAX_RESULTS = 500; private static final int DELETE_DIRECTORY_TIMEOUT_MILISECONDS = 180000; private static final int RENAME_TIMEOUT_MILISECONDS = 180000; diff --git a/hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/ITestAbfsClient.java b/hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/ITestAbfsClient.java index f024f257b7d..0f231d83a8f 100644 --- a/hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/ITestAbfsClient.java +++ b/hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/ITestAbfsClient.java @@ -28,7 +28,7 @@ import org.junit.Test; * Test continuation token which has equal sign. */ public final class ITestAbfsClient extends AbstractAbfsIntegrationTest { - private static final int LIST_MAX_RESULTS = 5000; + private static final int LIST_MAX_RESULTS = 500; public ITestAbfsClient() throws Exception { super();