DRILL-1578: Accountor message should be trace messages
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/30c40eac Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/30c40eac Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/30c40eac Branch: refs/heads/master Commit: 30c40eac72d53b4c75631a313376a31a1b68efbb Parents: 1d7f621 Author: Parth Chandra <pchan...@maprtech.com> Authored: Thu Nov 6 14:47:26 2014 -0800 Committer: Jinfeng Ni <j...@maprtech.com> Committed: Fri Nov 7 10:50:56 2014 -0800 ---------------------------------------------------------------------- .../org/apache/drill/exec/memory/Accountor.java | 22 ++++++++++---------- 1 file changed, 11 insertions(+), 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/30c40eac/exec/java-exec/src/main/java/org/apache/drill/exec/memory/Accountor.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/memory/Accountor.java b/exec/java-exec/src/main/java/org/apache/drill/exec/memory/Accountor.java index 0874585..0a8c405 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/memory/Accountor.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/memory/Accountor.java @@ -133,7 +133,7 @@ public class Accountor { } public boolean reserve(long size) { - logger.debug("Fragment:"+fragmentStr+" Reserved "+size+" bytes. Total Allocated: "+getAllocation()); + logger.trace("Fragment:"+fragmentStr+" Reserved "+size+" bytes. Total Allocated: "+getAllocation()); return remainder.get(size, this.applyFragmentLimit); } @@ -188,7 +188,7 @@ public class Accountor { if (parent != null){ parent.addFragmentContext(c); }else { - if(logger.isDebugEnabled()) { + if(logger.isTraceEnabled()) { FragmentHandle hndle; String fragStr; if(c!=null) { @@ -205,7 +205,7 @@ public class Accountor { sb.append("\n"); } - logger.debug("Fragment " + fragStr + " added to root accountor.\n"+sb.toString()); + logger.trace("Fragment " + fragStr + " added to root accountor.\n"+sb.toString()); } synchronized(this) { fragmentContexts.add(c); @@ -230,7 +230,7 @@ public class Accountor { fragStr = "[Null Context]"; } fragStr += " (Object Id: " + System.identityHashCode(c) + ")"; - logger.debug("Fragment " + fragStr + " removed from root accountor"); + logger.trace("Fragment " + fragStr + " removed from root accountor"); } synchronized(this) { fragmentContexts.remove(c); @@ -261,8 +261,8 @@ public class Accountor { allocatedMemory += fragment.getAllocator().getAllocatedMemory(); } } - if(logger.isDebugEnabled()) { - logger.info("Resetting Fragment Memory Limit: total Available memory== "+total + if(logger.isTraceEnabled()) { + logger.trace("Resetting Fragment Memory Limit: total Available memory== "+total +" Total Allocated Memory :"+allocatedMemory +" Number of fragments: "+nFragments + " fragmentMemOvercommitFactor: "+fragmentMemOvercommitFactor @@ -275,14 +275,14 @@ public class Accountor { fragment.setFragmentLimit((long) (rem * fragmentMemOvercommitFactor)); } } - if(logger.isDebugEnabled() && false){ + if(logger.isTraceEnabled() && false){ StringBuffer sb= new StringBuffer(); sb.append("[root](0:0)"); sb.append("Allocated memory: "); sb.append(this.getAllocation()); sb.append(" Fragment Limit: "); sb.append(this.getFragmentLimit()); - logger.debug(sb.toString()); + logger.trace(sb.toString()); for(FragmentContext fragment: fragmentContexts){ sb= new StringBuffer(); if (handle != null) { @@ -300,9 +300,9 @@ public class Accountor { sb.append(fragment.getAllocator().getAllocatedMemory()); sb.append(" Fragment Limit: "); sb.append(fragment.getAllocator().getFragmentLimit()); - logger.debug(sb.toString()); + logger.trace(sb.toString()); } - logger.debug("Resetting Complete"); + logger.trace("Resetting Complete"); } } } @@ -374,7 +374,7 @@ public class Accountor { if (parent != null && parent.parent==null) { // This is a fragment level accountor this.fragmentLimit=getAllocation()+add; this.remainder.setLimit(this.fragmentLimit); - logger.debug("Fragment "+fragmentStr+" memory limit set to "+this.fragmentLimit); + logger.trace("Fragment "+fragmentStr+" memory limit set to "+this.fragmentLimit); } }
