diff --git a/hadoop-common-project/hadoop-common/CHANGES.txt b/hadoop-common-project/hadoop-common/CHANGES.txt index 8d3f9f5784..763377c592 100644 --- a/hadoop-common-project/hadoop-common/CHANGES.txt +++ b/hadoop-common-project/hadoop-common/CHANGES.txt @@ -626,6 +626,8 @@ Release 2.7.0 - UNRELEASED HADOOP-11440. Use "test.build.data" instead of "build.test.dir" for testing in ClientBaseWithFixes. (Kengo Seki via aajisaka) + HADOOP-11607. Reduce log spew in S3AFileSystem. (Lei (Eddy) Xu via stevel) + OPTIMIZATIONS HADOOP-11323. WritableComparator#compare keeps reference to byte array. diff --git a/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3AFileSystem.java b/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3AFileSystem.java index 4de5c13b70..eaa5f2d902 100644 --- a/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3AFileSystem.java +++ b/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3AFileSystem.java @@ -354,7 +354,9 @@ private Path keyToPath(String key) { public FSDataInputStream open(Path f, int bufferSize) throws IOException { - LOG.info("Opening '" + f + "' for reading"); + if (LOG.isDebugEnabled()) { + LOG.debug("Opening '{}' for reading.", f); + } final FileStatus fileStatus = getFileStatus(f); if (fileStatus.isDirectory()) { throw new FileNotFoundException("Can't open " + f + " because it is a directory"); @@ -425,7 +427,9 @@ public FSDataOutputStream append(Path f, int bufferSize, * @return true if rename is successful */ public boolean rename(Path src, Path dst) throws IOException { - LOG.info("Rename path " + src + " to " + dst); + if (LOG.isDebugEnabled()) { + LOG.debug("Rename path {} to {}", src, dst); + } String srcKey = pathToKey(src); String dstKey = pathToKey(dst); @@ -441,7 +445,7 @@ public boolean rename(Path src, Path dst) throws IOException { try { srcStatus = getFileStatus(src); } catch (FileNotFoundException e) { - LOG.info("rename: src not found " + src); + LOG.error("rename: src not found {}", src); return false; }