kudu-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t...@apache.org
Subject [1/2] incubator-kudu git commit: Clean up log messages in AsyncKuduSession
Date Fri, 01 Jul 2016 18:53:44 GMT
Repository: incubator-kudu
Updated Branches:
  refs/heads/master 200b8c286 -> 1ebfa6c66


Clean up log messages in AsyncKuduSession

Change-Id: I0307281234d163d1f1471335171104386ac281e4
Reviewed-on: http://gerrit.cloudera.org:8080/3554
Tested-by: Kudu Jenkins
Reviewed-by: Jean-Daniel Cryans <jdcryans@apache.org>


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

Branch: refs/heads/master
Commit: c7ecdf0ef6e771711a51f7384e31bec5ae9daa0b
Parents: 200b8c2
Author: Dan Burkert <dan@cloudera.com>
Authored: Fri Jul 1 10:13:55 2016 -0700
Committer: Jean-Daniel Cryans <jdcryans@apache.org>
Committed: Fri Jul 1 18:09:51 2016 +0000

----------------------------------------------------------------------
 .../src/main/java/org/kududb/client/AsyncKuduSession.java     | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-kudu/blob/c7ecdf0e/java/kudu-client/src/main/java/org/kududb/client/AsyncKuduSession.java
----------------------------------------------------------------------
diff --git a/java/kudu-client/src/main/java/org/kududb/client/AsyncKuduSession.java b/java/kudu-client/src/main/java/org/kududb/client/AsyncKuduSession.java
index a4f126b..3c5daa5 100644
--- a/java/kudu-client/src/main/java/org/kududb/client/AsyncKuduSession.java
+++ b/java/kudu-client/src/main/java/org/kududb/client/AsyncKuduSession.java
@@ -400,7 +400,7 @@ public class AsyncKuduSession implements SessionConfiguration {
    * @return the operation responses
    */
   private Deferred<List<OperationResponse>> doFlush(Buffer buffer) {
-    LOG.info("flushing buffer: {}", buffer);
+    LOG.debug("flushing buffer: {}", buffer);
     if (buffer.getOperations().isEmpty()) {
       // no-op.
       return Deferred.<List<OperationResponse>>fromResult(ImmutableList.<OperationResponse>of());
@@ -548,7 +548,6 @@ public class AsyncKuduSession implements SessionConfiguration {
 
           if (activeBufferSize + 1 >= mutationBufferSpace && inactiveBufferAvailable())
{
             // If the operation filled the buffer, then flush it.
-            LOG.debug("flushing full buffer: {}", activeBuffer);
             fullBuffer = activeBuffer;
             activeBuffer = null;
           } else if (activeBufferSize == 0) {
@@ -585,7 +584,6 @@ public class AsyncKuduSession implements SessionConfiguration {
     Preconditions.checkState(activeBuffer == null);
     activeBuffer = inactiveBuffers.remove();
     activeBuffer.reset();
-    LOG.trace("active buffer refreshed: {}", activeBuffer);
   }
 
   /**
@@ -734,7 +732,7 @@ public class AsyncKuduSession implements SessionConfiguration {
      * successfully flushed.
      */
     public void callbackFlushNotification() {
-      LOG.debug("callbackFlushNotification on {}", flushNotification);
+      LOG.trace("buffer flush notification fired: {}", this);
       flushNotification.callback(null);
     }
 
@@ -744,6 +742,7 @@ public class AsyncKuduSession implements SessionConfiguration {
      */
     @GuardedBy("monitor")
     public void reset() {
+      LOG.trace("buffer reset: {}", this);
       operations.clear();
       flushNotification = new Deferred<>();
       flusherTask = null;


Mime
View raw message