From b307f18a584b207782124bee0a377b2dbfc13df0 Mon Sep 17 00:00:00 2001 From: jianghuazhu <740087514@qq.com> Date: Wed, 10 Nov 2021 10:32:52 +0800 Subject: [PATCH] HDFS-16301. Improve BenchmarkThroughput#SIZE naming standardization. (#3622) --- .../org/apache/hadoop/hdfs/BenchmarkThroughput.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/BenchmarkThroughput.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/BenchmarkThroughput.java index 515a0a0719..e22e07e802 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/BenchmarkThroughput.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/BenchmarkThroughput.java @@ -187,7 +187,7 @@ public int run(String[] args) throws IOException { } Configuration conf = getConf(); // the size of the file to write - long SIZE = conf.getLong("dfsthroughput.file.size", + long fileSize = conf.getLong("dfsthroughput.file.size", 10L * 1024 * 1024 * 1024); BUFFER_SIZE = conf.getInt("dfsthroughput.buffer.size", 4 * 1024); @@ -203,9 +203,9 @@ public int run(String[] args) throws IOException { ChecksumFileSystem checkedLocal = FileSystem.getLocal(conf); FileSystem rawLocal = checkedLocal.getRawFileSystem(); for(int i=0; i < reps; ++i) { - writeAndReadLocalFile("local", conf, SIZE); - writeAndReadFile(rawLocal, "raw", conf, SIZE); - writeAndReadFile(checkedLocal, "checked", conf, SIZE); + writeAndReadLocalFile("local", conf, fileSize); + writeAndReadFile(rawLocal, "raw", conf, fileSize); + writeAndReadFile(checkedLocal, "checked", conf, fileSize); } MiniDFSCluster cluster = null; try { @@ -214,7 +214,7 @@ public int run(String[] args) throws IOException { cluster.waitActive(); FileSystem dfs = cluster.getFileSystem(); for(int i=0; i < reps; ++i) { - writeAndReadFile(dfs, "dfs", conf, SIZE); + writeAndReadFile(dfs, "dfs", conf, fileSize); } } finally { if (cluster != null) {