trafodion-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ansha...@apache.org
Subject [11/15] incubator-trafodion git commit: Update TrxRegionEndpoint.java.tmpl
Date Thu, 15 Sep 2016 22:48:06 GMT
Update TrxRegionEndpoint.java.tmpl

Project: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/commit/8c7a9dcc
Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/tree/8c7a9dcc
Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/diff/8c7a9dcc

Branch: refs/heads/master
Commit: 8c7a9dcc8a8e5b8911c21c68245c6cc9bf6054bc
Parents: 454aa50
Author: Sean Broeder <sean.broeder@esgyn.com>
Authored: Tue Sep 13 14:23:44 2016 -0700
Committer: GitHub <noreply@github.com>
Committed: Tue Sep 13 14:23:44 2016 -0700

----------------------------------------------------------------------
 .../transactional/TrxRegionEndpoint.java.tmpl    | 19 +++++++------------
 1 file changed, 7 insertions(+), 12 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-trafodion/blob/8c7a9dcc/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/coprocessor/transactional/TrxRegionEndpoint.java.tmpl
----------------------------------------------------------------------
diff --git a/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/coprocessor/transactional/TrxRegionEndpoint.java.tmpl
b/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/coprocessor/transactional/TrxRegionEndpoint.java.tmpl
index 30766ea..0bf28d2 100644
--- a/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/coprocessor/transactional/TrxRegionEndpoint.java.tmpl
+++ b/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/coprocessor/transactional/TrxRegionEndpoint.java.tmpl
@@ -4996,8 +4996,7 @@ CoprocessorService, Coprocessor {
                     + ", warning memory usage exceeds indicated percentage");
        }
        else {
-//          if (LOG.isTraceEnabled()) LOG.trace("TrxRegionEndpoint coprocessor: putRegionTx
- performing memoryPercentage "
-          LOG.info("TrxRegionEndpoint coprocessor: putRegionTx - performing memoryPercentage
"
+          if (LOG.isTraceEnabled()) LOG.trace("TrxRegionEndpoint coprocessor: putRegionTx
- performing memoryPercentage "
                              + memoryPercentage + ", generating memory usage exceeds indicated
percentage exception");
           mue = new MemoryUsageException("putRegionTx memory usage exceeds " + memoryUsageThreshold
                    + " percent, tid is " + tid);
@@ -5017,19 +5016,16 @@ CoprocessorService, Coprocessor {
           try {   
              putRegionTx(tid, put, autoCommit);
           } catch (Throwable e) {
-             LOG.error("TrxRegionEndpoint coprocessor:putRegionTx - tid " + tid + ", Caught
exception after  internal put - "
-                         + e.getMessage() + " " + stackTraceToString(e));
+             LOG.error("TrxRegionEndpoint coprocessor:putRegionTx - tid " + tid + ", Caught
exception after  internal put - ", e);
              t = e;
           }
 
-//          if (LOG.isTraceEnabled()) LOG.trace("TrxRegionEndpoint coprocessor: putRegionTx
- tid "  + tid + ", regionName " + regionInfo.getRegionNameAsString()
-          LOG.info("TrxRegionEndpoint coprocessor: putRegionTx - tid "  + tid + ", regionName
" + regionInfo.getRegionNameAsString()
+          if (LOG.isTraceEnabled()) LOG.trace("TrxRegionEndpoint coprocessor: putRegionTx
- tid "  + tid + ", regionName " + regionInfo.getRegionNameAsString()
                    + ", type " + type + ", row " + Bytes.toStringBinary(proto.getRow().toByteArray())
                     + ", row in hex " + Hex.encodeHexString(proto.getRow().toByteArray()));
        }
        else{
-//          if (LOG.isTraceEnabled()) LOG.trace("TrxRegionEndpoint coprocessor: putRegionTx
- tid "  + tid + ", regionName " + regionInfo.getRegionNameAsString()
-          LOG.info("TrxRegionEndpoint coprocessor: putRegionTx - tid "  + tid + ", regionName
" + regionInfo.getRegionNameAsString()
+          if (LOG.isTraceEnabled()) LOG.trace("TrxRegionEndpoint coprocessor: putRegionTx
- tid "  + tid + ", regionName " + regionInfo.getRegionNameAsString()
                     + "- no valid PUT type or does not contain a row");
        }
     }
@@ -5052,8 +5048,7 @@ CoprocessorService, Coprocessor {
 
     if (mue != null)
     {
-//      if (LOG.isTraceEnabled()) LOG.trace("TrxRegionEndpoint coprocessor: putRegionTx -
performing memoryPercentage " + memoryPercentage
-      LOG.info("TrxRegionEndpoint coprocessor: putRegionTx - performing memoryPercentage
" + memoryPercentage
+      if (LOG.isTraceEnabled()) LOG.trace("TrxRegionEndpoint coprocessor: putRegionTx - performing
memoryPercentage " + memoryPercentage
           + ", posting memory usage exceeds indicated percentage exception");
       putRegionTxResponseBuilder.setHasException(true);
       putRegionTxResponseBuilder.setException(mue.toString());
@@ -5088,10 +5083,10 @@ CoprocessorService, Coprocessor {
     boolean success = commitIfPossible(tid, tid, tid, 1, true, autoCommit);
     
     if (! success) {
-       LOG.info("putRegionTx - tid " + tid + " was not successful.  Throwing IOException
");
+       LOG.error("putRegionTx - tid " + tid + " was not successful.  Throwing IOException
");
        throw new IOException("putRegionTx - tid " + tid + " was not successful.  Throwing
IOException ");
     }
-    LOG.info("putRegionTx - tid " + tid + " EXIT successful.");
+    if (LOG.isTraceEnabled()) LOG.trace("putRegionTx - tid " + tid + " EXIT successful.");
   }
 
   /**


Mime
View raw message