You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kudu.apache.org by ad...@apache.org on 2019/10/02 04:11:21 UTC

[kudu] 04/05: AsyncKuduClient: improve debug-level getTableKeyRanges logging

This is an automated email from the ASF dual-hosted git repository.

adar pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kudu.git

commit 3f6d3c46e8ca4cf5898eec50d61dbe91caa170e5
Author: Adar Dembo <ad...@cloudera.com>
AuthorDate: Tue Oct 1 14:01:00 2019 -0700

    AsyncKuduClient: improve debug-level getTableKeyRanges logging
    
    We've been seeing the occasional TestSplitKeyRange failure that's hard to
    debug because the test makes multiple getTableKeyRanges() calls and it's not
    clear to which call each line of output applies.
    
    Change-Id: I5efb5b04db725741f20ec6b1b64849b029ce6db3
    Reviewed-on: http://gerrit.cloudera.org:8080/14336
    Tested-by: Kudu Jenkins
    Reviewed-by: Alexey Serbin <as...@cloudera.com>
---
 .../src/main/java/org/apache/kudu/client/AsyncKuduClient.java          | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/java/kudu-client/src/main/java/org/apache/kudu/client/AsyncKuduClient.java b/java/kudu-client/src/main/java/org/apache/kudu/client/AsyncKuduClient.java
index ba3824a..8f5050b 100644
--- a/java/kudu-client/src/main/java/org/apache/kudu/client/AsyncKuduClient.java
+++ b/java/kudu-client/src/main/java/org/apache/kudu/client/AsyncKuduClient.java
@@ -2006,13 +2006,14 @@ public class AsyncKuduClient implements AutoCloseable {
                                          fakeRpc)
                           .addCallbackDeferring(resp -> {
                             final List<KeyRange> ranges = Lists.newArrayList();
+                            LOG.debug("Key ranges for {}", table.getName());
                             for (Common.KeyRangePB pb : resp.getKeyRanges()) {
                               KeyRange newRange = new KeyRange(tablet,
                                                                pb.getStartPrimaryKey().toByteArray(),
                                                                pb.getStopPrimaryKey().toByteArray(),
                                                                pb.getSizeBytesEstimates());
                               ranges.add(newRange);
-                              LOG.debug("Add key range {}", newRange);
+                              LOG.debug(newRange.toString());
                             }
                             return Deferred.fromResult(ranges);
                           }));