drill-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j..@apache.org
Subject [09/16] incubator-drill git commit: DRILL-1578: Accountor message should be trace messages
Date Sat, 08 Nov 2014 00:03:10 GMT
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 <pchandra@maprtech.com>
Authored: Thu Nov 6 14:47:26 2014 -0800
Committer: Jinfeng Ni <jni@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);
     }
   }
 


Mime
View raw message