You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by jn...@apache.org on 2014/11/08 01:03:10 UTC
[09/16] incubator-drill git commit: DRILL-1578: Accountor message
should be trace messages
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 <pc...@maprtech.com>
Authored: Thu Nov 6 14:47:26 2014 -0800
Committer: Jinfeng Ni <jn...@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);
}
}