From 0f5a250ac212d5ded5c3d437565329838cbafcbf Mon Sep 17 00:00:00 2001 From: Ashish Singhi Date: Fri, 16 Jun 2017 10:43:56 +0530 Subject: [PATCH] HBASE-18212 reduce log level for unbuffer warning. In Standalone mode with local filesystem HBase logs Warning message:Failed to invoke 'unbuffer' method in class org.apache.hadoop.fs.FSDataInputStream Signed-off-by: Umesh Agashe Signed-off-by: Sean Busbey --- .../hbase/io/FSDataInputStreamWrapper.java | 27 +++++++++++-------- 1 file changed, 16 insertions(+), 11 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/FSDataInputStreamWrapper.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/FSDataInputStreamWrapper.java index 25a33734684..fb6ebeb5ba3 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/FSDataInputStreamWrapper.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/FSDataInputStreamWrapper.java @@ -42,6 +42,7 @@ import com.google.common.annotations.VisibleForTesting; @InterfaceAudience.Private public class FSDataInputStreamWrapper implements Closeable { private static final Log LOG = LogFactory.getLog(FSDataInputStreamWrapper.class); + private static final boolean isLogTraceEnabled = LOG.isTraceEnabled(); private final HFileSystem hfs; private final Path path; @@ -274,10 +275,11 @@ public class FSDataInputStreamWrapper implements Closeable { try { this.unbuffer = streamClass.getDeclaredMethod("unbuffer"); } catch (NoSuchMethodException | SecurityException e) { - LOG.warn("Failed to find 'unbuffer' method in class " + streamClass - + " . So there may be a TCP socket connection " - + "left open in CLOSE_WAIT state.", - e); + if (isLogTraceEnabled) { + LOG.trace("Failed to find 'unbuffer' method in class " + streamClass + + " . So there may be a TCP socket connection " + + "left open in CLOSE_WAIT state.", e); + } return; } this.instanceOfCanUnbuffer = true; @@ -289,15 +291,18 @@ public class FSDataInputStreamWrapper implements Closeable { try { this.unbuffer.invoke(wrappedStream); } catch (IllegalAccessException | IllegalArgumentException | InvocationTargetException e) { - LOG.warn("Failed to invoke 'unbuffer' method in class " + streamClass - + " . So there may be a TCP socket connection left open in CLOSE_WAIT state.", - e); + if (isLogTraceEnabled) { + LOG.trace("Failed to invoke 'unbuffer' method in class " + streamClass + + " . So there may be a TCP socket connection left open in CLOSE_WAIT state.", e); + } } } else { - LOG.warn("Failed to find 'unbuffer' method in class " + streamClass - + " . So there may be a TCP socket connection " - + "left open in CLOSE_WAIT state. For more details check " - + "https://issues.apache.org/jira/browse/HBASE-9393"); + if (isLogTraceEnabled) { + LOG.trace("Failed to find 'unbuffer' method in class " + streamClass + + " . So there may be a TCP socket connection " + + "left open in CLOSE_WAIT state. For more details check " + + "https://issues.apache.org/jira/browse/HBASE-9393"); + } } } }